logic

Dec 19, 2024

Changes in this version

+ var ErrCPUProfilingBadOption = errors.New("unrecognized cpu profiling option")

+ var ErrCPUProfilingInProgress = errors.New("cpu profiling already in progress")

+ func GetConnectionConfig(ctx context.Context, container testcontainers.Container) (*mysql.ConnectionConfig, error)

+ func GetDSN(ctx context.Context, container testcontainers.Container) (string, error)

type Applier

+ func (this *Applier) InitAtomicCutOverWaitTimeout(tx *gosql.Tx) error

+ func (this *Applier) RevertAtomicCutOverWaitTimeout()

Oct 25, 2023

Changes in this version

+ const GhostChangelogTableComment

+ var ErrMigratorUnsupportedRenameAlter = errors.New(...)

type Applier

+ func (this *Applier) AttemptInstantDDL() error

type ChangelogState

+ const Migrated

Jul 7, 2022

Changes in this version

+ const ReadMigrationRangeValues

+ func Kill(db *gosql.DB, connectionID string) error

Jun 17, 2021 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Changes in this version

type Applier

+ func (this *Applier) AlterGhostAutoIncrement() error

May 3, 2021 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Aug 20, 2020 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Jul 21, 2020 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Feb 9, 2020 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Feb 14, 2019 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Oct 16, 2018 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

May 28, 2018 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Apr 17, 2018 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Feb 11, 2018 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Changes in this version

type Applier

+ func (this *Applier) Teardown()

type EventsStreamer

+ func (this *EventsStreamer) Teardown()

type Inspector

+ func (this *Inspector) Teardown()

type Throttler

+ func (this *Throttler) Teardown()

Sep 14, 2017 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Jul 21, 2017 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Apr 3, 2017 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Mar 12, 2017 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Changes in this version

type Applier

+ func (this *Applier) StartReplication() error

+ func (this *Applier) StartSlaveIOThread() error

Jan 9, 2017 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Changes in this version

type Applier

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

Dec 14, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Dec 6, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Changes in this version

type ChangelogState

+ func ReadChangelogState(s string) ChangelogState

Nov 1, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Changes in this version

type ChangelogState

+ const GhostTableMigrated

type EventsStreamer

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

Oct 12, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Sep 13, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Changes in this version

+ const NoPrintStatusRule

Sep 7, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Sep 5, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

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

Aug 26, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Aug 24, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Aug 22, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Changes in this version

+ const ForcePrintStatusAndHintRule

+ const ForcePrintStatusOnlyRule

Aug 18, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Aug 15, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Changes in this version

type Server

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

Aug 1, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Jul 31, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Jul 27, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Jul 19, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Jul 8, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Jul 4, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Jun 28, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

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

Jun 21, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Jun 20, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

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

Jun 15, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

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

Jun 9, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Jun 7, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Jun 7, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Jun 7, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

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)

Jun 6, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Changes in this version

type Inspector

+ func (this *Inspector) CountTableRows() error

Jun 1, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Changes in this version

type EventsStreamer

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

May 20, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

Changes in this version

+ const ReconnectStreamerSleepSeconds

type Applier

+ func (this *Applier) StartSlaveSQLThread() error

type EventsStreamer

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

May 17, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

May 16, 2016 GO-2022-0298

  GO-2022-0298: Command injection in gh-ost in github.com/github/gh-ost

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)