base

package

Go to main page

Versions in this module

v1

v1.0.48

Feb 14, 2019

Changes in this version

type MigrationContext

+ HooksHintOwner string

+ HooksHintToken string

+ TLSAllowInsecure bool

+ TLSCACertificate string

+ UseTLS bool

+ func (this *MigrationContext) SetupTLS() error

v1.0.47

Oct 16, 2018

Changes in this version

type MigrationContext

+ GoogleCloudPlatform bool

v1.0.46

May 28, 2018

Changes in this version

type MigrationContext

+ GhostTableVirtualColumns *sql.ColumnList

+ OriginalTableVirtualColumns *sql.ColumnList

v1.0.45

Apr 17, 2018

Changes in this version

type MigrationContext

+ AliyunRDS bool

+ CutOverExponentialBackoff bool

+ ExponentialBackoffMaxInterval int64

+ func (this *MigrationContext) SetExponentialBackoffMaxInterval(intervalSeconds int64) error

v1.0.44

Feb 11, 2018

Changes in this version

+ func TouchFile(fileName string) error

+ func ValidateConnection(db *gosql.DB, connectionConfig *mysql.ConnectionConfig) (string, error)

type MigrationContext

+ Uuid string

+ func NewMigrationContext() *MigrationContext

v1.0.42

Sep 14, 2017

Changes in this version

type MigrationContext

+ ForceTmpTableName string

v1.0.40

Jul 21, 2017

Changes in this version

+ const LeavingHibernationThrottleReasonHint

+ const MaxEventsBatchSize

type MigrationContext

+ CriticalLoadHibernateSeconds int64

+ DroppedColumnsMap map[string]bool

+ HibernateUntil int64

+ func (this *MigrationContext) GetRecentBinlogCoordinates() mysql.BinlogCoordinates

+ func (this *MigrationContext) SetRecentBinlogCoordinates(coordinates mysql.BinlogCoordinates)

v1.0.36

Apr 3, 2017

Changes in this version

+ const HTTPStatusOK

type MigrationContext

+ ThrottleHTTPStatusCode int64

+ func (this *MigrationContext) GetThrottleHTTP() string

+ func (this *MigrationContext) SetThrottleHTTP(throttleHTTP string)

v1.0.35

Mar 12, 2017

Changes in this version

type MigrationContext

+ ApplierMySQLVersion string

+ InspectorMySQLVersion string

+ TimestampOldTable bool

v1.0.34

Jan 9, 2017

Changes in this version

type MigrationContext

+ CliMasterPassword string

+ CliMasterUser string

+ DMLBatchSize int64

+ ReplicaServerId uint

+ func (this *MigrationContext) SetDMLBatchSize(batchSize int64)

v1.0.32

Dec 14, 2016

v1.0.30

Dec 6, 2016

Changes in this version

type MigrationContext

+ InCutOverCriticalSectionFlag int64

+ SkipForeignKeyChecks bool

v1.0.28

Nov 1, 2016

Changes in this version

type MigrationContext

+ ApplierTimeZone string

+ CutOverCompleteFlag int64

+ OriginalTableColumnsOnApplier *sql.ColumnList

type ThrottleCheckResult

+ ReasonHint ThrottleReasonHint

+ type ThrottleReasonHint string

+ const NoThrottleReasonHint

+ const UserCommandThrottleReasonHint

v1.0.21

Oct 12, 2016

Changes in this version

type MigrationContext

+ CriticalLoadIntervalMilliseconds int64

+ DiscardForeignKeys bool

+ func (this *MigrationContext) GetApplierHostname() string

+ func (this *MigrationContext) GetInspectorHostname() string

v1.0.20

Sep 13, 2016

Changes in this version

type MigrationContext

+ ForceNamedCutOverCommand bool

+ PanicAbort chan error

+ UserCommandedUnpostponeFlag int64

v1.0.18-experimental

Sep 7, 2016

v1.0.17

Sep 5, 2016

Changes in this version

type MigrationContext

+ AllEventsUpToLockProcessedInjectedFlag int64

+ AssumeMasterHostname string

+ CleanupImminentFlag int64

+ HeartbeatIntervalMilliseconds int64

+ HooksHintMessage string

+ HooksPath string

+ Hostname string

+ IsTungsten bool

+ func (this *MigrationContext) GetControlReplicasLagResult() mysql.ReplicationLagResult

+ func (this *MigrationContext) GetThrottleGeneralCheckResult() *ThrottleCheckResult

+ func (this *MigrationContext) SetControlReplicasLagResult(lagResult *mysql.ReplicationLagResult)

