datastoresyncer

Documentation

Index

• type DatastoreSyncer
  • func NewDatastoreSyncer(thisClusterID string, objectNamespace string, ...) *DatastoreSyncer
  • func (d *DatastoreSyncer) Run(stopCh <-chan struct{}) error

Types

type DatastoreSyncer

type DatastoreSyncer struct {
	// contains filtered or unexported fields
}

func NewDatastoreSyncer

func NewDatastoreSyncer(thisClusterID string, objectNamespace string, kubeClientSet kubernetes.Interface, submarinerClientset submarinerClientset.Interface, submarinerClusterInformer submarinerInformers.ClusterInformer, submarinerEndpointInformer submarinerInformers.EndpointInformer, datastore datastore.Datastore, colorcodes []string, localCluster types.SubmarinerCluster, localEndpoint types.SubmarinerEndpoint) *DatastoreSyncer

func (*DatastoreSyncer) Run

func (d *DatastoreSyncer) Run(stopCh <-chan struct{}) error