datastoresyncer

Documentation

Index

• type DatastoreSyncer
  • func New(syncerConfig *broker.SyncerConfig, localCluster *types.SubmarinerCluster, ...) *DatastoreSyncer
  • func (d *DatastoreSyncer) Cleanup() error
  • func (d *DatastoreSyncer) Start(stopCh <-chan struct{}) error

Types

type DatastoreSyncer

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

func New

func New(syncerConfig *broker.SyncerConfig, localCluster *types.SubmarinerCluster,
	localEndpoint *types.SubmarinerEndpoint,
) *DatastoreSyncer

func (*DatastoreSyncer) Cleanup

func (d *DatastoreSyncer) Cleanup() error

func (*DatastoreSyncer) Start

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