inst

Jul 11, 2016

Changes in this version

type Instance

+ func GetClusterGhostSlaves(clusterName string) (result [](*Instance), err error)

Jun 14, 2016

Changes in this version

+ func ExpirePoolInstances() error

type CandidatePromotionRule

+ func ParseCandidatePromotionRule(ruleName string) (CandidatePromotionRule, error)

May 18, 2016

Changes in this version

+ var DowntimeLostInRecoveryMessage = "lost-in-recovery"

+ func EnableSemiSync(instanceKey *InstanceKey, master, slave bool) error

+ func FindClusterNameByFuzzyInstanceKey(fuzzyInstanceKey *InstanceKey) (string, error)

+ func IsSmallerBinlogFormat(binlogFormat string, otherBinlogFormat string) bool

+ func IsSmallerMajorVersion(version string, otherVersion string) bool

+ func MajorVersion(version string) []string

+ func ReadAliasByClusterName(clusterName string) (alias string, err error)

+ func ReadClusterNameByAlias(alias string) (clusterName string, err error)

+ func ReplaceAliasClusterName(oldClusterName string, newClusterName string) error

type ClusterInfo

+ func (this *ClusterInfo) ApplyClusterAlias()

type Instance

+ AllowTLS bool

+ InstanceAlias string

+ IsDetachedMaster bool

+ SemiSyncEnforced bool

+ func ReadLostInRecoveryInstances(clusterName string) ([](*Instance), error)

+ func (this *Instance) IsMySQL59() bool

+ func (this *Instance) IsSmallerBinlogFormat(other *Instance) bool

+ func (this *Instance) MajorVersionString() string

type InstanceKey

+ func GetHeuristicClusterDomainInstanceAttribute(clusterName string) (instanceKey *InstanceKey, err error)

+ func HeuristicallyApplyClusterDomainInstanceAttribute(clusterName string) (instanceKey *InstanceKey, err error)

+ func ParseRawInstanceKeyLoose(hostPort string) (*InstanceKey, error)

Mar 10, 2016

Changes in this version

+ const AllMasterSlavesStale

+ const MixedAndRowLoggingSlavesStructureWarning

+ const MultipleMajorVersionsLoggingSlaves

+ const MustNotPromoteRule

+ const MustPromoteRule

+ const NeutralPromoteRule

+ const PreferNotPromoteRule

+ const PreferPromoteRule

+ const StatementAndMixedLoggingSlavesStructureWarning

+ const StatementAndRowLoggingSlavesStructureWarning

+ const UnreachableMasterWithStaleSlaves

+ func GetHeuristicClusterPoolInstancesLag(clusterName string, pool string) (int64, error)

+ func GetHeuristiclyRecentCoordinatesForInstance(instanceKey *InstanceKey) (selfCoordinates *BinlogCoordinates, relayLogCoordinates *BinlogCoordinates, ...)

+ func GetInstancesMaxLag(instances [](*Instance)) (maxLag int64, err error)

+ func GetSlaveRestartPreserveStatements(instanceKey *InstanceKey, injectedStatement string) (statements []string, err error)

+ func ReadInstancePromotionRule(instance *Instance) (err error)

+ func ReadReplicationCredentials(instanceKey *InstanceKey) (replicationUser string, replicationPassword string, err error)

+ func RecordInstanceBinlogFileHistory() error

+ func RecordInstanceCoordinatesHistory() error

+ func SemicolonTerminated(statement string) string

+ func UpdateInstanceRecentRelaylogHistory() error

+ type CandidatePromotionRule string

type Instance

+ HasReplicationCredentials bool

+ PromotionRule CandidatePromotionRule

+ ReplicationCredentialsAvailable bool

+ func ChangeMasterCredentials(instanceKey *InstanceKey, masterUser string, masterPassword string) (*Instance, error)

+ func FindFuzzyInstances(fuzzyInstanceKey *InstanceKey) ([](*Instance), error)

+ func GetHeuristicClusterPoolInstances(clusterName string, pool string) (result [](*Instance), err error)

+ func ReadClusterWriteableMaster(clusterName string) ([](*Instance), error)

+ func ReadFuzzyInstance(fuzzyInstanceKey *InstanceKey) (*Instance, error)

+ func ReadWriteableClustersMasters() (instances [](*Instance), err error)

+ func (this *Instance) LagStatusString() string

type InstanceKey

+ func ReadFuzzyInstanceKey(fuzzyInstanceKey *InstanceKey) *InstanceKey

+ func ReadFuzzyInstanceKeyIfPossible(fuzzyInstanceKey *InstanceKey) *InstanceKey

