agent

Documentation

Overview

Package agent provides the agent controller. (fleetagent)

Index

• func NewMappers(ctx context.Context, fleetRESTConfig *rest.Config, ...) (meta.RESTMapper, meta.RESTMapper, discovery.CachedDiscoveryInterface, error)
• func Register(ctx context.Context, kubeConfig, namespace, clusterID string) error
• func Start(ctx context.Context, kubeConfig, namespace, agentScope string, opts *Options) error
• type Options

Functions

func NewMappers

func NewMappers(ctx context.Context, fleetRESTConfig *rest.Config, clientconfig clientcmd.ClientConfig, opts *Options) (meta.RESTMapper, meta.RESTMapper, discovery.CachedDiscoveryInterface, error)

Share mappers across simulators

func Register

func Register(ctx context.Context, kubeConfig, namespace, clusterID string) error

Register is only used by simulators to start an agent

func Start

func Start(ctx context.Context, kubeConfig, namespace, agentScope string, opts *Options) error

Start the fleet agent

Types

type Options

type Options struct {
	DefaultNamespace string
	ClusterID        string
	NoLeaderElect    bool
	CheckinInterval  time.Duration
	StartAfter       <-chan struct{}
}