incr

Nov 26, 2024

Changes in this version

+ const CursorWaitTime

+ const DeleteError

+ const DuplicateError

+ const InsertError

+ const MatchedCountError

+ const OperationError

+ const OplogVersionError

+ const UpdateError

+ const UpsertError

+ const VersionMark

+ var FilteredOperations = map[string]bool

+ func BuildUpdateDelteOplog(prefixField string, obj bson.D) (interface{}, error)

+ func DiffUpdateOplogToNormal(updateObj bson.D) (interface{}, error)

+ func FindFiledPrefix(input bson.D, prefix string) bool

+ func GetDbAndCollection(namespace string) (string, string)

+ func GetKey(log bson.D, wanted string) interface

+ func GetKeyWithIndex(log bson.D, wanted string) (interface{}, int)

+ func GetObjectId(log bson.D) (primitive.ObjectID, error)

+ func IgnoreError(err error, op string, isFullSyncStage bool) bool

+ func RemoveFiled(input bson.D, key string) bson.D

+ func StartIncrementalReplication(ctx context.Context, checkpointManager checkpoint.CheckpointManager)

+ type ChangeLog struct

+ Collection string

+ Db string

+ type GenericObject struct

+ Id primitive.ObjectID

+ type GenericOplog struct

+ Parsed *ChangeLog

+ Raw []byte

+ type OplogReader struct

+ func NewOplogReader(ckptManager checkpoint.CheckpointManager) *OplogReader

+ func (o *OplogReader) StartReader(ctx context.Context)

+ func (o *OplogReader) StopReader()

+ type OplogWriterSingle struct

+ func NewOplogWriter(fullFinishTs int64, queuedLogs chan *ChangeLog, ...) *OplogWriterSingle

+ func (ow *OplogWriterSingle) Delete(l *ChangeLog) error

+ func (ow *OplogWriterSingle) Insert(l *ChangeLog) error

+ func (ow *OplogWriterSingle) StartWriter(ctx context.Context)

+ func (ow *OplogWriterSingle) StopWriter()

+ func (ow *OplogWriterSingle) Update(l *ChangeLog, upsert bool) error

+ func (sw *OplogWriterSingle) Upsert(l *ChangeLog, upsert bool) error

+ type ParsedLog struct

+ DocumentKey bson.D

+ FromMigrate bool

+ Gid string

+ Hash *int64

+ LSID bson.Raw

+ Namespace string

+ Object bson.D

+ Operation string

+ PrevOpTime bson.Raw

+ Query bson.D

+ Term *int64

+ Timestamp primitive.Timestamp

+ TxnNumber *int64

+ UI *primitive.Binary

+ UniqueIndexes bson.M

+ Version int

+ type Reader interface

+ StartReader func(context.Context)

+ StopReader func(context.Context)

+ type Writer interface

+ StartWriter func(context.Context)

+ StopWriter func(context.Context)