crdreplicator

type Controller struct {
	Scheme *runtime.Scheme
	client.Client
	ClientSet        *kubernetes.Clientset
	ClusterID        string
	RemoteDynClients map[string]dynamic.Interface // for each remote cluster we save dynamic client connected to its API server
	LocalDynClient   dynamic.Interface            // dynamic client pointing to the local API server
	// RegisteredResources is a list of GVRs of resources to be replicated, with the associated peering phase when the replication has to occur.
	RegisteredResources []Resource
	// LocalWatchers, we save all the running watchers monitoring the local resources:(registeredResource, chan)).
	LocalWatchers map[string]chan struct{}
	// RemoteWatchers, for each peering cluster we save all the running watchers monitoring the replicated resources:
	// (clusterID, (registeredResource, chan)).
	RemoteWatchers map[string]map[string]chan struct{}

	// NamespaceManager is an interface to manage the tenant namespaces.
	NamespaceManager tenantnamespace.Manager
	// IdentityReader is an interface to manage remote identities, and to get the rest config.
	IdentityReader identitymanager.IdentityReader
	// LocalToRemoteNamespaceMapper maps local namespaces to remote ones.
	LocalToRemoteNamespaceMapper map[string]string
	// RemoteToLocalNamespaceMapper maps remote namespaces to local ones.
	RemoteToLocalNamespaceMapper map[string]string
	// ClusterIDToLocalNamespaceMapper maps clusterIDs to local namespaces.
	ClusterIDToLocalNamespaceMapper map[string]string
	// ClusterIDToRemoteNamespaceMapper maps clusterIDs to remote namespaces.
	ClusterIDToRemoteNamespaceMapper map[string]string
	// contains filtered or unexported fields
}

type Resource struct {
	// GroupVersionResource contains the GVR of the resource to replicate.
	GroupVersionResource schema.GroupVersionResource
	// PeeringPhase contains the peering phase when this resource should be replicated.
	PeeringPhase consts.PeeringPhase
	// Ownership indicates the ownership over this resource.
	Ownership consts.OwnershipType
}