binlog

package

v1.0.48 Latest Latest Go to latest Published: Feb 14, 2019 License: MIT Imports: 10 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/CsongSY/gh-ost

Links

Open Source Insights

Documentation ¶

Index ¶

type BinlogDMLEvent
- func NewBinlogDMLEvent(databaseName, tableName string, dml EventDML) *BinlogDMLEvent
- func (this *BinlogDMLEvent) String() string
type BinlogEntry
- func NewBinlogEntry(logFile string, logPos uint64) *BinlogEntry
- func NewBinlogEntryAt(coordinates mysql.BinlogCoordinates) *BinlogEntry
- func (this *BinlogEntry) Duplicate() *BinlogEntry
- func (this *BinlogEntry) String() string
type BinlogReader
type EventDML
- func ToEventDML(description string) EventDML
type GoMySQLReader
- func NewGoMySQLReader(migrationContext *base.MigrationContext) (binlogReader *GoMySQLReader, err error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type BinlogDMLEvent ¶

type BinlogDMLEvent struct {
	DatabaseName      string
	TableName         string
	DML               EventDML
	WhereColumnValues *sql.ColumnValues
	NewColumnValues   *sql.ColumnValues
}

BinlogDMLEvent is a binary log rows (DML) event entry, with data

func NewBinlogDMLEvent ¶

func NewBinlogDMLEvent(databaseName, tableName string, dml EventDML) *BinlogDMLEvent

func (*BinlogDMLEvent) String ¶

func (this *BinlogDMLEvent) String() string

type BinlogEntry ¶

type BinlogEntry struct {
	Coordinates mysql.BinlogCoordinates
	EndLogPos   uint64

	DmlEvent *BinlogDMLEvent
}

BinlogEntry describes an entry in the binary log

func NewBinlogEntry ¶

func NewBinlogEntry(logFile string, logPos uint64) *BinlogEntry

NewBinlogEntry creates an empty, ready to go BinlogEntry object

func NewBinlogEntryAt ¶

func NewBinlogEntryAt(coordinates mysql.BinlogCoordinates) *BinlogEntry

NewBinlogEntryAt creates an empty, ready to go BinlogEntry object

func (*BinlogEntry) Duplicate ¶

func (this *BinlogEntry) Duplicate() *BinlogEntry

Duplicate creates and returns a new binlog entry, with some of the attributes pre-assigned

func (*BinlogEntry) String ¶

func (this *BinlogEntry) String() string

String() returns a string representation of this binlog entry

type BinlogReader ¶

type BinlogReader interface {
	StreamEvents(canStopStreaming func() bool, entriesChannel chan<- *BinlogEntry) error
	Reconnect() error
}

BinlogReader is a general interface whose implementations can choose their methods of reading a binary log file and parsing it into binlog entries

type EventDML ¶

type EventDML string

const (
	NotDML    EventDML = "NoDML"
	InsertDML EventDML = "Insert"
	UpdateDML EventDML = "Update"
	DeleteDML EventDML = "Delete"
)

func ToEventDML ¶

func ToEventDML(description string) EventDML

type GoMySQLReader ¶

type GoMySQLReader struct {
	LastAppliedRowsEventHint mysql.BinlogCoordinates
	// contains filtered or unexported fields
}

func NewGoMySQLReader ¶

func NewGoMySQLReader(migrationContext *base.MigrationContext) (binlogReader *GoMySQLReader, err error)

func (*GoMySQLReader) Close ¶ added in v1.0.28

func (this *GoMySQLReader) Close() error

func (*GoMySQLReader) ConnectBinlogStreamer ¶

func (this *GoMySQLReader) ConnectBinlogStreamer(coordinates mysql.BinlogCoordinates) (err error)

ConnectBinlogStreamer

func (*GoMySQLReader) GetCurrentBinlogCoordinates ¶ added in v0.7.16

func (this *GoMySQLReader) GetCurrentBinlogCoordinates() *mysql.BinlogCoordinates

func (*GoMySQLReader) StreamEvents ¶

func (this *GoMySQLReader) StreamEvents(canStopStreaming func() bool, entriesChannel chan<- *BinlogEntry) error

StreamEvents

Source Files ¶

View all Source files

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