agentkapp

Documentation

Index

• func NewCommand() *cobra.Command
• type AgentIdHolder
  • func NewAgentIdHolder() *AgentIdHolder
• type App
  • func (a *App) Run(ctx context.Context) (retErr error)
• type LeaderElector
• type Runner

Functions

func NewCommand

func NewCommand() *cobra.Command

Types

type AgentIdHolder

type AgentIdHolder struct {
	// contains filtered or unexported fields
}

AgentIdHolder holds agent id of this agentk.

func NewAgentIdHolder

func NewAgentIdHolder() *AgentIdHolder

type App

type App struct {
	Log          *zap.Logger
	LogLevel     zap.AtomicLevel
	GrpcLogLevel zap.AtomicLevel
	AgentMeta    *modshared.AgentMeta
	AgentId      *AgentIdHolder
	// KasAddress specifies the address of kas.
	KasAddress                 string
	KasCACertFile              string
	KasHeaders                 []string
	ServiceAccountName         string
	ObservabilityListenNetwork string
	ObservabilityListenAddress string
	ObservabilityCertFile      string
	ObservabilityKeyFile       string
	TokenFile                  string
	K8sClientGetter            genericclioptions.RESTClientGetter
}

func (*App) Run

func (a *App) Run(ctx context.Context) (retErr error)

type LeaderElector

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

type Runner

type Runner interface {
	// RunWhenLeader runs f when it is elected as the leader.
	// Provided context signals done when leadership is lost or when the program is terminating.
	// f may be called, stopped, called multiple times, depending on leadership status.
	// The returned function can be used to signal f to stop if it's already running or to avoid running it
	// if elected as the leader. The returned function blocks until f returns.
	RunWhenLeader(f func(context.Context)) func()
}