agentkapp

type App struct {
	Log                *slog.Logger
	LogLevel           *slog.LevelVar
	GRPCLogLevel       *slog.LevelVar
	AgentMeta          *entity.AgentMeta
	AgentID            *syncz.ValueHolder[int64]
	GitLabExternalURL  *syncz.ValueHolder[url.URL]
	ServiceAccountName string

	// KASAddress specifies the address of kas.
	// This field is used as a flag. If set, agentk is in the agentk->kas communication mode.
	// If not set, kas->agentk mode is activated.
	KASAddress       string
	KASCACertFile    string
	KASHeaders       []string
	KASSkipTLSVerify bool
	KASTLSServerName string

	APIListenNetwork string
	APIListenAddress string
	APICertFile      string
	APIKeyFile       string
	APIJWTFile       string
	APICACertFile    string
	APIMTLS          bool

	PrivateAPIListenNetwork string
	PrivateAPIListenAddress string
	PrivateAPICertFile      string
	PrivateAPIKeyFile       string
	PrivateAPICACertFile    string
	PrivateAPIJWTFile       string

	ObservabilityListenNetwork string
	ObservabilityListenAddress string
	ObservabilityCertFile      string
	ObservabilityKeyFile       string

	TokenFile       string
	AgentToken      api.AgentToken
	K8sClientGetter genericclioptions.RESTClientGetter
}

type CancelRunWhenLeaderFunc func()

type LeaderElector interface {
	Run(ctx context.Context, onStartedLeading, onStoppedLeading func())
}

type ModuleStartFunc func()

type ModuleStopFunc func() ModuleStopWaitFunc

type ModuleStopWaitFunc func(context.Context) error

type Runner interface {
	// RunWhenLeader registers the given start and stop functions for this module with the leader runner.
	// When the leader runner is elected as the leader it will execute the start function and
	// when the leader runner lost the leadership it will execute the stop function.
	// The start function must be able to be triggered multiple times (with intermediate stop executions)
	// without having to rely on a new agent configuration.
	// The function that is returned must be used to unregister the module
	// from the leader runner in case a shutdown is initiated or a previously registered start function
	// became invalid, for example because a new agent configuration turned out to be invalid.
	RunWhenLeader(ctx context.Context, startFn ModuleStartFunc, stopFunc ModuleStopFunc) (CancelRunWhenLeaderFunc, error)
}