mongosync

Documentation

Index

• Constants
• Variables
• func InitConfig(path string) error
• func NewClient(url string) *mongo.Client
• func NewDocManager(shardId string) *docManager
• func ParseNamespace(ns string) (db, coll string)
• func Run(config string)
• type MongoSync
  • func NewMongoSync() *MongoSync
• type Namespace

Constants

const (
	OplogDatabaseName   = "local"
	OplogCollectionName = "oplog.rs"
	OplogOpUpdate       = "u"
	OplogOpDelete       = "d"
	OplogOpInsert       = "i"
	OplogOpCommand      = "c"
)

Variables

var Checkpoint = &checkpoint{checkpointMap: make(map[string]*primitive.Timestamp), mutex: &sync.Mutex{}}

var Config = &config{}

var DocManager = &docManager{mutex: &sync.Mutex{}, managers: make(map[string]managers.IDocManager)}

var SignalMonitor = &signalMonitor{}

Functions

func InitConfig

func InitConfig(path string) error

func NewClient

func NewClient(url string) *mongo.Client

func NewDocManager

func NewDocManager(shardId string) *docManager

func ParseNamespace

func ParseNamespace(ns string) (db, coll string)

func Run

func Run(config string)

Types

type MongoSync

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

func NewMongoSync

func NewMongoSync() *MongoSync

type Namespace

type Namespace struct {
	Ns   string
	Db   string
	Coll string
}