Documentation
¶
Index ¶
Constants ¶
View Source
const (
NameCheckUniqueIndexExistsJob = "CheckIndexExistsJob"
)
Variables ¶
This section is empty.
Functions ¶
func AddExtraJob ¶
func RunExtraJob ¶
func RunExtraJob(RealSourceIncrSync []*utils.MongoSource) error
Types ¶
type CheckUniqueIndexExistsJob ¶
type CheckUniqueIndexExistsJob struct {
// contains filtered or unexported fields
}
func NewCheckUniqueIndexExistsJob ¶
func NewCheckUniqueIndexExistsJob(interval int, collections []string, urls []*utils.MongoSource) *CheckUniqueIndexExistsJob
func (*CheckUniqueIndexExistsJob) Name ¶
func (cui *CheckUniqueIndexExistsJob) Name() string
func (*CheckUniqueIndexExistsJob) Run ¶
func (cui *CheckUniqueIndexExistsJob) Run()
type ReplicationCoordinator ¶
type ReplicationCoordinator struct {
MongoD []*utils.MongoSource // the source mongod
MongoS *utils.MongoSource // the source mongos
MongoCS *utils.MongoSource // the source mongocs
RealSourceFullSync []*utils.MongoSource // point to MongoD if source is mongod, otherwise MongoS
RealSourceIncrSync []*utils.MongoSource // point to MongoD if source is mongod, otherwise MongoS
// contains filtered or unexported fields
}
ReplicationCoordinator global coordinator instance. consist of one syncerGroup and a number of workers
func (*ReplicationCoordinator) Run ¶
func (coordinator *ReplicationCoordinator) Run() error
func (*ReplicationCoordinator) SourceIsSharding ¶
func (coordinator *ReplicationCoordinator) SourceIsSharding() bool
Source Files
Click to show internal directories.
Click to hide internal directories.