clientmocks

Documentation

Index

• type MongoDriver
  • func (_m *MongoDriver) ApplyOp(ctx context.Context, op db.Oplog) error
  • func (_m *MongoDriver) Close(ctx context.Context) error
  • func (_m *MongoDriver) CreateIndexes(ctx context.Context, dbName string, collName string, ...) error
  • func (_m *MongoDriver) EnsureIsMaster(ctx context.Context) error
  • func (_m *MongoDriver) IsMaster(ctx context.Context) (models.IsMaster, error)
  • func (_m *MongoDriver) LastWriteTS(ctx context.Context) (models.Timestamp, models.Timestamp, error)
  • func (_m *MongoDriver) TailOplogFrom(ctx context.Context, from models.Timestamp) (client.OplogCursor, error)
• type OplogCursor
  • func (_m *OplogCursor) Close(ctx context.Context) error
  • func (_m *OplogCursor) Data() []byte
  • func (_m *OplogCursor) Err() error
  • func (_m *OplogCursor) Next(_a0 context.Context) bool
  • func (_m *OplogCursor) Push(_a0 []byte) error

Types

type MongoDriver

type MongoDriver struct {
	mock.Mock
}

MongoDriver is an autogenerated mock type for the MongoDriver type

func (*MongoDriver) ApplyOp

func (_m *MongoDriver) ApplyOp(ctx context.Context, op db.Oplog) error

ApplyOp provides a mock function with given fields: ctx, op

func (*MongoDriver) Close

func (_m *MongoDriver) Close(ctx context.Context) error

Close provides a mock function with given fields: ctx

func (*MongoDriver) CreateIndexes

func (_m *MongoDriver) CreateIndexes(ctx context.Context, dbName string, collName string, indexes []client.IndexDocument) error

CreateIndexes provides a mock function with given fields: ctx, dbName, collName, indexes

func (*MongoDriver) EnsureIsMaster

func (_m *MongoDriver) EnsureIsMaster(ctx context.Context) error

EnsureIsMaster provides a mock function with given fields: ctx

func (*MongoDriver) IsMaster

func (_m *MongoDriver) IsMaster(ctx context.Context) (models.IsMaster, error)

IsMaster provides a mock function with given fields: ctx

func (*MongoDriver) LastWriteTS

func (_m *MongoDriver) LastWriteTS(ctx context.Context) (models.Timestamp, models.Timestamp, error)

LastWriteTS provides a mock function with given fields: ctx

func (*MongoDriver) TailOplogFrom

func (_m *MongoDriver) TailOplogFrom(ctx context.Context, from models.Timestamp) (client.OplogCursor, error)

TailOplogFrom provides a mock function with given fields: ctx, from

type OplogCursor

type OplogCursor struct {
	mock.Mock
}

OplogCursor is an autogenerated mock type for the OplogCursor type

func (*OplogCursor) Close

func (_m *OplogCursor) Close(ctx context.Context) error

Close provides a mock function with given fields: ctx

func (*OplogCursor) Data

func (_m *OplogCursor) Data() []byte

Data provides a mock function with given fields:

func (*OplogCursor) Err

func (_m *OplogCursor) Err() error

Err provides a mock function with given fields:

func (*OplogCursor) Next

func (_m *OplogCursor) Next(_a0 context.Context) bool

Next provides a mock function with given fields: _a0

func (*OplogCursor) Push

func (_m *OplogCursor) Push(_a0 []byte) error

Push provides a mock function with given fields: _a0