agent

Documentation

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

func Start

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

Types

type Options

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