mongo

Documentation

Index

• Constants
• func FetchBackupStreamAndOplog(folder storage.Folder, backup *internal.Backup) error
• func HandleOplogPush(uploader *Uploader)
• func HandleStreamPush(uploader *Uploader)
• type StreamSentinelDto
• type Uploader
  • func (uploader *Uploader) UploadStream(stream io.Reader) error

Constants

const (
	OplogPrefix = "oplog_"
	OplogPath   = "oplog_" + utility.VersionStr + "/"
	OplogEndTs  = "WALG_MONGO_OPLOG_END_TS"
	OplogDst    = "WALG_MONGO_OPLOG_DST"
)

Functions

func FetchBackupStreamAndOplog

func FetchBackupStreamAndOplog(folder storage.Folder, backup *internal.Backup) error

func HandleOplogPush

func HandleOplogPush(uploader *Uploader)

func HandleStreamPush

func HandleStreamPush(uploader *Uploader)

Types

type StreamSentinelDto

type StreamSentinelDto struct {
	StartLocalTime time.Time
}

type Uploader

type Uploader struct {
	*internal.Uploader
}

func (*Uploader) UploadStream

func (uploader *Uploader) UploadStream(stream io.Reader) error

TODO : unit tests UploadStream compresses a stream and uploads it.