type InstanceKeyMap

+ func (this *InstanceKeyMap) HasKey(key InstanceKey) bool

type PoolInstancesMap

+ func ReadClusterPoolInstancesMap(clusterName string, pool string) (*PoolInstancesMap, error)

type ReplicationAnalysis

+ CountDistinctMajorVersionsLoggingSlaves uint

+ CountMixedBasedLoggingSlaves uint

+ CountRowBasedLoggingSlaves uint

+ CountStaleSlaves uint

+ CountStatementBasedLoggingSlaves uint

+ StructureAnalysis []StructureAnalysisCode

+ func (this *ReplicationAnalysis) AnalysisString() string

+ type StructureAnalysisCode string

Nov 24, 2015

Changes in this version

+ func HostnameResolveMethodIsNone() bool

+ func LoadHostnameResolveCache() error

Nov 24, 2015

Changes in this version

type BinlogCoordinates

+ func (this *BinlogCoordinates) IsEmpty() bool

type Instance

+ GtidPurged string

+ type OracleGtidSet struct

+ GtidEntries [](*OracleGtidSetEntry)

+ func ParseGtidSet(gtidSet string) (res *OracleGtidSet, err error)

+ func (this *OracleGtidSet) RemoveUUID(uuid string) (removed bool)

+ func (this OracleGtidSet) String() string

+ type OracleGtidSetEntry struct

+ Ranges string

+ UUID string

+ func NewOracleGtidSetEntry(gtidRangeString string) (*OracleGtidSetEntry, error)

+ func (this OracleGtidSetEntry) String() string

Nov 23, 2015

Changes in this version

+ func ReadInstanceClusterAttributes(instance *Instance) (err error)

type Instance

+ func DetachSlaveMasterHost(instanceKey *InstanceKey) (*Instance, error)

+ func ReattachSlaveMasterHost(instanceKey *InstanceKey) (*Instance, error)

+ func ResetMaster(instanceKey *InstanceKey) (*Instance, error)

+ func ResetMasterGTIDOperation(instanceKey *InstanceKey) (*Instance, error)

type InstanceKey

+ func (this *InstanceKey) DetachedKey() *InstanceKey

+ func (this *InstanceKey) IsDetached() bool

+ func (this *InstanceKey) ReattachedKey() *InstanceKey

+ func (this *InstanceKey) SmallerThan(other *InstanceKey) bool

+ func (this *InstanceKey) StringCode() string

Nov 19, 2015

Changes in this version

type BinlogCoordinates

+ func (this *BinlogCoordinates) SmallerThanOrEquals(other *BinlogCoordinates) bool

type Instance

+ LastSeenTimestamp string

Nov 11, 2015

Changes in this version

+ func AuditInstanceAnalysisInChangelog(instanceKey *InstanceKey, analysisCode AnalysisCode) error

+ func ExpireInstanceAnalysisChangelog() error

+ type ReplicationAnalysisChangelog struct

+ AnalyzedInstanceKey InstanceKey

+ Changelog string

+ func ReadReplicationAnalysisChangelog() ([]ReplicationAnalysisChangelog, error)

Oct 27, 2015

Changes in this version

+ func RegroupSlavesPseudoGTID(masterKey *InstanceKey, returnSlaveEvenOnFailureToRegroup bool, ...) ([](*Instance), [](*Instance), [](*Instance), *Instance, error)

+ func RegroupSlavesPseudoGTIDIncludingSubSlavesOfBinlogServers(masterKey *InstanceKey, returnSlaveEvenOnFailureToRegroup bool, ...) ([](*Instance), [](*Instance), [](*Instance), *Instance, error)

type BinlogCoordinates

+ func CorrelateBinlogCoordinates(instance *Instance, binlogCoordinates *BinlogCoordinates, ...) (*BinlogCoordinates, int, error)

+ func ParseBinlogCoordinates(logFileLogPos string) (*BinlogCoordinates, error)

+ func SearchEntryInBinlog(instanceKey *InstanceKey, binlog string, entryText string, ...) (BinlogCoordinates, bool, error)

+ func SearchEntryInInstanceBinlogs(instance *Instance, entryText string, monotonicPseudoGTIDEntries bool) (*BinlogCoordinates, error)

+ func (this BinlogCoordinates) String() string

Oct 22, 2015

Changes in this version

+ func GetClusterName(instanceKey *InstanceKey) (clusterName string, err error)

Oct 20, 2015

Changes in this version

+ func EnableAuditSyslog() (err error)

type Instance

+ func RemoveBinlogServerInstances(instances [](*Instance)) [](*Instance)

