controller

type AgentConfig ¶ added in v0.9.0

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(spec *AgentSpecification, syncerConf broker.SyncerConfig, syncerMetricNames AgentConfig) (*Controller, error)

func (a *Controller) Cleanup(ctx context.Context) error

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

type EndpointSliceController ¶ added in v0.15.0

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

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

type EndpointSliceListerFn ¶ added in v0.16.1

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

type IngressIP ¶ added in v0.10.1

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

type ServiceEndpointSliceController ¶ added in v0.16.0

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 (c *ServiceEndpointSliceController) Delete(ctx context.Context, obj runtime.Object) error

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

type ServiceExportClient ¶ added in v0.15.0

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

type ServiceImportAggregator ¶ added in v0.15.0

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

type ServiceImportController ¶ added in v0.7.0

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 (c *ServiceImportController) Delete(ctx context.Context, obj runtime.Object) error

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

type ServiceImportMigrator ¶ added in v0.15.0

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

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