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
• type EndpointController
• type ServiceImportController

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, runtimeScheme *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

type EndpointController

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

Each EndpointController listens for the endpoints that backs a service and have a ServiceImport It will create an endpoint slice corresponding to an endpoint object and set the owner references to ServiceImport. The app label from the endpoint will be added to endpoint slice as well.

type ServiceImportController

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

The ServiceImportController listens for ServiceImport resources created in the target namespace and creates an EndpointController in response. The EndpointController will use the app label as filter to listen only for the endpoints event related to ServiceImport created