logic

package

Go to main page

Versions in this module

v1

v1.0.36

Apr 3, 2017

v1.0.35

Mar 12, 2017

Changes in this version

type Applier

+ func (this *Applier) StartReplication() error

+ func (this *Applier) StartSlaveIOThread() error

v1.0.34

Jan 9, 2017

Changes in this version

type Applier

+ func (this *Applier) ApplyDMLEventQueries(dmlEvents [](*binlog.BinlogDMLEvent)) error

v1.0.32

Dec 14, 2016

v1.0.30

Dec 6, 2016

Changes in this version

type ChangelogState

+ func ReadChangelogState(s string) ChangelogState

v1.0.28

Nov 1, 2016

Changes in this version

type ChangelogState

+ const GhostTableMigrated

type EventsStreamer

+ func (this *EventsStreamer) Close() (err error)

v1.0.21

Oct 12, 2016

v1.0.20

Sep 13, 2016

Changes in this version

+ const NoPrintStatusRule

v1.0.18-experimental

Sep 7, 2016

v1.0.17

Sep 5, 2016

Changes in this version

+ type HooksExecutor struct

+ func NewHooksExecutor() *HooksExecutor

type Migrator

+ func (this *Migrator) ExecOnFailureHook() (err error)

+ type Throttler struct

+ func NewThrottler(applier *Applier, inspector *Inspector, panicAbort chan error) *Throttler

v1.0.14

Aug 26, 2016

v1.0.13

Aug 24, 2016

v1.0.11

Aug 22, 2016

Changes in this version

+ const ForcePrintStatusAndHintRule

+ const ForcePrintStatusOnlyRule

v1.0.10

Aug 18, 2016

v1.0.9

Aug 15, 2016

Changes in this version

type Server

+ func (this *Server) RemoveSocketFile() (err error)

v1.0.8

Aug 1, 2016

v1.0.7

Jul 31, 2016

v1.0.6

Jul 27, 2016

v1.0.2

Jul 19, 2016

v1.0.1

Jul 8, 2016

v0

v0.9.9

Jul 4, 2016

v0.9.8

Jun 28, 2016

Changes in this version

type Applier

+ func (this *Applier) AtomicCutOverMagicLock(sessionIdChan chan int64, tableLocked chan<- error, ...) error

+ func (this *Applier) AtomicCutoverRename(sessionIdChan chan int64, tablesRenamed chan<- error) error

+ func (this *Applier) CreateAtomicCutOverSentryTable() error

+ func (this *Applier) DropAtomicCutOverSentryTableIfExists() error

v0.9.7

Jun 21, 2016

v0.9.6

Jun 20, 2016

Changes in this version

+ const ForcePrintStatusAndHint

+ const ForcePrintStatusRule

+ const HeuristicPrintStatusRule

type Applier

+ func (this *Applier) ExecuteThrottleQuery() (int64, error)

+ func (this *Applier) StopReplication() error

+ type PrintStatusRule int

v0.9.2

Jun 15, 2016

Changes in this version

type Applier

+ func (this *Applier) ExpectUsedLock(sessionId int64) error

+ func (this *Applier) GetSessionLockName(sessionId int64) string

+ func (this *Applier) LockOriginalTable() error

+ func (this *Applier) LockOriginalTableAndWait(sessionIdChan chan int64, tableLocked chan<- error, ...) error

+ func (this *Applier) RenameGhostTable(sessionIdChan chan int64, ghostTableRenamed chan<- error) error

+ func (this *Applier) RenameOriginalTable(sessionIdChan chan int64, originalTableRenamed chan<- error) error

+ func (this *Applier) RenameTable(fromName, toName string) (err error)

+ func (this *Applier) RenameTablesRollback() (renameError error)

+ func (this *Applier) StopSlaveSQLThread() error

v0.8.8

Jun 9, 2016

v0.8.7

Jun 7, 2016

v0.8.5

Jun 7, 2016

v0.8.4

Jun 7, 2016

Changes in this version

+ type Server struct

+ func NewServer(onCommand onCommandFunc) *Server

+ func (this *Server) BindSocketFile() (err error)

+ func (this *Server) BindTCPPort() (err error)

+ func (this *Server) Serve() (err error)

v0.8.3

Jun 6, 2016

Changes in this version

type Inspector

+ func (this *Inspector) CountTableRows() error

v0.8.2

Jun 1, 2016

Changes in this version

type EventsStreamer

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

v0.7.16

May 20, 2016

Changes in this version

+ const ReconnectStreamerSleepSeconds

type Applier

+ func (this *Applier) StartSlaveSQLThread() error

type EventsStreamer

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

v0.7.2

May 17, 2016

v0.7.1

May 16, 2016

Changes in this version

+ const EventsChannelBufferSize

+ type Applier struct

+ func NewApplier() *Applier

+ func (this *Applier) AlterGhost() error

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

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

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

+ func (this *Applier) CreateChangelogTable() error

+ func (this *Applier) CreateGhostTable() error

+ func (this *Applier) DropChangelogTable() error

+ func (this *Applier) DropGhostTable() error

+ func (this *Applier) DropOldTable() error

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

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

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

+ func (this *Applier) InitiateHeartbeat(heartbeatIntervalMilliseconds int64)

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

+ func (this *Applier) LockTables() error

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

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

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

+ func (this *Applier) ReadMigrationRangeValues() error

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

+ func (this *Applier) StopSlaveIOThread() error

+ func (this *Applier) StopSlaveNicely() error

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

+ func (this *Applier) SwapTablesQuickAndBumpy() error

+ func (this *Applier) UnlockTables() error

+ func (this *Applier) ValidateOrDropExistingTables() error

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

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

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

+ type BinlogEventListener struct

+ type ChangelogState string

+ const AllEventsUpToLockProcessed

+ const TablesInPlace

+ type EventsStreamer struct

+ func NewEventsStreamer() *EventsStreamer

+ func (this *EventsStreamer) AddListener(async bool, databaseName string, tableName string, ...) (err error)

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

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

+ type Inspector struct

+ func NewInspector() *Inspector

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

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

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

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

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

+ type Migrator struct

+ func NewMigrator() *Migrator

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

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