+ func RemoveInstance(instances [](*Instance), instanceKey *InstanceKey) [](*Instance)

+ func RemoveNilInstances(instances [](*Instance)) [](*Instance)

Oct 13, 2015

Changes in this version

+ const DeadCoMasterAndSomeSlaves

Oct 8, 2015

Changes in this version

+ type PostponedFunctionsContainer struct

+ PostponedFunctions [](func() error)

+ func NewPostponedFunctionsContainer() *PostponedFunctionsContainer

+ func (this *PostponedFunctionsContainer) AddPostponedFunction(f func() error)

+ func (this *PostponedFunctionsContainer) InvokePostponed() (err error)

Oct 7, 2015

Changes in this version

+ func FlushNontrivialResolveCacheToDatabase() error

type InstanceKey

+ func (this InstanceKey) String() string

Sep 17, 2015

Changes in this version

+ func RegroupSlavesGTID(masterKey *InstanceKey, returnSlaveEvenOnFailureToRegroup bool, ...) ([](*Instance), [](*Instance), *Instance, error)

+ func UpdateClusterAliases() error

type BinlogCoordinates

+ func (this *BinlogCoordinates) DetachedCoordinates() (isDetached bool, detachedLogFile string, detachedLogPos string)

type Instance

+ DowntimeEndTimestamp string

+ DowntimeOwner string

+ DowntimeReason string

+ IsDetached bool

+ IsDowntimed bool

+ ServerUUID string

+ SuggestedClusterAlias string

+ func GetCandidateSlaveOfBinlogServerTopology(masterKey *InstanceKey) (candidateSlave *Instance, err error)

+ func PurgeBinaryLogsTo(instanceKey *InstanceKey, logFile string) (*Instance, error)

+ func PurgeBinaryLogsToCurrent(instanceKey *InstanceKey) (*Instance, error)

+ func RegroupSlavesBinlogServers(masterKey *InstanceKey, returnSlaveEvenOnFailureToRegroup bool) (promotedBinlogServer *Instance, err error)

+ func SkipToNextBinaryLog(instanceKey *InstanceKey) (*Instance, error)

type InstanceKeyMap

+ func NewInstanceKeyMap() *InstanceKeyMap

+ func (this *InstanceKeyMap) AddInstances(instances [](*Instance))

+ func (this *InstanceKeyMap) AddKey(key InstanceKey)

+ func (this *InstanceKeyMap) AddKeys(keys []InstanceKey)

+ func (this *InstanceKeyMap) ReadCommaDelimitedList(list string) error

+ func (this *InstanceKeyMap) ReadJson(jsonString string) error

+ func (this *InstanceKeyMap) ToCommaDelimitedList() string

+ func (this *InstanceKeyMap) ToJSON() (string, error)

+ func (this *InstanceKeyMap) ToJSONString() string

type ReplicationAnalysis

+ BinlogServerImmediateTopology bool

+ MariaDBGTIDImmediateTopology bool

+ OracleGTIDImmediateTopology bool

+ PseudoGTIDImmediateTopology bool

Sep 1, 2015

Changes in this version

+ func MoveSlavesGTID(masterKey *InstanceKey, belowKey *InstanceKey, pattern string) (movedSlaves [](*Instance), unmovedSlaves [](*Instance), err error, ...)

type Instance

+ func MoveBelowGTID(instanceKey, otherKey *InstanceKey) (*Instance, error)

Aug 27, 2015

Changes in this version

+ func EmptyCommitInstance(instanceKey *InstanceKey) error

+ func ExpireMasterPositionEquivalence() error

+ func MoveSlavesViaGTID(slaves [](*Instance), other *Instance) (movedSlaves [](*Instance), unmovedSlaves [](*Instance), err error, ...)

+ func WriteMasterPositionEquivalence(master1Key *InstanceKey, master1BinlogCoordinates *BinlogCoordinates, ...) error

type BinlogCoordinates

+ func GetEquivalentBinlogCoordinatesFor(instanceCoordinates *InstanceBinlogCoordinates, belowKey *InstanceKey) (*BinlogCoordinates, error)

type Instance

+ ExecutedGtidSet string

+ func MoveEquivalent(instanceKey, otherKey *InstanceKey) (*Instance, error)

+ func RestartSlave(instanceKey *InstanceKey) (instance *Instance, err error)

+ func (this *Instance) NextGTID() (string, error)

+ type InstanceBinlogCoordinates struct

+ Coordinates BinlogCoordinates

+ Key InstanceKey

