coordinator

Documentation

Index

• Constants
• func AddExtraJob(name string, interval int, input ...interface{})
• func RunExtraJob(RealSourceIncrSync []*utils.MongoSource) error
• type CheckUniqueIndexExistsJob
  • func NewCheckUniqueIndexExistsJob(interval int, collections []string, urls []*utils.MongoSource) *CheckUniqueIndexExistsJob
  • func (cui *CheckUniqueIndexExistsJob) Name() string
  • func (cui *CheckUniqueIndexExistsJob) Run()
• type ReplicationCoordinator
  • func (coordinator *ReplicationCoordinator) Run() error
  • func (coordinator *ReplicationCoordinator) SourceIsSharding() bool

Constants

const (
	NameCheckUniqueIndexExistsJob = "CheckIndexExistsJob"
)

Functions

func AddExtraJob

func AddExtraJob(name string, interval int, input ...interface{})

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