Documentation
¶
Index ¶
- func ClusterWideKeyFunc(obj interface{}) (util.QueueKey, error)
- type ClusterDetector
- func (d *ClusterDetector) GetUnstructuredObject(objectKey keys.ClusterWideKey) (*unstructured.Unstructured, error)
- func (d *ClusterDetector) OnAdd(obj interface{})
- func (d *ClusterDetector) OnDelete(obj interface{})
- func (d *ClusterDetector) OnUpdate(_, newObj interface{})
- func (d *ClusterDetector) Reconcile(key util.QueueKey) error
- func (d *ClusterDetector) Start(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClusterWideKeyFunc ¶
ClusterWideKeyFunc generates a ClusterWideKey for object.
Types ¶
type ClusterDetector ¶
type ClusterDetector struct {
ControllerPlaneConfig *rest.Config
ClusterAPIConfig *rest.Config
ClusterAPIClient client.Client
InformerManager genericmanager.SingleClusterInformerManager
EventHandler cache.ResourceEventHandler
Processor util.AsyncWorker
ConcurrentReconciles int
// contains filtered or unexported fields
}
ClusterDetector is a cluster watcher which watched cluster object in cluster-api management cluster and reconcile the events.
func (*ClusterDetector) GetUnstructuredObject ¶
func (d *ClusterDetector) GetUnstructuredObject(objectKey keys.ClusterWideKey) (*unstructured.Unstructured, error)
GetUnstructuredObject retrieves object by key and returned its unstructured.
func (*ClusterDetector) OnAdd ¶
func (d *ClusterDetector) OnAdd(obj interface{})
OnAdd handles object add event and push the object to queue.
func (*ClusterDetector) OnDelete ¶
func (d *ClusterDetector) OnDelete(obj interface{})
OnDelete handles object delete event and push the object to queue.
func (*ClusterDetector) OnUpdate ¶
func (d *ClusterDetector) OnUpdate(_, newObj interface{})
OnUpdate handles object update event and push the object to queue.
Source Files
Click to show internal directories.
Click to hide internal directories.