agent

Documentation

Index

• type Agent
  • func NewAgent(opts *options.AgentOptions) (*Agent, error)
  • func (agent *Agent) Run(ctx context.Context) error
• type Manager
  • func NewStatusManager(apiserverURL string, opts *options.AgentOptions, ...) *Manager
  • func (mgr *Manager) Run(ctx context.Context, parentDedicatedKubeConfig *rest.Config, ...)

Types

type Agent

type Agent struct {
	SecureServing *apiserver.SecureServingInfo

	// Identity is the unique string identifying a lease holder across
	// all participants in an election.
	Identity string

	// ClusterID denotes current child cluster id
	ClusterID *types.UID

	// dedicated namespace in parent cluster for current child cluster
	DedicatedNamespace *string
	// contains filtered or unexported fields
}

Agent defines configuration for clusternet-agent

func NewAgent

func NewAgent(opts *options.AgentOptions) (*Agent, error)

NewAgent returns a new Agent.

func (*Agent) Run

func (agent *Agent) Run(ctx context.Context) error

type Manager

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

func NewStatusManager

func NewStatusManager(
	apiserverURL string,
	opts *options.AgentOptions,
	kubeClient kubernetes.Interface,
	metricClient *metricsv.Clientset,
	kubeInformerFactory informers.SharedInformerFactory,
) *Manager

func (*Manager) Run

func (mgr *Manager) Run(ctx context.Context, parentDedicatedKubeConfig *rest.Config, dedicatedNamespace *string, clusterID *types.UID)