dispatch

Apr 29, 2019

Changes in this version

+ func RetainClusterFields(targetKind string, desiredObj, clusterObj, fedObj *unstructured.Unstructured) error

+ type DispatchRecorder interface

+ RecordError func(clusterName, operation string, err error)

+ RecordEvent func(clusterName, operation, operationContinuous string)

+ type FederatedResourceForDispatch interface

+ Object func() *unstructured.Unstructured

+ ObjectForCluster func(clusterName string) (*unstructured.Unstructured, error)

+ RecordError func(errorCode string, err error)

+ RecordEvent func(reason, messageFmt string, args ...interface{})

+ TargetKind func() string

+ TargetName func() util.QualifiedName

+ VersionForCluster func(clusterName string) (string, error)

+ type ManagedDispatcher interface

+ Create func(clusterName string)

+ Update func(clusterName string, clusterObj *unstructured.Unstructured)

+ VersionMap func() map[string]string

+ func NewManagedDispatcher(clientAccessor clientAccessorFunc, fedResource FederatedResourceForDispatch) ManagedDispatcher

+ type OperationDispatcher interface

+ Wait func() (ok bool, timeoutErr error)

+ type UnmanagedDispatcher interface

+ Delete func(clusterName string)

+ RemoveManagedLabel func(clusterName string, clusterObj *unstructured.Unstructured)

+ func NewUnmanagedDispatcher(clientAccessor clientAccessorFunc, targetKind string, ...) UnmanagedDispatcher