+ func GetEquivalentMasterCoordinates(instanceCoordinates *InstanceBinlogCoordinates) (result [](*InstanceBinlogCoordinates), err error)

Aug 19, 2015

Changes in this version

+ const GTIDHintDeny

+ const GTIDHintForce

+ const GTIDHintNeutral

type Instance

+ func DisableGTID(instanceKey *InstanceKey) (*Instance, error)

+ func EnableGTID(instanceKey *InstanceKey) (*Instance, error)

+ type OperationGTIDHint string

Aug 13, 2015

Changes in this version

type Instance

+ func RelocateBelow(instanceKey, otherKey *InstanceKey) (*Instance, error)

+ func RelocateSlaves(instanceKey, otherKey *InstanceKey, pattern string) (slaves [](*Instance), err error, errs []error)

Aug 7, 2015

Changes in this version

+ func ExpireAudit() error

type BinlogCoordinates

+ func (this *BinlogCoordinates) FileNumber() (int, int)

+ func (this *BinlogCoordinates) FileNumberDistance(other *BinlogCoordinates) int

type Instance

+ func FlushBinaryLogsTo(instanceKey *InstanceKey, logFile string) (*Instance, error)

+ func (this *Instance) IsMySQL51() bool

+ func (this *Instance) IsMySQL55() bool

+ func (this *Instance) IsMySQL56() bool

+ func (this *Instance) IsMySQL57() bool

+ func (this *Instance) IsMySQL58() bool

+ func (this *Instance) IsOracleMySQL() bool

+ func (this *Instance) IsSmallerMajorVersionByString(otherVersion string) bool

Aug 6, 2015

Changes in this version

+ func ApplyClusterDomain(clusterInfo *ClusterInfo)

+ func ExpireClusterDomainName() error

+ func ReadClusterDomainName(clusterName string) (string, error)

+ func WriteClusterDomainName(clusterName string, domainName string) error

type ClusterInfo

+ ClusterDomain string

Jul 24, 2015

Changes in this version

+ func RegroupSlavesIncludingSubSlavesOfBinlogServers(masterKey *InstanceKey, returnSlaveEvenOnFailureToRegroup bool, ...) ([](*Instance), [](*Instance), [](*Instance), *Instance, error)

type Instance

+ func RepointTo(slaves [](*Instance), belowKey *InstanceKey) ([](*Instance), error, []error)

Jul 21, 2015

Changes in this version

+ const BinlogServerFailingToConnectToMaster

type Instance

+ func ReadBinlogServerSlaveInstances(masterKey *InstanceKey) ([](*Instance), error)

+ func ReadSlaveInstancesIncludingBinlogServerSubSlaves(masterKey *InstanceKey) ([](*Instance), error)

+ func (this *Instance) IsBinlogServer() bool

type ReplicationAnalysis

+ IsBinlogServer bool

Jul 16, 2015

Changes in this version

+ const AllIntermediateMasterSlavesFailingToConnectOrDead

Jul 10, 2015

Changes in this version

+ const AllMasterSlavesNotReplicatingOrDead

+ const DeadIntermediateMasterWithSingleSlave

+ const DeadIntermediateMasterWithSingleSlaveFailingToConnect

+ const MasterSingleSlaveDead

+ const MasterSingleSlaveNotReplicating

+ func ResolveUnknownMasterHostnameResolves() error

type BinlogCoordinates

+ func (this *BinlogCoordinates) PreviousFileCoordinatesBy(offset int) (BinlogCoordinates, error)

type Instance

+ func RepointSlavesTo(instanceKey *InstanceKey, pattern string, masterKey *InstanceKey) ([](*Instance), error, []error)

type ReplicationAnalysis

+ CountSlavesFailingToConnectToMaster uint

Jul 8, 2015

Changes in this version

+ func WriteHostnameUnresolve(instanceKey *InstanceKey, unresolvedHostname string) error

Jul 3, 2015

Changes in this version

+ const AllCoMasterSlavesNotReplicating

+ const AllIntermediateMasterSlavesNotReplicating

+ const AllMasterSlavesNotReplicating

+ const DeadCoMaster

+ const DeadIntermediateMaster

+ const DeadIntermediateMasterAndSomeSlaves

+ const DeadMaster

+ const DeadMasterAndSlaves

+ const DeadMasterAndSomeSlaves

+ const DeadMasterWithoutSlaves

+ const FirstTierSlaveFailingToConnectToMaster

+ const MasterWithoutSlaves

+ const MaxscaleFailingToConnectToMaster

+ const NoProblem

+ const UnreachableCoMaster

+ const UnreachableIntermediateMaster

