objectwatcher

Documentation

Index

• type ClientSetFunc
• type ObjectWatcher
  • func NewObjectWatcher(kubeClientSet client.Client, restMapper meta.RESTMapper, ...) ObjectWatcher

Types

type ClientSetFunc

type ClientSetFunc func(c string, client client.Client) (*util.DynamicClusterClient, error)

ClientSetFunc is used to generate client set of member cluster

type ObjectWatcher

type ObjectWatcher interface {
	Create(ctx context.Context, clusterName string, desireObj *unstructured.Unstructured) error
	Update(ctx context.Context, clusterName string, desireObj, clusterObj *unstructured.Unstructured) error
	Delete(ctx context.Context, clusterName string, desireObj *unstructured.Unstructured) error
	NeedsUpdate(clusterName string, desiredObj, clusterObj *unstructured.Unstructured) (bool, error)
}

ObjectWatcher manages operations for object dispatched to member clusters.

func NewObjectWatcher

func NewObjectWatcher(kubeClientSet client.Client, restMapper meta.RESTMapper, clusterClientSetFunc ClientSetFunc, interpreter resourceinterpreter.ResourceInterpreter) ObjectWatcher

NewObjectWatcher returns an instance of ObjectWatcher