controller

Documentation

Index

• Constants
• func FindServiceExportStatusCondition(conditions []mcsv1a1.ServiceExportCondition, ...) *mcsv1a1.ServiceExportCondition
• func GetGlobalIngressIPObj() *unstructured.Unstructured
• type AgentConfig
• type AgentSpecification
• type AggregatedServiceImportGetterFn
• 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
  • func NewServiceExportClient(client dynamic.Interface, scheme *runtime.Scheme) *ServiceExportClient
  • func (c *ServiceExportClient) UpdateStatusConditions(ctx context.Context, name, namespace string, ...)
• 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"
)

const (
	ExportFailedReason                   = "ExportFailed"
	TypeConflictReason                   = "ConflictingType"
	PortConflictReason                   = "ConflictingPorts"
	SessionAffinityConflictReason        = "ConflictingSessionAffinity"
	SessionAffinityConfigConflictReason  = "ConflictingSessionAffinityConfig"
	ClusterSetIPEnablementConflictReason = "ConflictingClusterSetIPEnablement"
)

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
	IPPool                   *ipam.IPPool
}

type AgentSpecification

type AgentSpecification struct {
	ClusterID           string
	Namespace           string
	Verbosity           int
	ClustersetIPCidr    string `split_words:"true"`
	ClustersetIPEnabled bool   `split_words:"true"`
	GlobalnetEnabled    bool   `split_words:"true"`
	Uninstall           bool
	HaltOnCertError     bool `split_words:"true"`
	Debug               bool
}

type AggregatedServiceImportGetterFn

type AggregatedServiceImportGetterFn func(serviceName string, serviceNamespace string) *mcsv1a1.ServiceImport

type Controller

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

func New

func New(spec *AgentSpecification, syncerConf broker.SyncerConfig, agentConfig 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
}

func NewServiceExportClient

func NewServiceExportClient(client dynamic.Interface, scheme *runtime.Scheme) *ServiceExportClient

func (*ServiceExportClient) UpdateStatusConditions

func (c *ServiceExportClient) UpdateStatusConditions(ctx context.Context, name, namespace string,
	conditions ...mcsv1a1.ServiceExportCondition,
)

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.