spoke

Documentation

Index

• Constants
• type WorkAgentConfig
  • func NewWorkAgentConfig(commonOpts *commonoptions.AgentOptions, opts *WorkloadAgentOptions) *WorkAgentConfig
  • func (o *WorkAgentConfig) RunWorkloadAgent(ctx context.Context, controllerContext *controllercmd.ControllerContext) error
• type WorkloadAgentOptions
  • func NewWorkloadAgentOptions() *WorkloadAgentOptions
  • func (o *WorkloadAgentOptions) AddFlags(fs *pflag.FlagSet)
• type WorkloadSourceDriver

Constants

const (
	KubeDriver = "kube"
	MQTTDriver = "mqtt"
)

Types

type WorkAgentConfig

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

func NewWorkAgentConfig

func NewWorkAgentConfig(commonOpts *commonoptions.AgentOptions, opts *WorkloadAgentOptions) *WorkAgentConfig

NewWorkAgentConfig returns a WorkAgentConfig

func (*WorkAgentConfig) RunWorkloadAgent

func (o *WorkAgentConfig) RunWorkloadAgent(ctx context.Context, controllerContext *controllercmd.ControllerContext) error

RunWorkloadAgent starts the controllers on agent to process work from hub.

type WorkloadAgentOptions

type WorkloadAgentOptions struct {
	StatusSyncInterval                     time.Duration
	AppliedManifestWorkEvictionGracePeriod time.Duration
	WorkloadSourceDriver                   WorkloadSourceDriver
}

WorkloadAgentOptions defines the flags for workload agent

func NewWorkloadAgentOptions

func NewWorkloadAgentOptions() *WorkloadAgentOptions

NewWorkloadAgentOptions returns the flags with default value set

func (*WorkloadAgentOptions) AddFlags

func (o *WorkloadAgentOptions) AddFlags(fs *pflag.FlagSet)

AddFlags register and binds the default flags

type WorkloadSourceDriver

type WorkloadSourceDriver struct {
	Type   string
	Config string
}