base

package

Go to main page

Versions in this module

v1

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