incr

package
v0.0.14 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 31, 2025 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Uuid     = "ui"
	ApplyOps = "applyOps"
)
View Source 
const (
	StateUnknown  = iota
	StateRunning  = 1
	StatePaused   = 2
	StateSnapshot = 3
)
View Source 
const (
	VersionMark       = "$v"
	OplogVersionError = "unknown version of OPLog"
	OperationError    = "operation error"
	InsertError       = "insert error"
	UpdateError       = "update error"
	DeleteError       = "delete error"
	UpsertError       = "upsert error"
	DuplicateError    = "duplicate error"
	MatchedCountError = "matched count error"
)
View Source 
const (
	CursorWaitTime = 5 * time.Second
)

Variables

View Source 
var AllowedOperation = map[string]bool{
	"applyOps":         true,
	"startIndexBuild":  true,
	"commitIndexBuild": true,
	"abortIndexBuild":  true,
	"dropIndex":        false,
	"dropIndexes":      true,
}

Functions

func ApplyOpsFilter added in v0.0.14 

func ApplyOpsFilter(key string) bool

func BuildUpdateDelteOplog 

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

func DiffUpdateOplogToNormal 

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

"o" : { "$v" : 2, "diff" : { "d" : { "count" : false }, "u" : { "name" : "orange" }, "i" : { "c" : 11 } } }

func ExtraCommandName added in v0.0.14 

func ExtraCommandName(o bson.D) (string, bool)

func FilterApplyOps added in v0.0.14 

func FilterApplyOps(ele primitive.E, keepSubOp func(primitive.D) bool, computedCmd primitive.D, computedCmdSize int) (primitive.D, int)

Filter an applyOps command sub-operations

func FindFiledPrefix 

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

func GetId added in v0.0.14 

func GetId(log bson.D) (primitive.ObjectID, error)

func GetKey 

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

func GetKeyWithIndex 

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

func GetObjectId 

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

func IgnoreError 

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

true means error can be ignored https://github.com/mongodb/mongo/blob/master/src/mongo/base/error_codes.yml

func KeepOperation added in v0.0.14 

func KeepOperation(command string) bool

func KeepSubOp added in v0.0.14 

func KeepSubOp(doc bson.D) bool

Check if a sub-operation from an applyOps command should be kept We only keep insert, update and delete operations We also apply filter on the namespace

func RemoveField added in v0.0.14 

func RemoveField(input bson.D, key string) bson.D

pay attention: the input bson.D will be modified.

func RunCommand added in v0.0.14 

func RunCommand(database, command string, l *oplog.ChangeLog, client *mongo.Client) error

See this documentation for a full list of available commands: https://www.mongodb.com/docs/manual/reference/command/

func RunCommandApplyOps added in v0.0.14 

func RunCommandApplyOps(database string, l *oplog.ChangeLog, client *mongo.Client) error

func RunCommandCreateIndexes added in v0.0.14 

func RunCommandCreateIndexes(database string, l *oplog.ChangeLog, client *mongo.Client) error

Create indexes on a collection using the createIndexes command

func RunCommandDropIndexes added in v0.0.14 

func RunCommandDropIndexes(database string, l *oplog.ChangeLog, client *mongo.Client) error

Types

type CommandOperation added in v0.0.14 

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

type Incr added in v0.0.14 

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

func NewIncr added in v0.0.14 

func NewIncr(ckptManager checkpoint.CheckpointManager, cmdc chan commands.Command) *Incr

func (*Incr) RunIncremental added in v0.0.14 

func (o *Incr) RunIncremental(ctx context.Context)

type OplogReader 

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

func NewOplogReader 

func NewOplogReader(ckpt checkpoint.CheckpointManager,
	latest primitive.Timestamp,
	cmdc <-chan commands.Command,
	queue chan *oplog.ChangeLog) *OplogReader

func (*OplogReader) RunReader added in v0.0.14 

func (r *OplogReader) RunReader(ctx context.Context)

func (*OplogReader) StartReader 

func (r *OplogReader) StartReader(ctx context.Context)

func (*OplogReader) StopReader 

func (o *OplogReader) StopReader()

type OplogWriterSingle 

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

func NewOplogWriter 

func NewOplogWriter(ckptManager checkpoint.CheckpointManager, fullFinishTs int64, queue chan *oplog.ChangeLog) *OplogWriterSingle

func (*OplogWriterSingle) Command added in v0.0.14 

func (w *OplogWriterSingle) Command(l *oplog.ChangeLog) error

func (*OplogWriterSingle) Delete 

func (ow *OplogWriterSingle) Delete(l *oplog.ChangeLog) error

func (*OplogWriterSingle) Insert 

func (w *OplogWriterSingle) Insert(l *oplog.ChangeLog) error

func (*OplogWriterSingle) RunWriter added in v0.0.14 

func (w *OplogWriterSingle) RunWriter(ctx context.Context)

Start the writer

func (*OplogWriterSingle) StartWriter 

func (w *OplogWriterSingle) StartWriter(ctx context.Context)

Start the writer in a dedicated go routine

func (*OplogWriterSingle) StopWriter 

func (w *OplogWriterSingle) StopWriter()

func (*OplogWriterSingle) Update 

func (w *OplogWriterSingle) Update(l *oplog.ChangeLog, upsert bool) error

Update the document

func (*OplogWriterSingle) Upsert 

func (w *OplogWriterSingle) Upsert(l *oplog.ChangeLog, upsert bool) error

Upsert the document

type Reader 

type Reader interface {
	StartReader(context.Context)
	StopReader(context.Context)
}

type Writer 

type Writer interface {
	StartWriter(context.Context)
	StopWriter(context.Context)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.