+ const UnreachableMaster

+ func ASCIITopology(instanceKey *InstanceKey, historyTimestampPattern string) (string, error)

+ func ApplyClusterAlias(clusterInfo *ClusterInfo)

+ func ApplyPoolInstances(pool string, instancesList string) error

+ func AuditOperation(auditType string, instanceKey *InstanceKey, message string) error

+ func BeginBoundedMaintenance(instanceKey *InstanceKey, owner string, reason string, durationSeconds uint) (int64, error)

+ func BeginDowntime(instanceKey *InstanceKey, owner string, reason string, durationSeconds uint) error

+ func BeginMaintenance(instanceKey *InstanceKey, owner string, reason string) (int64, error)

+ func DeleteInvalidHostnameResolves() error

+ func DeregisterHostnameUnresolve(instanceKey *InstanceKey) error

+ func EndDowntime(instanceKey *InstanceKey) error

+ func EndMaintenance(maintenanceToken int64) error

+ func EndMaintenanceByInstanceKey(instanceKey *InstanceKey) error

+ func ExecDBWriteFunc(f func() error) error

+ func ExecInstance(instanceKey *InstanceKey, query string, args ...interface{}) (sql.Result, error)

+ func ExecInstanceNoPrepare(instanceKey *InstanceKey, query string, args ...interface{}) (sql.Result, error)

+ func ExecuteOnTopology(f func())

+ func ExpireCandidateInstances() error

+ func ExpireDowntime() error

+ func ExpireHostnameUnresolve() error

+ func ExpireMaintenance() error

+ func FlushBinaryLogs(instanceKey *InstanceKey) error

+ func ForgetExpiredHostnameResolves() error

+ func ForgetInstance(instanceKey *InstanceKey) error

+ func ForgetLongUnseenInstances() error

+ func ForgetUnseenInstancesDifferentlyResolved() error

+ func GetCNAME(hostname string) (string, error)

+ func GetCandidateSlave(masterKey *InstanceKey, forRematchPurposes bool) (*Instance, [](*Instance), [](*Instance), [](*Instance), error)

+ func GetClusterByAlias(alias string) (string, error)

+ func GetClusterHeuristicLag(clusterName string) (int64, error)

+ func GetMaintenanceOwner() string

+ func HostnameResolveCache() (map[string]*cache.Item, error)

+ func InjectUnseenMasters() error

+ func InstanceIsMasterOf(instance0, instance1 *Instance) bool

+ func InstancesAreSiblings(instance0, instance1 *Instance) bool

+ func LoadHostnameResolveCacheFromDatabase() error

+ func MatchBelow(instanceKey, otherKey *InstanceKey, requireInstanceMaintenance bool, ...) (*Instance, *BinlogCoordinates, error)

+ func MatchUp(instanceKey *InstanceKey, requireInstanceMaintenance bool, ...) (*Instance, *BinlogCoordinates, error)

+ func MatchUpSlaves(masterKey *InstanceKey, pattern string) ([](*Instance), *Instance, error, []error)

+ func MoveUpSlaves(instanceKey *InstanceKey, pattern string) ([](*Instance), *Instance, error, []error)

+ func MultiMatchBelow(slaves [](*Instance), belowKey *InstanceKey, slavesAlreadyStopped bool) ([](*Instance), *Instance, error, []error)

+ func MultiMatchSlaves(masterKey *InstanceKey, belowKey *InstanceKey, pattern string) ([](*Instance), *Instance, error, []error)

+ func PopulateInstancesAgents(instances [](*Instance)) error

+ func ReadClusterAliases() error

+ func ReadClusterByAlias(alias string) (string, error)

+ func ReadClusterNameByMaster(instanceKey *InstanceKey, masterKey *InstanceKey) (clusterName string, replicationDepth uint, isCoMaster bool, err error)

+ func ReadClusters() ([]string, error)

+ func ReadCountMySQLSnapshots(hostnames []string) (map[string]int, error)

+ func ReadResolvedHostname(hostname string) (string, error)

+ func RefreshTopologyInstances(instances [](*Instance))

+ func RegisterCandidateInstance(instanceKey *InstanceKey) error

+ func RegisterHostnameUnresolve(instanceKey *InstanceKey, unresolvedHostname string) error

+ func RegroupSlaves(masterKey *InstanceKey, onCandidateSlaveChosen func(*Instance)) ([](*Instance), [](*Instance), [](*Instance), *Instance, error)

+ func RematchSlave(instanceKey *InstanceKey, requireInstanceMaintenance bool, ...) (*Instance, *BinlogCoordinates, error)

