datastoresyncer

Documentation

Index

• type DatastoreSyncer
  • func New(restConfig *rest.Config, namespace string, ...) *DatastoreSyncer
  • func NewWithDetail(thisClusterID, namespace string, localCluster types.SubmarinerCluster, ...) *DatastoreSyncer
  • func (d *DatastoreSyncer) Run(stopCh <-chan struct{}) error
• type NewSyncer

Types

type DatastoreSyncer

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

func New

func New(restConfig *rest.Config, namespace string, localCluster types.SubmarinerCluster,
	localEndpoint types.SubmarinerEndpoint, colorcodes []string) *DatastoreSyncer

func NewWithDetail

func NewWithDetail(thisClusterID, namespace string, localCluster types.SubmarinerCluster,
	localEndpoint types.SubmarinerEndpoint, colorcodes []string, syncerConfig broker.SyncerConfig, newSyncer NewSyncer) *DatastoreSyncer

Intended for unit tests.

func (*DatastoreSyncer) Run

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

type NewSyncer

type NewSyncer func(*broker.SyncerConfig) (*broker.Syncer, error)