manager

Documentation

Index

• type BaseResourceSyncer
  • func (b *BaseResourceSyncer) BackPopulate(s string) error
  • func (b *BaseResourceSyncer) GetListener() listener.ClusterChangeListener
  • func (b *BaseResourceSyncer) GetMCController() *mc.MultiClusterController
  • func (b *BaseResourceSyncer) GetUpwardController() *uw.UpwardController
  • func (b *BaseResourceSyncer) PatrollerDo()
  • func (b *BaseResourceSyncer) Reconcile(request reconciler.Request) (reconciler.Result, error)
  • func (b *BaseResourceSyncer) StartDWS(stopCh <-chan struct{}) error
  • func (b *BaseResourceSyncer) StartPatrol(stopCh <-chan struct{}) error
  • func (b *BaseResourceSyncer) StartUWS(stopCh <-chan struct{}) error
• type ControllerManager
  • func New() *ControllerManager
  • func (m *ControllerManager) AddResourceSyncer(s ResourceSyncer)
  • func (m *ControllerManager) Start(stop <-chan struct{}) error
• type ResourceSyncer
• type ResourceSyncerNew
• type ResourceSyncerOptions

Types

type BaseResourceSyncer

type BaseResourceSyncer struct {
	Config                 *config.SyncerConfiguration
	MultiClusterController *mc.MultiClusterController
	UpwardController       *uw.UpwardController
	Patroller              *pa.Patroller
}

func (*BaseResourceSyncer) BackPopulate

func (b *BaseResourceSyncer) BackPopulate(s string) error

func (*BaseResourceSyncer) GetListener

func (b *BaseResourceSyncer) GetListener() listener.ClusterChangeListener

func (*BaseResourceSyncer) GetMCController

func (b *BaseResourceSyncer) GetMCController() *mc.MultiClusterController

func (*BaseResourceSyncer) GetUpwardController

func (b *BaseResourceSyncer) GetUpwardController() *uw.UpwardController

func (*BaseResourceSyncer) PatrollerDo

func (b *BaseResourceSyncer) PatrollerDo()

func (*BaseResourceSyncer) Reconcile

func (b *BaseResourceSyncer) Reconcile(request reconciler.Request) (reconciler.Result, error)

func (*BaseResourceSyncer) StartDWS

func (b *BaseResourceSyncer) StartDWS(stopCh <-chan struct{}) error

func (*BaseResourceSyncer) StartPatrol

func (b *BaseResourceSyncer) StartPatrol(stopCh <-chan struct{}) error

func (*BaseResourceSyncer) StartUWS

func (b *BaseResourceSyncer) StartUWS(stopCh <-chan struct{}) error

type ControllerManager

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

ControllerManager manages number of resource syncers. It starts their caches, waits for those to sync, then starts the controllers.

func New

func New() *ControllerManager

func (*ControllerManager) AddResourceSyncer

func (m *ControllerManager) AddResourceSyncer(s ResourceSyncer)

AddController adds a resource syncer to the ControllerManager.

func (*ControllerManager) Start

func (m *ControllerManager) Start(stop <-chan struct{}) error

Start gets all the unique caches of the controllers it manages, starts them, then starts the controllers as soon as their respective caches are synced. Start blocks until an error or stop is received.

type ResourceSyncer

type ResourceSyncer interface {
	reconciler.DWReconciler
	reconciler.UWReconciler
	reconciler.PatrolReconciler
	GetMCController() *mc.MultiClusterController
	GetUpwardController() *uw.UpwardController
	GetListener() listener.ClusterChangeListener
	StartUWS(stopCh <-chan struct{}) error
	StartDWS(stopCh <-chan struct{}) error
	StartPatrol(stopCh <-chan struct{}) error
}

ResourceSyncer is the interface used by ControllerManager to manage multiple resource syncers.

type ResourceSyncerNew

type ResourceSyncerNew func(*config.SyncerConfiguration,
	clientset.Interface,
	informers.SharedInformerFactory,
	vcclient.Interface,
	vcinformers.VirtualClusterInformer, ResourceSyncerOptions) (ResourceSyncer, error)

type ResourceSyncerOptions

type ResourceSyncerOptions struct {
	MCOptions     *mc.Options
	UWOptions     *uw.Options
	PatrolOptions *pa.Options
	IsFake        bool
}