dispatch

type CheckUnmanagedDispatcher interface {
	OperationDispatcher

	CheckRemovedOrUnlabeled(clusterName string, isHostNamespace isNamespaceInHostClusterFunc)
}

type FederatedResourceForDispatch interface {
	TargetName() util.QualifiedName
	TargetKind() string
	TargetGVK() schema.GroupVersionKind
	Object() *unstructured.Unstructured
	VersionForCluster(clusterName string) (string, error)
	ObjectForCluster(clusterName string) (*unstructured.Unstructured, error)
	ApplyOverrides(obj *unstructured.Unstructured, clusterName string) error
	RecordError(errorCode string, err error)
	RecordEvent(reason, messageFmt string, args ...interface{})
	IsNamespaceInHostCluster(clusterObj runtimeclient.Object) bool
}

type ManagedDispatcher interface {
	UnmanagedDispatcher

	Create(clusterName string)
	Update(clusterName string, clusterObj *unstructured.Unstructured)
	VersionMap() map[string]string
	CollectedStatus() (status.CollectedPropagationStatus, status.CollectedResourceStatus)

	RecordClusterError(propStatus status.PropagationStatus, clusterName string, err error)
	RecordStatus(clusterName string, propStatus status.PropagationStatus, resourceStatus interface{})
}

type OperationDispatcher interface {
	// Wait returns true for ok if all operations completed
	// successfully and false if only some operations completed
	// successfully.  An error is returned on timeout.
	Wait() (ok bool, timeoutErr error)
}

type UnmanagedDispatcher interface {
	OperationDispatcher

	Delete(clusterName string, opts ...runtimeclient.DeleteOption)
	RemoveManagedLabel(clusterName string, clusterObj *unstructured.Unstructured)
}