+ func ResetHostnameResolveCache() error

+ func ResolveHostname(hostname string) (string, error)

+ func ReviewUnseenInstances() error

+ func ScanInstanceRow(instanceKey *InstanceKey, query string, dest ...interface{}) error

+ func SetClusterAlias(clusterName string, alias string) error

+ func SetMaintenanceOwner(owner string)

+ func SnapshotTopologies() error

+ func StartSlaves(slaves [](*Instance))

+ func UpdateInstanceLastAttemptedCheck(instanceKey *InstanceKey) error

+ func UpdateInstanceLastChecked(instanceKey *InstanceKey) error

+ func UpdateResolvedHostname(hostname string, resolvedHostname string) bool

+ func WriteClusterAlias(clusterName string, alias string) error

+ func WriteLongRunningProcesses(instanceKey *InstanceKey, processes []Process) error

+ func WriteResolvedHostname(hostname string, resolvedHostname string) error

+ type AnalysisCode string

+ type Audit struct

+ AuditId int64

+ AuditInstanceKey InstanceKey

+ AuditTimestamp string

+ AuditType string

+ Message string

+ func ReadRecentAudit(page int) ([]Audit, error)

+ type BinlogCoordinates struct

+ LogFile string

+ LogPos int64

+ Type BinlogType

+ func FindLastPseudoGTIDEntry(instance *Instance, recordedInstanceRelayLogCoordinates BinlogCoordinates, ...) (*BinlogCoordinates, string, error)

+ func GetNextBinlogCoordinatesToMatch(instance *Instance, instanceCoordinates BinlogCoordinates, ...) (*BinlogCoordinates, int, error)

+ func SearchPseudoGTIDEntryInBinlog(instanceKey *InstanceKey, binlog string, entryText string) (BinlogCoordinates, bool, error)

+ func SearchPseudoGTIDEntryInInstance(instance *Instance, entryText string) (*BinlogCoordinates, error)

+ func (this *BinlogCoordinates) DisplayString() string

+ func (this *BinlogCoordinates) Equals(other *BinlogCoordinates) bool

+ func (this *BinlogCoordinates) FileSmallerThan(other *BinlogCoordinates) bool

+ func (this *BinlogCoordinates) NextFileCoordinates() (BinlogCoordinates, error)

+ func (this *BinlogCoordinates) PreviousFileCoordinates() (BinlogCoordinates, error)

+ func (this *BinlogCoordinates) SmallerThan(other *BinlogCoordinates) bool

+ type BinlogEvent struct

+ Coordinates BinlogCoordinates

+ EventType string

+ Info string

+ NextEventPos int64

+ func (this *BinlogEvent) NextBinlogCoordinates() BinlogCoordinates

+ func (this *BinlogEvent) NormalizeInfo()

+ type BinlogEventCursor struct

+ func NewBinlogEventCursor(startCoordinates BinlogCoordinates, ...) BinlogEventCursor

+ type BinlogType int

+ const BinaryLog

+ const RelayLog

+ type ClusterInfo struct

+ ClusterAlias string

+ ClusterName string

+ CountInstances uint

+ HasAutomatedIntermediateMasterRecovery bool

+ HasAutomatedMasterRecovery bool

+ HeuristicLag int64

+ func ReadClusterInfo(clusterName string) (*ClusterInfo, error)

+ func ReadClustersInfo() ([]ClusterInfo, error)

+ func (this *ClusterInfo) ReadRecoveryInfo()

+ type ClusterPoolInstance struct

+ ClusterAlias string

+ ClusterName string

+ Hostname string

+ Pool string

+ Port int

+ func ReadAllClusterPoolInstances() ([](*ClusterPoolInstance), error)

+ type HostnameResolve struct

+ type Instance struct

+ Binlog_format string

+ ClusterName string

+ CountMySQLSnapshots int

+ DataCenter string

+ ExecBinlogCoordinates BinlogCoordinates

+ HasReplicationFilters bool

+ IsCandidate bool

+ IsCoMaster bool

+ IsLastCheckValid bool

+ IsRecentlyChecked bool

+ IsUpToDate bool

+ Key InstanceKey

+ LastIOError string

+ LastSQLError string

+ LogBinEnabled bool

+ LogSlaveUpdatesEnabled bool

+ MasterKey InstanceKey

+ PhysicalEnvironment string

+ ReadBinlogCoordinates BinlogCoordinates

+ ReadOnly bool

+ RelaylogCoordinates BinlogCoordinates

+ ReplicationDepth uint

+ SQLDelay uint

+ SecondsBehindMaster sql.NullInt64

