mysql

package

v0.2.11 Latest Latest Go to latest Published: Aug 12, 2019 License: Apache-2.0 Imports: 22 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/aallzz/temp

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func BinlogShouldBeFetched(backupStartUploadTime time.Time, endTS *time.Time, object storage.Object) bool
func ExtractBinlogName(object storage.Object, folder storage.Folder) string
func GetBinlogConfigs() (endTS *time.Time, dstFolder string, err error)
func HandleBinlogPush(uploader *Uploader)
func HandleStreamFetch(backupName string, folder storage.Folder)
func HandleStreamPush(uploader *Uploader)
type Backup
- func (backup *Backup) FetchStreamSentinel() (StreamSentinelDto, error)
type MySQLLogsCache
type StreamSentinelDto
type Uploader
- func (uploader *Uploader) UploadStream(db *sql.DB, stream io.Reader) error

Constants ¶

View Source

const (
	StreamPrefix          = "stream_"
	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 MysqlBinlogCacheFileName = ".walg_mysql_binlogs_cache"

Variables ¶

This section is empty.

Functions ¶

func BinlogShouldBeFetched ¶

func BinlogShouldBeFetched(backupStartUploadTime time.Time, endTS *time.Time, object storage.Object) bool

func ExtractBinlogName ¶

func ExtractBinlogName(object storage.Object, folder storage.Folder) string

func GetBinlogConfigs ¶

func GetBinlogConfigs() (endTS *time.Time, dstFolder string, err error)

func HandleBinlogPush ¶

func HandleBinlogPush(uploader *Uploader)

func HandleStreamFetch ¶

func HandleStreamFetch(backupName string, folder storage.Folder)

func HandleStreamPush ¶

func HandleStreamPush(uploader *Uploader)

Types ¶

type Backup ¶

type Backup struct {
	*internal.Backup
}

func (*Backup) FetchStreamSentinel ¶

func (backup *Backup) FetchStreamSentinel() (StreamSentinelDto, error)

TODO : unit tests

type MySQLLogsCache ¶

type MySQLLogsCache 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.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL