Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCommand ¶
Types ¶
type AgentIdHolder ¶ added in v15.4.0
type AgentIdHolder struct {
// contains filtered or unexported fields
}
AgentIdHolder holds agent id of this agentk.
func NewAgentIdHolder ¶ added in v15.4.0
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 }
type LeaderElector ¶ added in v15.4.0
type Runner ¶ added in v15.4.0
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() }
Click to show internal directories.
Click to hide internal directories.