Versions in this module Expand all Collapse all v0 v0.2.23 May 14, 2021 Changes in this version + type Applier interface + Apply func(context.Context, chan *models.Oplog) (chan error, error) + type BetweenFetcher interface + FetchBetween func(context.Context, models.Timestamp, models.Timestamp) (chan *models.Oplog, chan error, error) + type Buffer interface + Len func() int + Reader func() (io.Reader, error) + Reset func() error + type CloserBuffer struct + func NewCloserBuffer() *CloserBuffer + func (cb *CloserBuffer) Close() error + type CursorMajFetcher struct + func NewCursorMajFetcher(m client.MongoDriver, cur client.OplogCursor, lwUpdateInterval time.Duration) *CursorMajFetcher + func (dbf *CursorMajFetcher) Fetch(ctx context.Context) (oplogc chan *models.Oplog, errc chan error, err error) + type Fetcher interface + Fetch func(context.Context) (chan *models.Oplog, chan error, error) + type FileBuffer struct + func NewFileBuffer(path string) (*FileBuffer, error) + func (fb *FileBuffer) Close() error + func (fb *FileBuffer) Len() int + func (fb *FileBuffer) Read(p []byte) (n int, err error) + func (fb *FileBuffer) Reader() (io.Reader, error) + func (fb *FileBuffer) Reset() error + func (fb *FileBuffer) Write(p []byte) (n int, err error) + type GapHandler interface + HandleGap func(from, until models.Timestamp, err error) error + type GenericApplier struct + func NewGenericApplier(applier oplog.Applier) *GenericApplier + func (dba *GenericApplier) Apply(ctx context.Context, ch chan *models.Oplog) (chan error, error) + type MemoryBuffer struct + func NewMemoryBuffer() *MemoryBuffer + func (mb *MemoryBuffer) Close() error + func (mb *MemoryBuffer) Reader() (io.Reader, error) + func (mb *MemoryBuffer) Reset() error + func (mb *MemoryBuffer) Write(p []byte) (n int, err error) + type StorageApplier struct + func NewStorageApplier(uploader archive.Uploader, buf Buffer, archiveAfterSize int, ...) *StorageApplier + func (sa *StorageApplier) Apply(ctx context.Context, oplogc chan *models.Oplog) (chan error, error) + type StorageFetcher struct + func NewStorageFetcher(downloader archive.Downloader, path archive.Sequence) *StorageFetcher + func (sf *StorageFetcher) FetchBetween(ctx context.Context, from, until models.Timestamp) (oplogc chan *models.Oplog, errc chan error, err error) + type StorageGapHandler struct + func NewStorageGapHandler(uploader archive.Uploader) *StorageGapHandler + func (sgh *StorageGapHandler) HandleGap(from, until models.Timestamp, gapErr error) error