controller

Documentation

Index

• Constants
• func FindServiceExportStatusCondition(conditions []mcsv1a1.ServiceExportCondition, ...) *mcsv1a1.ServiceExportCondition
• func GetGlobalIngressIPObj() *unstructured.Unstructured
• type AgentConfig
• type AgentSpecification
• type Controller
  • func New(spec *AgentSpecification, syncerConf broker.SyncerConfig, ...) (*Controller, error)
  • func (a *Controller) Cleanup() error
  • func (a *Controller) Start(stopCh <-chan struct{}) error
• type EndpointController
• type EndpointSliceController
• type IngressIP
• type ServiceExportClient
• type ServiceImportAggregator
• type ServiceImportController
  • func (c *ServiceImportController) Delete(obj runtime.Object) error
  • func (c *ServiceImportController) Distribute(obj runtime.Object) error
• type ServiceImportMigrator

Constants

const (
	ClusterIPService   = "ClusterIPService"
	HeadlessServicePod = "HeadlessServicePod"
)

const (
	LegacySourceNameLabel    = "lighthouse.submariner.io/sourceName"
	LegacySourceClusterLabel = "lighthouse.submariner.io/sourceCluster"
)

Functions

func FindServiceExportStatusCondition

func FindServiceExportStatusCondition(conditions []mcsv1a1.ServiceExportCondition,
	condType mcsv1a1.ServiceExportConditionType,
) *mcsv1a1.ServiceExportCondition

func GetGlobalIngressIPObj

func GetGlobalIngressIPObj() *unstructured.Unstructured

Types

type AgentConfig

type AgentConfig struct {
	ServiceImportCounterName string
	ServiceExportCounterName string
}

type AgentSpecification

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

type Controller

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

func New

func New(spec *AgentSpecification, syncerConf broker.SyncerConfig, syncerMetricNames AgentConfig) (*Controller, error)

func (*Controller) Cleanup

func (a *Controller) Cleanup() error

func (*Controller) Start

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

type EndpointController

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

Each EndpointController watches for the Endpoints that backs a Service and have a ServiceImport by using a filter that listen only for the Service's endpoints. It creates an EndpointSlice corresponding to an Endpoints object that is distributed to other clusters.

type EndpointSliceController

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

EndpointSliceController encapsulates a syncer that syncs EndpointSlices to and from that broker.

type IngressIP

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

type ServiceExportClient

type ServiceExportClient struct {
	dynamic.NamespaceableResourceInterface
	// contains filtered or unexported fields
}

type ServiceImportAggregator

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

type ServiceImportController

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

The ServiceImportController encapsulates two resource syncers; one that watches for local cluster ServiceImports from the submariner namespace and creates/updates the aggregated ServiceImport on the broker; the other that syncs aggregated ServiceImports from the broker to the local service namespace. It also creates an EndpointController.

func (*ServiceImportController) Delete

func (c *ServiceImportController) Delete(obj runtime.Object) error

func (*ServiceImportController) Distribute

func (c *ServiceImportController) Distribute(obj runtime.Object) error

type ServiceImportMigrator

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

ServiceImportMigrator handles migration from the legacy per-cluster ServiceImports to aggregated ServiceImports added in 0.15.