mcs

Documentation

Index

• Constants
• type ServiceExportController
  • func NewServiceExportController(kubeClient kubeclient.Interface, ...) (*ServiceExportController, error)
  • func (c *ServiceExportController) HasSynced() bool
  • func (c *ServiceExportController) IsControllerReady() bool
  • func (c *ServiceExportController) Run(ctx context.Context)
• type ServiceImportController
  • func NewServiceImportController(kubeClient kubeclient.Interface, ...) (*ServiceImportController, error)
  • func (c *ServiceImportController) HasSynced() bool
  • func (c *ServiceImportController) IsControllerReady() bool
  • func (c *ServiceImportController) Run(ctx context.Context)

Constants

const (
	ServiceImportControllerName = "serviceimport-controller"

	PrefixedGlobalSchedulerName         = common.DefaultPrefix + "global-scheduler"
	PrefixedServiceImportControllerName = common.DefaultPrefix + ServiceImportControllerName

	EventReasonSyncPlacementsToEndpointSlice = "SyncPlacementsToEndpointSlice"
)

const (
	EndpointSliceSourceClusterLabel = common.DefaultPrefix + "source-cluster"
)

const (
	ServiceExportControllerName = "serviceexport-controller"
)

Types

type ServiceExportController

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

func NewServiceExportController

func NewServiceExportController(
	kubeClient kubeclient.Interface,
	endpointSliceInformer discoveryv1b1informers.EndpointSliceInformer,
	fedInformerManager informermanager.FederatedInformerManager,
	logger klog.Logger,
	metrics stats.Metrics,
	workerCount int,
) (*ServiceExportController, error)

func (*ServiceExportController) HasSynced

func (c *ServiceExportController) HasSynced() bool

func (*ServiceExportController) IsControllerReady

func (c *ServiceExportController) IsControllerReady() bool

func (*ServiceExportController) Run

func (c *ServiceExportController) Run(ctx context.Context)

type ServiceImportController

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

func NewServiceImportController

func NewServiceImportController(
	kubeClient kubeclient.Interface,
	endpointSliceInformer discoveryv1b1informers.EndpointSliceInformer,
	fedClient fedclient.Interface,
	fedObjectInformer fedcorev1a1informers.FederatedObjectInformer,
	metrics stats.Metrics,
	logger klog.Logger,
	workerCount int,
) (*ServiceImportController, error)

func (*ServiceImportController) HasSynced

func (c *ServiceImportController) HasSynced() bool

func (*ServiceImportController) IsControllerReady

func (c *ServiceImportController) IsControllerReady() bool

func (*ServiceImportController) Run

func (c *ServiceImportController) Run(ctx context.Context)