Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BetweenFetcher ¶
type BetweenFetcher interface {
FetchBetween(context.Context, models.Timestamp, models.Timestamp) (chan *models.Oplog, chan error, error)
}
BetweenFetcher defines interface to fetch oplog records between given timestamps.
type CloserBuffer ¶
CloserBuffer defines buffer which wraps bytes.Buffer and has dummy implementation of Closer interface.
func NewCloserBuffer ¶
func NewCloserBuffer() *CloserBuffer
NewCloserBuffer builds CloserBuffer instance
func (*CloserBuffer) Close ¶
func (cb *CloserBuffer) Close() error
Close is dummy function that implements Closer interface.
type CursorMajFetcher ¶
type CursorMajFetcher struct {
// contains filtered or unexported fields
}
CursorMajFetcher implements Fetcher interface for mongodb
func NewCursorMajFetcher ¶
func NewCursorMajFetcher(m client.MongoDriver, cur client.OplogCursor, lwUpdateInterval time.Duration) *CursorMajFetcher
NewCursorMajFetcher builds CursorMajFetcher with given args.
type Fetcher ¶
Fetcher defines interface to fetch oplog records. TODO: FIX INTERFACE METHOD NAME AND SIGNATURE
type FileBuffer ¶
FileBuffer implements Buffer interface with filesystem backend.
func NewFileBuffer ¶
func NewFileBuffer(path string) (*FileBuffer, error)
NewFileBuffer builds FileBuffer with given args.
func (*FileBuffer) Close ¶
func (fb *FileBuffer) Close() error
Close closes FileBuffer and removes temporary file.
func (*FileBuffer) Len ¶
func (fb *FileBuffer) Len() int
Len returns the number of bytes of the unread portion of the buffer we assume small files only, so cast to int to match bytes.Buffer interface
func (*FileBuffer) Read ¶
func (fb *FileBuffer) Read(p []byte) (n int, err error)
Read reads the next len(p) bytes from the buffer or until the buffer is drained.
type GapHandler ¶
type GenericApplier ¶
type GenericApplier struct {
// contains filtered or unexported fields
}
DBApplier implements Applier interface for mongodb.
func NewGenericApplier ¶
func NewGenericApplier(applier oplog.Applier) *GenericApplier
NewDBApplier builds DBApplier with given args.
type MemoryBuffer ¶
func (*MemoryBuffer) Close ¶
func (mb *MemoryBuffer) Close() error
Close closes FileBuffer and removes temporary file.
type StorageApplier ¶
type StorageApplier struct {
// contains filtered or unexported fields
}
StorageApplier implements Applier interface for storage.
func NewStorageApplier ¶
func NewStorageApplier(uploader archive.Uploader, buf Buffer, archiveAfterSize int, archiveTimeout time.Duration, statsUpdater stats.OplogUploadStatsUpdater) *StorageApplier
NewStorageApplier builds StorageApplier. TODO: switch to functional options
type StorageFetcher ¶
type StorageFetcher struct {
// contains filtered or unexported fields
}
StorageFetcher implements BetweenFetcher interface for storage.
func NewStorageFetcher ¶
func NewStorageFetcher(downloader archive.Downloader, path archive.Sequence) *StorageFetcher
NewStorageFetcher builds StorageFetcher instance
type StorageGapHandler ¶
type StorageGapHandler struct {
// contains filtered or unexported fields
}
func NewStorageGapHandler ¶
func NewStorageGapHandler(uploader archive.Uploader) *StorageGapHandler
Source Files
Directories