stagesmocks

Documentation

Index

• type Applier
  • func (_m *Applier) Apply(_a0 context.Context, _a1 chan *models.Oplog) (chan error, error)
• type BetweenFetcher
  • func (_m *BetweenFetcher) FetchBetween(_a0 context.Context, _a1 models.Timestamp, _a2 models.Timestamp) (chan *models.Oplog, chan error, error)
• type Buffer
  • func (_m *Buffer) Close() error
  • func (_m *Buffer) Len() int
  • func (_m *Buffer) Reader() (io.Reader, error)
  • func (_m *Buffer) Reset() error
  • func (_m *Buffer) Write(p []byte) (int, error)
• type Fetcher
  • func (_m *Fetcher) Fetch(_a0 context.Context) (chan *models.Oplog, chan error, error)
• type FromFetcher
  • func (_m *FromFetcher) OplogFrom(_a0 context.Context, _a1 models.Timestamp, _a2 *sync.WaitGroup) (chan *models.Oplog, chan error, error)
• type GapHandler
  • func (_m *GapHandler) HandleGap(from models.Timestamp, until models.Timestamp, err error) error

Types

type Applier

type Applier struct {
	mock.Mock
}

Applier is an autogenerated mock type for the Applier type

func (*Applier) Apply

func (_m *Applier) Apply(_a0 context.Context, _a1 chan *models.Oplog) (chan error, error)

Apply provides a mock function with given fields: _a0, _a1

type BetweenFetcher

type BetweenFetcher struct {
	mock.Mock
}

BetweenFetcher is an autogenerated mock type for the BetweenFetcher type

func (*BetweenFetcher) FetchBetween

func (_m *BetweenFetcher) FetchBetween(_a0 context.Context, _a1 models.Timestamp, _a2 models.Timestamp) (chan *models.Oplog, chan error, error)

FetchBetween provides a mock function with given fields: _a0, _a1, _a2

type Buffer

type Buffer struct {
	mock.Mock
}

Buffer is an autogenerated mock type for the Buffer type

func (*Buffer) Close

func (_m *Buffer) Close() error

Close provides a mock function with given fields:

func (*Buffer) Len

func (_m *Buffer) Len() int

Len provides a mock function with given fields:

func (*Buffer) Reader

func (_m *Buffer) Reader() (io.Reader, error)

Reader provides a mock function with given fields:

func (*Buffer) Reset

func (_m *Buffer) Reset() error

Reset provides a mock function with given fields:

func (*Buffer) Write

func (_m *Buffer) Write(p []byte) (int, error)

Write provides a mock function with given fields: p

type Fetcher

type Fetcher struct {
	mock.Mock
}

Fetcher is an autogenerated mock type for the Fetcher type

func (*Fetcher) Fetch

func (_m *Fetcher) Fetch(_a0 context.Context) (chan *models.Oplog, chan error, error)

Fetch provides a mock function with given fields: _a0

type FromFetcher

type FromFetcher struct {
	mock.Mock
}

FromFetcher is an autogenerated mock type for the FromFetcher type

func (*FromFetcher) OplogFrom

func (_m *FromFetcher) OplogFrom(_a0 context.Context, _a1 models.Timestamp, _a2 *sync.WaitGroup) (chan *models.Oplog, chan error, error)

OplogFrom provides a mock function with given fields: _a0, _a1, _a2

type GapHandler

type GapHandler struct {
	mock.Mock
}

GapHandler is an autogenerated mock type for the GapHandler type

func (*GapHandler) HandleGap

func (_m *GapHandler) HandleGap(from models.Timestamp, until models.Timestamp, err error) error

HandleGap provides a mock function with given fields: from, until, err