logic

package
v0.8.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 6, 2016 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EventsChannelBufferSize       = 1
	ReconnectStreamerSleepSeconds = 5
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Applier 

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

Applier reads data from the read-MySQL-server (typically a replica, but can be the master) It is used for gaining initial status and structure, and later also follow up on progress and changelog

func NewApplier 

func NewApplier() *Applier

func (*Applier) AlterGhost 

func (this *Applier) AlterGhost() error

AlterGhost applies `alter` statement on ghost table

func (*Applier) ApplyDMLEventQuery 

func (this *Applier) ApplyDMLEventQuery(dmlEvent *binlog.BinlogDMLEvent) error

func (*Applier) ApplyIterationInsertQuery 

func (this *Applier) ApplyIterationInsertQuery() (chunkSize int64, rowsAffected int64, duration time.Duration, err error)

func (*Applier) CalculateNextIterationRangeEndValues 

func (this *Applier) CalculateNextIterationRangeEndValues() (hasFurtherRange bool, err error)

CalculateNextIterationRangeEndValues reads the next-iteration-range-end unique key values, which will be used for copying the next chunk of rows. Ir returns "false" if there is no further chunk to work through, i.e. we're past the last chunk and are done with itrating the range (and this done with copying row chunks)

func (*Applier) CreateChangelogTable 

func (this *Applier) CreateChangelogTable() error

CreateChangelogTable creates the changelog table on the applier host

func (*Applier) CreateGhostTable 

func (this *Applier) CreateGhostTable() error

CreateGhostTable creates the ghost table on the applier host

func (*Applier) DropChangelogTable 

func (this *Applier) DropChangelogTable() error

DropChangelogTable drops the changelog table on the applier host

func (*Applier) DropGhostTable 

func (this *Applier) DropGhostTable() error

DropGhostTable drops the ghost table on the applier host

func (*Applier) DropOldTable 

func (this *Applier) DropOldTable() error

DropOldTable drops the _Old table on the applier host

func (*Applier) ExpectProcess 

func (this *Applier) ExpectProcess(sessionId int64, stateHint, infoHint string) error

func (*Applier) GrabVoluntaryLock 

func (this *Applier) GrabVoluntaryLock(lockGrabbed chan<- error, okToRelease <-chan bool) error

GrabVoluntaryLock gets a named lock (`GET_LOCK`) and listens on a okToRelease in order to release it

func (*Applier) InitDBConnections 

func (this *Applier) InitDBConnections() (err error)

func (*Applier) InitiateHeartbeat 

func (this *Applier) InitiateHeartbeat(heartbeatIntervalMilliseconds int64)

InitiateHeartbeat creates a heartbeat cycle, writing to the changelog table. This is done asynchronously

func (*Applier) IssueBlockingQueryOnVoluntaryLock 

func (this *Applier) IssueBlockingQueryOnVoluntaryLock(sessionIdChan chan int64) error

IssueBlockingQueryOnVoluntaryLock will SELECT on the original table using a conditional on a known to be occupied lock. This query is expected to block, and will further block the followup RENAME statement

func (*Applier) LockTables 

func (this *Applier) LockTables() error

LockTables

func (*Applier) MasterPosWait 

func (this *Applier) MasterPosWait(binlogCoordinates *mysql.BinlogCoordinates) error

MasterPosWait is applicable with --test-on-replica

func (*Applier) ReadMigrationMaxValues 

func (this *Applier) ReadMigrationMaxValues(uniqueKey *sql.UniqueKey) error

ReadMigrationMinValues

func (*Applier) ReadMigrationMinValues 

func (this *Applier) ReadMigrationMinValues(uniqueKey *sql.UniqueKey) error

ReadMigrationMinValues

func (*Applier) ReadMigrationRangeValues 

func (this *Applier) ReadMigrationRangeValues() error

func (*Applier) ShowStatusVariable 

func (this *Applier) ShowStatusVariable(variableName string) (result int64, err error)

func (*Applier) StartSlaveSQLThread added in v0.7.16 

func (this *Applier) StartSlaveSQLThread() error

StartSlaveSQLThread is applicable with --test-on-replica

