mcs

Documentation

Index

• type EpsController
  • func NewEpsController(clusteID, targetNamespace string, ...) (*EpsController, error)
  • func (c *EpsController) Handle(obj interface{}) (requeueAfter *time.Duration, err error)
  • func (c *EpsController) Run(ctx context.Context) error
• type ServiceExportController
  • func NewServiceExportController(clusteID string, epsInformer discoveryinformerv1.EndpointSliceInformer, ...) (*ServiceExportController, error)
  • func (c *ServiceExportController) Handle(obj interface{}) (requeueAfter *time.Duration, err error)
  • func (c *ServiceExportController) Run(ctx context.Context, parentDedicatedKubeConfig *rest.Config, ...) error
• type ServiceImportController
  • func NewServiceImportController(kubeclient kubernetes.Interface, ...) (*ServiceImportController, error)
  • func (c *ServiceImportController) Handle(obj interface{}) (requeueAfter *time.Duration, err error)
  • func (c *ServiceImportController) Run(ctx context.Context)

Types

type EpsController

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

func NewEpsController

func NewEpsController(clusteID, targetNamespace string, epsInformer discoveryinformerv1.EndpointSliceInformer, kubeClientSet kubernetes.Interface,
	k8sInformerFactory kubeinformers.SharedInformerFactory, seController *ServiceExportController, mcsSet *mcsclientset.Clientset) (*EpsController, error)

func (*EpsController) Handle

func (c *EpsController) Handle(obj interface{}) (requeueAfter *time.Duration, err error)

func (*EpsController) Run

func (c *EpsController) Run(ctx context.Context) error

type ServiceExportController

type ServiceExportController struct {
	YachtController *yacht.Controller
	// contains filtered or unexported fields
}

func NewServiceExportController

func NewServiceExportController(clusteID string, epsInformer discoveryinformerv1.EndpointSliceInformer, mcsClientset *mcsclientset.Clientset, mcsInformerFactory mcsInformers.SharedInformerFactory) (*ServiceExportController, error)

func (*ServiceExportController) Handle

func (c *ServiceExportController) Handle(obj interface{}) (requeueAfter *time.Duration, err error)

func (*ServiceExportController) Run

func (c *ServiceExportController) Run(ctx context.Context, parentDedicatedKubeConfig *rest.Config, delicatedNamespace string) error

type ServiceImportController

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

func NewServiceImportController

func NewServiceImportController(kubeclient kubernetes.Interface, epsInformer discoveryinformerv1.EndpointSliceInformer, mcsClientset *mcsclientset.Clientset,
	mcsInformerFactory mcsInformers.SharedInformerFactory) (*ServiceImportController, error)

func (*ServiceImportController) Handle

func (c *ServiceImportController) Handle(obj interface{}) (requeueAfter *time.Duration, err error)

func (*ServiceImportController) Run

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