Documentation ¶
Index ¶
- Constants
- func FetchLogs(folder storage.Folder, backupUploadTime time.Time, untilDT string) error
- func HandleBackupPush(uploader *Uploader, command []string)
- func HandleBinlogFetch(folder storage.Folder, backupName string, untilDT string, needApply bool) error
- func HandleBinlogPush(uploader *Uploader)
- 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
- type LogsCache
- type StreamSentinelDto
- type Uploader
Constants ¶
View Source
const ( BinlogMagicOffset = 4 TimestampHeaderLength = 4 )
View Source
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" )
View Source
const BinlogCacheFileName = ".walg_mysql_binlogs_cache"
Variables ¶
This section is empty.
Functions ¶
func HandleBackupPush ¶ added in v0.2.14
func HandleBinlogFetch ¶ added in v0.2.14
func HandleBinlogPush ¶
func HandleBinlogPush(uploader *Uploader)
Types ¶
type BinlogFetchHandlers ¶ added in v0.2.12
type BinlogFetchHandlers struct {
// contains filtered or unexported fields
}
func (BinlogFetchHandlers) DownloadLogTo ¶ added in v0.2.12
func (BinlogFetchHandlers) GetLogFilePath ¶ added in v0.2.12
func (handlers BinlogFetchHandlers) GetLogFilePath(pathToLog string) (string, error)
func (BinlogFetchHandlers) HandleAbortFetch ¶ added in v0.2.12
func (handlers BinlogFetchHandlers) HandleAbortFetch(logFilePath string) error
func (BinlogFetchHandlers) ShouldBeAborted ¶ added in v0.2.12
func (handlers BinlogFetchHandlers) ShouldBeAborted(pathToLog string) (bool, error)
type BinlogFetchSettings ¶ added in v0.2.12
type BinlogFetchSettings struct {
// contains filtered or unexported fields
}
func (BinlogFetchSettings) GetDestFolderPath ¶ added in v0.2.14
func (settings BinlogFetchSettings) GetDestFolderPath() (string, error)
func (BinlogFetchSettings) GetEndTS ¶ added in v0.2.14
func (settings BinlogFetchSettings) GetEndTS() (*time.Time, error)
func (BinlogFetchSettings) GetLogFolderPath ¶ added in v0.2.12
func (settings BinlogFetchSettings) GetLogFolderPath() string
type LogsCache ¶ added in v0.2.12
type LogsCache struct {
LastArchivedBinlog string `json:"LastArchivedBinlog"`
}
type StreamSentinelDto ¶
Click to show internal directories.
Click to hide internal directories.