+ func (this *MigrationContext) SetHeartbeatIntervalMilliseconds(heartbeatIntervalMilliseconds int64)

+ func (this *MigrationContext) SetThrottleGeneralCheckResult(checkResult *ThrottleCheckResult) *ThrottleCheckResult

+ type ThrottleCheckResult struct

+ Reason string

+ ShouldThrottle bool

+ func NewThrottleCheckResult(throttle bool, reason string) *ThrottleCheckResult

v1.0.14

Aug 26, 2016

Changes in this version

type MigrationContext

+ ConcurrentCountTableRows bool

+ RowsDeltaEstimate int64

v1.0.13

Aug 24, 2016

Changes in this version

type MigrationContext

+ TestOnReplicaSkipReplicaStop bool

v1.0.11

Aug 22, 2016

v1.0.10

Aug 18, 2016

Changes in this version

type MigrationContext

+ AssumeRBR bool

+ HasSuperPrivilege bool

v1.0.9

Aug 15, 2016

v1.0.8

Aug 1, 2016

v1.0.7

Jul 31, 2016

Changes in this version

type MigrationContext

+ CountingRowsFlag int64

+ func (this *MigrationContext) GetNiceRatio() float64

+ func (this *MigrationContext) MarkRowCopyStartTime()

+ func (this *MigrationContext) SetNiceRatio(newRatio float64)

v1.0.6

Jul 27, 2016

Changes in this version

type MigrationContext

+ DropServeSocket bool

+ func (this *MigrationContext) AddThrottleControlReplicaKey(key mysql.InstanceKey) error

+ func (this *MigrationContext) GetReplicationLagQuery() string

+ func (this *MigrationContext) SetReplicationLagQuery(newQuery string)

v1.0.2

Jul 19, 2016

Changes in this version

type MigrationContext

+ func (this *MigrationContext) SetMaxLagMillisecondsThrottleThreshold(maxLagMillisecondsThrottleThreshold int64)

v1.0.1

Jul 8, 2016

Changes in this version

type MigrationContext

+ CutOverLockTimeoutSeconds int64

+ func (this *MigrationContext) SetCutOverLockTimeoutSeconds(timeoutSeconds int64) error

v0

v0.9.9

Jul 4, 2016

Changes in this version

type MigrationContext

+ NiceRatio int64

v0.9.8

Jun 28, 2016

Changes in this version

+ const CutOverAtomic

type MigrationContext

+ AllowedMasterMaster bool

v0.9.7

Jun 21, 2016

v0.9.6

Jun 20, 2016

Changes in this version

+ func StringContainsAll(s string, substrings ...string) bool

+ type LoadMap map[string]int64

+ func NewLoadMap() LoadMap

+ func ParseLoadMap(loadList string) (LoadMap, error)

+ func (this *LoadMap) Duplicate() LoadMap

+ func (this *LoadMap) String() string

type MigrationContext

+ ApproveRenamedColumns bool

+ ColumnRenameMap map[string]string

+ MappedSharedColumns *sql.ColumnList

+ PanicFlagFile string

+ RowCopyEndTime time.Time

+ SkipRenamedColumns bool

+ ThrottleQuery string

+ func (this *MigrationContext) GetCriticalLoad() LoadMap

+ func (this *MigrationContext) GetThrottleControlReplicaKeys() *mysql.InstanceKeyMap

+ func (this *MigrationContext) GetThrottleQuery() string

+ func (this *MigrationContext) MarkRowCopyEndTime()

+ func (this *MigrationContext) ReadCriticalLoad(criticalLoadList string) error

+ func (this *MigrationContext) ReadThrottleControlReplicaKeys(throttleControlReplicas string) error

+ func (this *MigrationContext) SetDefaultNumRetries(retries int64)

+ func (this *MigrationContext) SetThrottleQuery(newQuery string)

v0.9.2

Jun 15, 2016

Changes in this version

type CutOver

+ const CutOverSafe

type MigrationContext

+ IsPostponingCutOver int64

+ MigrateOnReplica bool

v0.8.8

Jun 9, 2016

Changes in this version

type MigrationContext

+ func (this *MigrationContext) GetMaxLoad() map[string]int64

v0.8.7

Jun 7, 2016

v0.8.5

Jun 7, 2016

Changes in this version

type MigrationContext

+ PostponeCutOverFlagFile string

v0.8.4

Jun 7, 2016

Changes in this version

type MigrationContext

+ ServeSocketFile string

+ ServeTCPPort int64

+ ThrottleCommandedByUser int64

+ func (this *MigrationContext) SetChunkSize(chunkSize int64)

