Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Applier ¶
type Applier interface {
Apply(ctx context.Context, opr models.Oplog) error
Close(ctx context.Context) error
}
Applier defines interface to apply given oplog records.
func NewWriteApplier ¶ added in v0.2.16
func NewWriteApplier(format string, wc io.WriteCloser) (Applier, error)
NewWriteApplier builds one of write appliers
type BSONApplier ¶ added in v0.2.16
type BSONApplier struct {
// contains filtered or unexported fields
}
BSONApplier implements Applier interface for debugging.
func NewBSONApplier ¶ added in v0.2.16
func NewBSONApplier(w io.WriteCloser) *BSONApplier
NewBSONApplier builds BSONApplier with given args.
type BSONRawApplier ¶ added in v0.2.16
type BSONRawApplier struct {
// contains filtered or unexported fields
}
BSONRawApplier implements Applier interface for debugging.
func NewBSONRawApplier ¶ added in v0.2.16
func NewBSONRawApplier(w io.WriteCloser) *BSONRawApplier
NewBSONRawApplier builds BSONRawApplier with given args.
type DBApplier ¶
type DBApplier struct {
// contains filtered or unexported fields
}
DBApplier implements Applier interface for mongodb.
func NewDBApplier ¶
func NewDBApplier(m client.MongoDriver, preserveUUID bool, ignoreErrCodes map[string][]int32) *DBApplier
NewDBApplier builds DBApplier with given args.
type JSONApplier ¶ added in v0.2.16
type JSONApplier struct {
// contains filtered or unexported fields
}
JSONApplier implements Applier interface for debugging.
func NewJSONApplier ¶ added in v0.2.16
func NewJSONApplier(w io.WriteCloser) *JSONApplier
NewJSONApplier builds JSONApplier with given args.
type OpHandleError ¶ added in v0.2.18
type OpHandleError struct {
// contains filtered or unexported fields
}
func NewOpHandleError ¶ added in v0.2.18
func NewOpHandleError(op interface{}, err error) *OpHandleError
func (*OpHandleError) Error ¶ added in v0.2.18
func (e *OpHandleError) Error() string
type TypeAssertionError ¶ added in v0.2.18
type TypeAssertionError struct {
// contains filtered or unexported fields
}
func NewTypeAssertionError ¶ added in v0.2.18
func NewTypeAssertionError(etype, key string, value interface{}) *TypeAssertionError
func (*TypeAssertionError) Error ¶ added in v0.2.18
func (e *TypeAssertionError) Error() string
Source Files
Click to show internal directories.
Click to hide internal directories.