mysql

Documentation

Index

• Constants
• func FetchLogs(folder storage.Folder, backup *internal.Backup) error
• func HandleBinlogPush(uploader *Uploader)
• func HandleStreamPush(uploader *Uploader, command []string)
• type BinlogFetchHandlers
  • func (handlers BinlogFetchHandlers) DownloadLogTo(logFolder storage.Folder, logName string, dstLogFilePath string) error
  • func (handlers BinlogFetchHandlers) GetLogFilePath(pathToLog string) (string, error)
  • func (handlers BinlogFetchHandlers) HandleAbortFetch(logFilePath string) error
  • func (handlers BinlogFetchHandlers) ShouldBeAborted(pathToLog string) (bool, error)
• type BinlogFetchSettings
  • func (settings BinlogFetchSettings) GetDstEnv() string
  • func (settings BinlogFetchSettings) GetEndTsEnv() string
  • func (settings BinlogFetchSettings) GetLogFolderPath() string
• type LogsCache
• type StreamSentinelDto
• type Uploader
  • func (uploader *Uploader) UploadStream(db *sql.DB, stream io.Reader) error

Constants

const (
	BinlogMagicOffset     = 4
	TimestampHeaderLength = 4
)

const (
	BinlogPath            = "binlog_" + utility.VersionStr + "/"
	DatasourceNameSetting = "WALG_MYSQL_DATASOURCE_NAME"
	BinlogEndTsSetting    = "WALG_MYSQL_BINLOG_END_TS"
	BinlogDstSetting      = "WALG_MYSQL_BINLOG_DST"
	BinlogSrcSetting      = "WALG_MYSQL_BINLOG_SRC"
	SslCaSetting          = "WALG_MYSQL_SSL_CA"
)

const BinlogCacheFileName = ".walg_mysql_binlogs_cache"

Functions

func FetchLogs

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

func HandleBinlogPush

func HandleBinlogPush(uploader *Uploader)

func HandleStreamPush

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

Types

type BinlogFetchHandlers

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

func (BinlogFetchHandlers) DownloadLogTo

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

func (BinlogFetchHandlers) GetLogFilePath

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

func (BinlogFetchHandlers) HandleAbortFetch

func (handlers BinlogFetchHandlers) HandleAbortFetch(logFilePath string) error

func (BinlogFetchHandlers) ShouldBeAborted

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

type BinlogFetchSettings

type BinlogFetchSettings struct{}

func (BinlogFetchSettings) GetDstEnv

func (settings BinlogFetchSettings) GetDstEnv() string

func (BinlogFetchSettings) GetEndTsEnv

func (settings BinlogFetchSettings) GetEndTsEnv() string

func (BinlogFetchSettings) GetLogFolderPath

func (settings BinlogFetchSettings) GetLogFolderPath() string

type LogsCache

type LogsCache struct {
	LastArchivedBinlog string `json:"LastArchivedBinlog"`
}

type StreamSentinelDto

type StreamSentinelDto struct {
	BinLogStart    string `json:"BinLogStart,omitempty"`
	BinLogEnd      string `json:"BinLogEnd,omitempty"`
	StartLocalTime time.Time
}

type Uploader

type Uploader struct {
	*internal.Uploader
}

func (*Uploader) UploadStream

func (uploader *Uploader) UploadStream(db *sql.DB, stream io.Reader) error

TODO : unit tests UploadFile compresses a file and uploads it.