v0.8.3

Jun 6, 2016

Changes in this version

+ type CutOver int

+ const CutOverTwoStep

+ const CutOverUdfWait

+ const CutOverVoluntaryLock

type MigrationContext

+ CutOverType CutOver

v0.8.2

Jun 1, 2016

Changes in this version

type MigrationContext

+ func (this *MigrationContext) MarkPointOfInterest() int64

+ func (this *MigrationContext) TimeSincePointOfInterest() time.Duration

v0.7.16

May 20, 2016

Changes in this version

+ type ContextConfig struct

+ Client struct{ ... }

+ Osc struct{ ... }

type MigrationContext

+ CliPassword string

+ CliUser string

+ NullableUniqueKeyAllowed bool

+ func (this *MigrationContext) ApplyCredentials()

v0.7.2

May 17, 2016

Changes in this version

+ func FileExists(fileName string) bool

type MigrationContext

+ PostponeSwapTablesFlagFile string

v0.7.1

May 16, 2016

Changes in this version

+ const CountRowsEstimate

+ const ExplainRowsEstimate

+ const TableStatusRowsEstimate

+ func PrettifyDurationOutput(d time.Duration) string

+ type MigrationContext struct

+ AllowedRunningOnMaster bool

+ AlterStatement string

+ ApplierConnectionConfig *mysql.ConnectionConfig

+ CanStopStreaming func() bool

+ ChunkSize int64

+ ConfigFile string

+ CountTableRows bool

+ CurrentLag int64

+ DatabaseName string

+ GhostTableColumns *sql.ColumnList

+ GhostTableUniqueKeys [](*sql.UniqueKey)

+ InitiallyDropGhostTable bool

+ InitiallyDropOldTable bool

+ InspectorConnectionConfig *mysql.ConnectionConfig

+ Iteration int64

+ LockTablesStartTime time.Time

+ MaxLagMillisecondsThrottleThreshold int64

+ MaxLoad map[string]int64

+ MigrationIterationRangeMaxValues *sql.ColumnValues

+ MigrationIterationRangeMinValues *sql.ColumnValues

+ MigrationRangeMaxValues *sql.ColumnValues

+ MigrationRangeMinValues *sql.ColumnValues

+ Noop bool

+ OkToDropTable bool

+ OriginalBinlogFormat string

+ OriginalBinlogRowImage string

+ OriginalTableColumns *sql.ColumnList

+ OriginalTableName string

+ OriginalTableUniqueKeys [](*sql.UniqueKey)

+ QuickAndBumpySwapTables bool

+ RenameTablesEndTime time.Time

+ RenameTablesStartTime time.Time

+ ReplictionLagQuery string

+ RowCopyStartTime time.Time

+ RowsEstimate int64

+ SharedColumns *sql.ColumnList

+ StartTime time.Time

+ SwapTablesTimeoutSeconds int64

+ SwitchToRowBinlogFormat bool

+ TableEngine string

+ TestOnReplica bool

+ ThrottleAdditionalFlagFile string

+ ThrottleControlReplicaKeys *mysql.InstanceKeyMap

+ ThrottleFlagFile string

+ TotalDMLEventsApplied int64

+ TotalRowsCopied int64

+ UniqueKey *sql.UniqueKey

+ UsedRowsEstimateMethod RowsEstimateMethod

+ func GetMigrationContext() *MigrationContext

+ func (this *MigrationContext) ElapsedRowCopyTime() time.Duration

+ func (this *MigrationContext) ElapsedTime() time.Duration

+ func (this *MigrationContext) GetChangelogTableName() string

+ func (this *MigrationContext) GetGhostTableName() string

+ func (this *MigrationContext) GetIteration() int64

+ func (this *MigrationContext) GetOldTableName() string

+ func (this *MigrationContext) GetTotalRowsCopied() int64

+ func (this *MigrationContext) GetVoluntaryLockName() string

+ func (this *MigrationContext) HasMigrationRange() bool

+ func (this *MigrationContext) InspectorIsAlsoApplier() bool

+ func (this *MigrationContext) IsThrottled() (bool, string)

+ func (this *MigrationContext) IsTransactionalTable() bool

+ func (this *MigrationContext) MaxRetries() int

+ func (this *MigrationContext) ReadConfigFile() error

+ func (this *MigrationContext) ReadMaxLoad(maxLoadList string) error

+ func (this *MigrationContext) RequiresBinlogFormatChange() bool

+ func (this *MigrationContext) SetThrottled(throttle bool, reason string)

+ type RowsEstimateMethod string

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