+ SecondsSinceLastSeen sql.NullInt64

+ SelfBinlogCoordinates BinlogCoordinates

+ ServerID uint

+ SlaveHosts InstanceKeyMap

+ SlaveLagSeconds sql.NullInt64

+ Slave_IO_Running bool

+ Slave_SQL_Running bool

+ SupportsOracleGTID bool

+ UnresolvedHostname string

+ Uptime uint

+ UsingMariaDBGTID bool

+ UsingOracleGTID bool

+ UsingPseudoGTID bool

+ Version string

+ func ChangeMasterTo(instanceKey *InstanceKey, masterKey *InstanceKey, ...) (*Instance, error)

+ func DetachSlave(instanceKey *InstanceKey) (*Instance, error)

+ func DetachSlaveOperation(instanceKey *InstanceKey) (*Instance, error)

+ func EnslaveMaster(instanceKey *InstanceKey) (*Instance, error)

+ func EnslaveSiblings(instanceKey *InstanceKey) (*Instance, int, error)

+ func FindInstances(regexpPattern string) ([](*Instance), error)

+ func GetClusterOSCSlaves(clusterName string) ([](*Instance), error)

+ func GetInstanceMaster(instance *Instance) (*Instance, error)

+ func KillQuery(instanceKey *InstanceKey, process int64) (*Instance, error)

+ func MakeCoMaster(instanceKey *InstanceKey) (*Instance, error)

+ func MakeLocalMaster(instanceKey *InstanceKey) (*Instance, error)

+ func MakeMaster(instanceKey *InstanceKey) (*Instance, error)

+ func MasterPosWait(instanceKey *InstanceKey, binlogCoordinates *BinlogCoordinates) (*Instance, error)

+ func MoveBelow(instanceKey, siblingKey *InstanceKey) (*Instance, error)

+ func MoveBelowViaGTID(instance, otherInstance *Instance) (*Instance, error)

+ func MoveUp(instanceKey *InstanceKey) (*Instance, error)

+ func NewInstance() *Instance

+ func ReadClusterCandidateInstances(clusterName string) ([](*Instance), error)

+ func ReadClusterInstances(clusterName string) ([](*Instance), error)

+ func ReadHistoryClusterInstances(clusterName string, historyTimestampPattern string) ([](*Instance), error)

+ func ReadInstance(instanceKey *InstanceKey) (*Instance, bool, error)

+ func ReadProblemInstances() ([](*Instance), error)

+ func ReadSlaveInstances(masterKey *InstanceKey) ([](*Instance), error)

+ func ReadTopologyInstance(instanceKey *InstanceKey) (*Instance, error)

+ func ReadUnseenInstances() ([](*Instance), error)

+ func ReattachSlave(instanceKey *InstanceKey) (*Instance, error)

+ func ReattachSlaveOperation(instanceKey *InstanceKey) (*Instance, error)

+ func RefreshInstanceSlaveHosts(instanceKey *InstanceKey) (*Instance, error)

+ func RefreshTopologyInstance(instanceKey *InstanceKey) (*Instance, error)

+ func Repoint(instanceKey *InstanceKey, masterKey *InstanceKey) (*Instance, error)

+ func RepointSlaves(instanceKey *InstanceKey, pattern string) ([](*Instance), error, []error)

+ func ResetSlave(instanceKey *InstanceKey) (*Instance, error)

+ func ResetSlaveOperation(instanceKey *InstanceKey) (*Instance, error)

+ func SearchInstances(searchString string) ([](*Instance), error)

+ func SetReadOnly(instanceKey *InstanceKey, readOnly bool) (*Instance, error)

+ func SkipQuery(instanceKey *InstanceKey) (*Instance, error)

+ func StartSlave(instanceKey *InstanceKey) (*Instance, error)

+ func StartSlaveUntilMasterCoordinates(instanceKey *InstanceKey, masterCoordinates *BinlogCoordinates) (*Instance, error)

+ func StopSlave(instanceKey *InstanceKey) (*Instance, error)

+ func StopSlaveNicely(instanceKey *InstanceKey, timeout time.Duration) (*Instance, error)

+ func StopSlavesNicely(slaves [](*Instance), timeout time.Duration) [](*Instance)

+ func (this *Instance) AddSlaveKey(slaveKey *InstanceKey)

+ func (this *Instance) CanMove() (bool, error)

+ func (this *Instance) CanMoveAsCoMaster() (bool, error)

+ func (this *Instance) CanMoveViaMatch() (bool, error)

+ func (this *Instance) CanReplicateFrom(other *Instance) (bool, error)

