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 ¶
func NewWriteApplier(format string, wc io.WriteCloser) (Applier, error)
NewWriteApplier builds one of write appliers
type BSONApplier ¶
type BSONApplier struct {
// contains filtered or unexported fields
}
BSONApplier implements Applier interface for debugging.
func NewBSONApplier ¶
func NewBSONApplier(w io.WriteCloser) *BSONApplier
NewBSONApplier builds BSONApplier with given args.
type BSONRawApplier ¶
type BSONRawApplier struct {
// contains filtered or unexported fields
}
BSONRawApplier implements Applier interface for debugging.
func NewBSONRawApplier ¶
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 ¶
type JSONApplier struct {
// contains filtered or unexported fields
}
JSONApplier implements Applier interface for debugging.
func NewJSONApplier ¶
func NewJSONApplier(w io.WriteCloser) *JSONApplier
NewJSONApplier builds JSONApplier with given args.
type OpHandleError ¶
type OpHandleError struct {
// contains filtered or unexported fields
}
func NewOpHandleError ¶
func NewOpHandleError(op interface{}, err error) *OpHandleError
func (*OpHandleError) Error ¶
func (e *OpHandleError) Error() string
type TypeAssertionError ¶
type TypeAssertionError struct {
// contains filtered or unexported fields
}
func NewTypeAssertionError ¶
func NewTypeAssertionError(etype, key string, value interface{}) *TypeAssertionError
func (*TypeAssertionError) Error ¶
func (e *TypeAssertionError) Error() string
Source Files
Click to show internal directories.
Click to hide internal directories.