controller

Documentation

Index

• Variables
• type AgentSpecification
• type Controller
  • func New(spec *AgentSpecification, cfg *rest.Config) (*Controller, error)
  • func NewWithDetail(spec *AgentSpecification, syncerConf *broker.SyncerConfig, ...) (*Controller, error)
  • func (a *Controller) Start(stopCh <-chan struct{}) error

Variables

var MaxExportStatusConditions = 10

Types

type AgentSpecification

type AgentSpecification struct {
	ClusterID        string
	Namespace        string
	GlobalnetEnabled bool `split_words:"true"`
}

type Controller

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

func New

func New(spec *AgentSpecification, cfg *rest.Config) (*Controller, error)

func NewWithDetail

func NewWithDetail(spec *AgentSpecification, syncerConf *broker.SyncerConfig, restMapper meta.RESTMapper, localClient dynamic.Interface,
	kubeClientSet kubernetes.Interface, lighthouseClient lighthouseClientset.Interface, scheme *runtime.Scheme,
	newSyncer func(*broker.SyncerConfig) (*broker.Syncer, error)) (*Controller, error)

Constructor that takes additional detail. This is intended for unit tests.

func (*Controller) Start

func (a *Controller) Start(stopCh <-chan struct{}) error