+ func (this *Instance) Equals(other *Instance) bool

+ func (this *Instance) GetNextBinaryLog(binlogCoordinates BinlogCoordinates) (BinlogCoordinates, error)

+ func (this *Instance) GetSlaveHostsAsJson() string

+ func (this *Instance) HasReasonableMaintenanceReplicationLag() bool

+ func (this *Instance) HumanReadableDescription() string

+ func (this *Instance) IsMariaDB() bool

+ func (this *Instance) IsMasterOf(slave *Instance) bool

+ func (this *Instance) IsMaxScale() bool

+ func (this *Instance) IsSlave() bool

+ func (this *Instance) IsSlaveOf(master *Instance) bool

+ func (this *Instance) IsSmallerMajorVersion(other *Instance) bool

+ func (this *Instance) MajorVersion() []string

+ func (this *Instance) ReadSlaveHostsFromJson(jsonString string) error

+ func (this *Instance) SQLThreadUpToDate() bool

+ func (this *Instance) SlaveRunning() bool

+ func (this *Instance) StatusString() string

+ func (this *Instance) UsingGTID() bool

+ type InstanceKey struct

+ Hostname string

+ Port int

+ func NewInstanceKeyFromStrings(hostname string, port string) (*InstanceKey, error)

+ func NewRawInstanceKey(hostPort string) (*InstanceKey, error)

+ func ParseInstanceKey(hostPort string) (*InstanceKey, error)

+ func ParseInstanceKeyLoose(hostPort string) (*InstanceKey, error)

+ func ReadMaintenanceInstanceKey(maintenanceToken int64) (*InstanceKey, error)

+ func ReadOutdatedInstanceKeys() ([]InstanceKey, error)

+ func UnresolveHostname(instanceKey *InstanceKey) (InstanceKey, bool, error)

+ func (this *InstanceKey) DisplayString() string

+ func (this *InstanceKey) Equals(other *InstanceKey) bool

+ func (this *InstanceKey) Formalize() *InstanceKey

+ func (this *InstanceKey) IsValid() bool

+ type InstanceKeyMap map[InstanceKey]bool

+ func (this *InstanceKeyMap) GetInstanceKeys() []InstanceKey

+ func (this *InstanceKeyMap) MarshalJSON() ([]byte, error)

+ type InstancesByCountSlaveHosts [](*Instance)

+ func (this InstancesByCountSlaveHosts) Len() int

+ func (this InstancesByCountSlaveHosts) Less(i, j int) bool

+ func (this InstancesByCountSlaveHosts) Swap(i, j int)

+ type InstancesByExecBinlogCoordinates [](*Instance)

+ func (this InstancesByExecBinlogCoordinates) Len() int

+ func (this InstancesByExecBinlogCoordinates) Less(i, j int) bool

+ func (this InstancesByExecBinlogCoordinates) Swap(i, j int)

+ type Maintenance struct

+ BeginTimestamp string

+ IsActive bool

+ Key InstanceKey

+ MaintenanceId uint

+ Owner string

+ Reason string

+ SecondsElapsed uint

+ func ReadActiveMaintenance() ([]Maintenance, error)

+ type PoolInstancesMap map[string]([]*InstanceKey)

+ func ReadClusterPoolInstances(clusterName string) (*PoolInstancesMap, error)

+ type Process struct

+ Command string

+ Db string

+ Host string

+ Id int64

+ Info string

+ InstanceHostname string

+ InstancePort int

+ StartedAt string

+ State string

+ Time int64

+ User string

+ func ReadLongRunningProcesses(filter string) ([]Process, error)

+ type ReplicationAnalysis struct

+ Analysis AnalysisCode

+ AnalyzedInstanceKey InstanceKey

+ AnalyzedInstanceMasterKey InstanceKey

+ ClusterDetails ClusterInfo

+ CountSlaves uint

+ CountValidReplicatingSlaves uint

+ CountValidSlaves uint

+ Description string

+ DowntimeEndTimestamp string

+ DowntimeRemainingSeconds int

+ IsCoMaster bool

+ IsDowntimed bool

+ IsFailingToConnectToMaster bool

+ IsMaster bool

+ IsMaxscale bool

+ LastCheckValid bool

+ ReplicationDepth uint

+ SlaveHosts InstanceKeyMap

+ func GetReplicationAnalysis(includeDowntimed bool) ([]ReplicationAnalysis, error)

+ func (this *ReplicationAnalysis) GetSlaveHostsAsString() string

+ func (this *ReplicationAnalysis) ReadSlaveHostsFromString(slaveHostsString string) error