controller

Documentation

Index

• type AgentConfig
• type Syncer
  • func New(spec *known.AgentSpecification, syncerConf known.SyncerConfig, ...) (*Syncer, error)
  • func (a *Syncer) Start(ctx context.Context) error

Types

type AgentConfig

type AgentConfig struct {
	ServiceImportCounterName string
	ServiceExportCounterName string
}

type Syncer

type Syncer struct {
	ClusterID               string
	LocalNamespace          string
	KubeClientSet           kubernetes.Interface
	KubeInformerFactory     kubeinformers.SharedInformerFactory
	ServiceExportController *mcs.ServiceExportController
	HubKubeConfig           *rest.Config
	SyncerConf              known.SyncerConfig
	EpsController           *mcs.EpsController
}

func New

func New(spec *known.AgentSpecification, syncerConf known.SyncerConfig, kubeClientSet kubernetes.Interface, mcsClientSet *mcsclientset.Clientset) (*Syncer, error)

func (*Syncer) Start

func (a *Syncer) Start(ctx context.Context) error