Versions in this module Expand all Collapse all v0 v0.2.23 May 14, 2021 Changes in this version + type Applier interface + Apply func(ctx context.Context, opr models.Oplog) error + Close func(ctx context.Context) error + func NewWriteApplier(format string, wc io.WriteCloser) (Applier, error) + type BSONApplier struct + func NewBSONApplier(w io.WriteCloser) *BSONApplier + func (ap *BSONApplier) Apply(ctx context.Context, opr models.Oplog) error + func (ap *BSONApplier) Close(ctx context.Context) error + type BSONRawApplier struct + func NewBSONRawApplier(w io.WriteCloser) *BSONRawApplier + func (ap *BSONRawApplier) Apply(ctx context.Context, opr models.Oplog) error + func (ap *BSONRawApplier) Close(ctx context.Context) error + type DBApplier struct + func NewDBApplier(m client.MongoDriver, preserveUUID bool, ignoreErrCodes map[string][]int32) *DBApplier + func (ap *DBApplier) Apply(ctx context.Context, opr models.Oplog) error + func (ap *DBApplier) Close(ctx context.Context) error + type JSONApplier struct + func NewJSONApplier(w io.WriteCloser) *JSONApplier + func (ap *JSONApplier) Apply(ctx context.Context, opr models.Oplog) error + func (ap *JSONApplier) Close(ctx context.Context) error + type OpHandleError struct + func NewOpHandleError(op interface{}, err error) *OpHandleError + func (e *OpHandleError) Error() string + type TypeAssertionError struct + func NewTypeAssertionError(etype, key string, value interface{}) *TypeAssertionError + func (e *TypeAssertionError) Error() string