mongo

Documentation

Index

• Constants
• func FetchLogs(folder storage.Folder, backup *internal.Backup) error
• func HandleOplogPush(uploader *Uploader)
• func HandleStreamPush(uploader *Uploader, command []string)
• type OpLogFetchHandlers
  • func (handlers OpLogFetchHandlers) DownloadLogTo(logFolder storage.Folder, logName string, dstLogFilePath string) error
  • func (handlers OpLogFetchHandlers) GetLogFilePath(pathToLog string) (string, error)
  • func (handlers OpLogFetchHandlers) HandleAbortFetch(logFilePath string) error
  • func (handlers OpLogFetchHandlers) ShouldBeAborted(pathToLog string) (bool, error)
• type OpLogFetchSettings
  • func (settings OpLogFetchSettings) GetDstEnv() string
  • func (settings OpLogFetchSettings) GetEndTsEnv() string
  • func (settings OpLogFetchSettings) GetLogFolderPath() string
• 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 FetchLogs

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

func HandleOplogPush

func HandleOplogPush(uploader *Uploader)

func HandleStreamPush

func HandleStreamPush(uploader *Uploader, command []string)

Types

type OpLogFetchHandlers

type OpLogFetchHandlers struct {
	// contains filtered or unexported fields
}

func (OpLogFetchHandlers) DownloadLogTo

func (handlers OpLogFetchHandlers) DownloadLogTo(logFolder storage.Folder, logName string, dstLogFilePath string) error

func (OpLogFetchHandlers) GetLogFilePath

func (handlers OpLogFetchHandlers) GetLogFilePath(pathToLog string) (string, error)

func (OpLogFetchHandlers) HandleAbortFetch

func (handlers OpLogFetchHandlers) HandleAbortFetch(logFilePath string) error

func (OpLogFetchHandlers) ShouldBeAborted

func (handlers OpLogFetchHandlers) ShouldBeAborted(pathToLog string) (bool, error)

type OpLogFetchSettings

type OpLogFetchSettings struct{}

func (OpLogFetchSettings) GetDstEnv

func (settings OpLogFetchSettings) GetDstEnv() string

func (OpLogFetchSettings) GetEndTsEnv

func (settings OpLogFetchSettings) GetEndTsEnv() string

func (OpLogFetchSettings) GetLogFolderPath

func (settings OpLogFetchSettings) GetLogFolderPath() string

type StreamSentinelDto

type StreamSentinelDto struct {
	StartLocalTime  time.Time   `json:"StartLocalTime,omitempty"`
	FinishLocalTime time.Time   `json:"FinishLocalTime,omitempty"`
	UserData        interface{} `json:"UserData,omitempty"`
}

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.