Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ReplicationWorker ¶
type ReplicationWorker struct { DBEngine string SourceDB string SourceCollection string ReplicationIndex string NSQProducer *nsq.Producer NSQConsumer *nsq.Consumer // contains filtered or unexported fields }
func CreateReplicationWorker ¶
func (ReplicationWorker) StartReplication ¶
func (worker ReplicationWorker) StartReplication()
Click to show internal directories.
Click to hide internal directories.