Documentation
¶
Index ¶
- type BaseResourceSyncer
- func (b *BaseResourceSyncer) BackPopulate(s string) error
- func (b *BaseResourceSyncer) Conversion() conversion.Conversion
- 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
- type ResourceSyncer
- type ResourceSyncerNew
- type ResourceSyncerOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseResourceSyncer ¶
type BaseResourceSyncer struct {
Config *config.SyncerConfiguration
MultiClusterController *mc.MultiClusterController
UpwardController *uw.UpwardController
Patroller *pa.Patroller
// contains filtered or unexported fields
}
func (*BaseResourceSyncer) BackPopulate ¶
func (b *BaseResourceSyncer) BackPopulate(s string) error
func (*BaseResourceSyncer) Conversion ¶
func (b *BaseResourceSyncer) Conversion() conversion.Conversion
Conversion is a shortcut to construct a convertor
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)
AddResourceSyncer 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)
Source Files
Click to show internal directories.
Click to hide internal directories.