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(ctx context.Context) error
  • func (a *Controller) Start(stopCh <-chan struct{}) error
• type EndpointSliceController
• type EndpointSliceListerFn
• type IngressIP
• type ServiceEndpointSliceController
  • func (c *ServiceEndpointSliceController) Delete(ctx context.Context, obj runtime.Object) error
  • func (c *ServiceEndpointSliceController) Distribute(ctx context.Context, obj runtime.Object) error
• type ServiceExportClient
• type ServiceImportAggregator
• type ServiceImportController
  • func (c *ServiceImportController) Delete(ctx context.Context, obj runtime.Object) error
  • func (c *ServiceImportController) Distribute(ctx context.Context, obj runtime.Object) error
• type ServiceImportMigrator

Constants

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

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
	Verbosity        int
	GlobalnetEnabled bool `split_words:"true"`
	Uninstall        bool
	HaltOnCertError  bool `split_words:"true"`
	Debug            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(ctx context.Context) error

func (*Controller) Start

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

type EndpointSliceController

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

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

type EndpointSliceListerFn

type EndpointSliceListerFn func(selector k8slabels.Selector) []runtime.Object

type IngressIP

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

type ServiceEndpointSliceController

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

Each ServiceEndpointSliceController watches for the EndpointSlices that backs a Service and have a ServiceImport. It creates LH EndpointSlices corresponding to service EndpointSlices that are distributed to other clusters.

func (*ServiceEndpointSliceController) Delete

func (c *ServiceEndpointSliceController) Delete(ctx context.Context, obj runtime.Object) error

func (*ServiceEndpointSliceController) Distribute

func (c *ServiceEndpointSliceController) Distribute(ctx context.Context, obj runtime.Object) error

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 a ServiceEndpointSliceController.

func (*ServiceImportController) Delete

func (c *ServiceImportController) Delete(ctx context.Context, obj runtime.Object) error

func (*ServiceImportController) Distribute

func (c *ServiceImportController) Distribute(ctx context.Context, 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.