func (*Applier) StopSlaveIOThread 

func (this *Applier) StopSlaveIOThread() error

StopSlaveIOThread is applicable with --test-on-replica; it stops the IO thread, duh. We need to keep the SQL thread active so as to complete processing received events, and have them written to the binary log, so that we can then read them via streamer

func (*Applier) StopSlaveNicely 

func (this *Applier) StopSlaveNicely() error

func (*Applier) SwapTablesAtomic 

func (this *Applier) SwapTablesAtomic(sessionIdChan chan int64) error

SwapTablesAtomic issues a single two-table RENAME statement to swap ghost table into original's place

func (*Applier) SwapTablesQuickAndBumpy 

func (this *Applier) SwapTablesQuickAndBumpy() error

SwapTablesQuickAndBumpy

func (*Applier) UnlockTables 

func (this *Applier) UnlockTables() error

UnlockTables

func (*Applier) ValidateOrDropExistingTables 

func (this *Applier) ValidateOrDropExistingTables() error

func (*Applier) WriteAndLogChangelog 

func (this *Applier) WriteAndLogChangelog(hint, value string) (string, error)

func (*Applier) WriteChangelog 

func (this *Applier) WriteChangelog(hint, value string) (string, error)

WriteChangelog writes a value to the changelog table. It returns the hint as given, for convenience

func (*Applier) WriteChangelogState 

func (this *Applier) WriteChangelogState(value string) (string, error)

type BinlogEventListener 

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

type ChangelogState 

type ChangelogState string
const (
	TablesInPlace              ChangelogState = "TablesInPlace"
	AllEventsUpToLockProcessed                = "AllEventsUpToLockProcessed"
)

type EventsStreamer 

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

EventsStreamer reads data from binary logs and streams it on. It acts as a publisher, and interested parties may subscribe for per-table events.

func NewEventsStreamer 

func NewEventsStreamer() *EventsStreamer

func (*EventsStreamer) AddListener 

func (this *EventsStreamer) AddListener(
	async bool, databaseName string, tableName string, onDmlEvent func(event *binlog.BinlogDMLEvent) error) (err error)

func (*EventsStreamer) GetCurrentBinlogCoordinates added in v0.7.16 

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

func (*EventsStreamer) GetReconnectBinlogCoordinates added in v0.8.2 

func (this *EventsStreamer) GetReconnectBinlogCoordinates() *mysql.BinlogCoordinates

func (*EventsStreamer) InitDBConnections 

func (this *EventsStreamer) InitDBConnections() (err error)

func (*EventsStreamer) StreamEvents 

func (this *EventsStreamer) StreamEvents(canStopStreaming func() bool) error

StreamEvents will begin streaming events. It will be blocking, so should be executed by a goroutine

type Inspector 

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

Inspector reads data from the read-MySQL-server (typically a replica, but can be the master) It is used for gaining initial status and structure, and later also follow up on progress and changelog

func NewInspector 

func NewInspector() *Inspector

func (*Inspector) CountTableRows added in v0.8.3 

func (this *Inspector) CountTableRows() error

func (*Inspector) InitDBConnections 

func (this *Inspector) InitDBConnections() (err error)

func (*Inspector) InspectOriginalAndGhostTables 

func (this *Inspector) InspectOriginalAndGhostTables() (err error)

InspectOriginalAndGhostTables compares original and ghost tables to see whether the migration makes sense and is valid. It extracts the list of shared columns and the chosen migration unique key

func (*Inspector) InspectOriginalTable 

func (this *Inspector) InspectOriginalTable() (err error)

func (*Inspector) InspectTableColumnsAndUniqueKeys 

func (this *Inspector) InspectTableColumnsAndUniqueKeys(tableName string) (columns *sql.ColumnList, uniqueKeys [](*sql.UniqueKey), err error)

func (*Inspector) ValidateOriginalTable 

func (this *Inspector) ValidateOriginalTable() (err error)

type Migrator 

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

Migrator is the main schema migration flow manager.

func NewMigrator 

func NewMigrator() *Migrator

func (*Migrator) Migrate 

func (this *Migrator) Migrate() (err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.