inst

package

Go to main page

Versions in this module

v0

v0.14.5

Mar 30, 2023 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.14.4

Nov 29, 2022 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.14.2

Sep 1, 2022 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.14.1

Jul 26, 2022 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.14.0

Jun 28, 2022 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

+ var ErrKeyspaceNotFound = errors.New("keyspace not found")

+ func GetDurabilityPolicy(instance V) (reparentutil.Durabler, error)

+ func ReadKeyspace(keyspaceName string) (*topo.KeyspaceInfo, error)

+ func SaveKeyspace(keyspace *topo.KeyspaceInfo) error

type ReplicationAnalysis

+ AnalyzedKeyspace string

v0.13.3

Sep 1, 2022 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.13.2

Jul 26, 2022 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.13.1

Apr 14, 2022 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.13.0

Feb 22, 2022 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

+ var ErrReplicationNotRunning = fmt.Errorf("Replication not running")

+ func ChooseCandidateReplica(replicas [](*Instance)) (candidateReplica *Instance, ...)

+ func IsReplicaSemiSync(primaryKey, replicaKey InstanceKey) bool

+ func MoveReplicasViaGTID(replicas []*Instance, other *Instance, ...) (movedReplicas []*Instance, unmovedReplicas []*Instance, errs []error, ...)

+ func SemiSyncAckers(instanceKey InstanceKey) int

+ func SortInstancesDataCenterHint(instances [](*Instance), dataCenterHint string)

type AnalysisCode

+ const GraceFulPrimaryTakeover

type Audit

+ AuditID int64

type Instance

+ BinlogFormat string

type InstanceKeyMap

+ func (instanceKeyMap *InstanceKeyMap) ReadJSON(jsonString string) error

type Maintenance

+ MaintenanceID uint

type Process

+ ID int64

v0.12.6

Sep 1, 2022 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.12.5

Jul 27, 2022 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.12.4

May 20, 2022 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.12.3

Jan 10, 2022 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.12.2

Dec 17, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.12.1

Dec 14, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.12.0

Oct 26, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

+ const Error1201CouldnotInitializePrimaryInfoStructure

+ const ForcePrimaryFailoverCommandHint

+ const ForcePrimaryTakeoverCommandHint

+ const GracefulPrimaryTakeoverCommandHint

+ const GroupReplicationMemberStateUnreachable

+ func GetClusterPrimaryKVKey(clusterAlias string) string

+ func GetClusterPrimaryKVPairs(clusterAlias string, primaryKey *InstanceKey) (kvPairs [](*kv.KVPair))

+ func GetPrimariesKVPairs(clusterName string) (kvPairs [](*kv.KVPair), err error)

+ func InjectUnseenPrimaries() error

+ func InstanceIsPrimaryOf(allegedPrimary, allegedReplica *Instance) bool

+ func PrimarySemiSync(instanceKey InstanceKey) int

+ func ResolveUnknownPrimaryHostnameResolves() error

+ func SetSemiSyncPrimary(instanceKey *InstanceKey, enablePrimary bool) error

+ func ShowPrimaryStatus(instanceKey *InstanceKey) (primaryStatusFound bool, executedGtidSet string, err error)

+ func SwitchPrimary(newPrimaryKey, oldPrimaryKey InstanceKey) error

+ func TakePrimaryHook(successor *Instance, demoted *Instance)

type AnalysisCode

+ const AllCoPrimaryReplicasNotReplicating

+ const AllIntermediatePrimaryReplicasFailingToConnectOrDead

+ const AllIntermediatePrimaryReplicasNotReplicating

+ const AllPrimaryReplicasNotReplicating

+ const AllPrimaryReplicasNotReplicatingOrDead

+ const BinlogServerFailingToConnectToPrimary

+ const ClusterHasNoPrimary

+ const ConnectedToWrongPrimary

+ const DeadCoPrimary

+ const DeadCoPrimaryAndSomeReplicas

+ const DeadIntermediatePrimary

+ const DeadIntermediatePrimaryAndReplicas

+ const DeadIntermediatePrimaryAndSomeReplicas

+ const DeadIntermediatePrimaryWithSingleReplica

+ const DeadIntermediatePrimaryWithSingleReplicaFailingToConnect

+ const DeadPrimary

+ const DeadPrimaryAndReplicas

+ const DeadPrimaryAndSomeReplicas

+ const DeadPrimaryWithoutReplicas

+ const FirstTierReplicaFailingToConnectToPrimary

+ const LockedSemiSyncPrimary

+ const LockedSemiSyncPrimaryHypothesis

+ const NotConnectedToPrimary

+ const PrimaryHasPrimary

+ const PrimaryIsReadOnly

+ const PrimarySemiSyncMustBeSet

+ const PrimarySemiSyncMustNotBeSet

+ const PrimarySingleReplicaDead

+ const PrimarySingleReplicaNotReplicating

+ const PrimaryWithoutReplicas

+ const UnreachableCoPrimary

+ const UnreachableIntermediatePrimary

+ const UnreachableIntermediatePrimaryWithLaggingReplicas

+ const UnreachablePrimary

+ const UnreachablePrimaryWithLaggingReplicas

type AnalysisInstanceType

+ const AnalysisInstanceTypeCoPrimary

+ const AnalysisInstanceTypeIntermediatePrimary

+ const AnalysisInstanceTypePrimary

type ClusterInfo

+ HasAutomatedIntermediatePrimaryRecovery bool

+ HasAutomatedPrimaryRecovery bool

type Instance

+ IsCoPrimary bool

+ IsDetachedPrimary bool

+ SecondsBehindPrimary sql.NullInt64

+ SemiSyncPrimaryClients uint

+ SemiSyncPrimaryEnabled bool

+ SemiSyncPrimaryStatus bool

+ SemiSyncPrimaryTimeout uint64

+ SemiSyncPrimaryWaitForReplicaCount uint

+ SourceKey InstanceKey

+ SourceUUID string

+ func ChangePrimaryTo(instanceKey *InstanceKey, primaryKey *InstanceKey, ...) (*Instance, error)

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

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

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

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

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

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

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

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

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

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

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

+ func StartReplicationUntilPrimaryCoordinates(instanceKey *InstanceKey, primaryCoordinates *BinlogCoordinates) (*Instance, error)

+ func TakePrimary(instanceKey *InstanceKey, allowTakingCoPrimary bool) (*Instance, error)

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

+ func (this *Instance) IsPrimary() bool

+ func (this *Instance) IsPrimaryOf(replica *Instance) bool

type MinimalInstance

+ PrimaryKey InstanceKey

type ReplicationAnalysis

+ AnalyzedInstancePrimaryKey InstanceKey

+ CountReplicasFailingToConnectToPrimary uint

+ IsClusterPrimary bool

+ IsCoPrimary bool

+ IsFailingToConnectToPrimary bool

+ IsPrimary bool

+ PrimaryTimeStamp time.Time

+ SemiSyncPrimaryClients uint

+ SemiSyncPrimaryEnabled bool

+ SemiSyncPrimaryStatus bool

+ SemiSyncPrimaryWaitForReplicaCount uint

type StructureAnalysisCode

+ const NoWriteablePrimaryStructureWarning

v0.11.4

Jan 10, 2022 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.11.3

Dec 17, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.11.2

Dec 14, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.11.1

Sep 9, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.11.0

Jul 27, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.10.5

Jan 10, 2022 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.10.4

Dec 17, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.10.3

Dec 14, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.10.2

May 27, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.10.1

May 4, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.10.0

Apr 27, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.9.2

May 25, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.9.1

May 6, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.9.0

Jan 25, 2021 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

v0.8.0

Oct 27, 2020 GO-2023-1717 +2 more

GO-2023-1717: Improper handling of keyspaces in vitess.io/vitess

GO-2024-2826: Denial of service attack by triggering unbounded memory usage in vitess.io/vitess

GO-2024-3306: Vitess allows HTML injection in /debug/querylogz and /debug/env in vitess.io/vitess

Changes in this version

+ const Error1201CouldnotInitializeMasterInfoStructure

+ const ForceMasterFailoverCommandHint

+ const ForceMasterTakeoverCommandHint

+ const GracefulMasterTakeoverCommandHint

+ const GroupReplicationMemberRolePrimary

+ const GroupReplicationMemberRoleSecondary

+ const GroupReplicationMemberStateError

+ const GroupReplicationMemberStateOffline

+ const GroupReplicationMemberStateOnline

+ const GroupReplicationMemberStateRecovering

+ const ReasonableDiscoveryLatency

+ var DowntimeLostInRecoveryMessage = "lost-in-recovery"

+ var ErrTabletAliasNil = errors.New("tablet alias is nil")

+ var GroupReplicationNotSupportedErrors = map[uint16]bool

+ var ReplicationNotRunningError = fmt.Errorf("Replication not running")

+ var TagEqualsRegexp = regexp.MustCompile("^([^=]+)=(.*)$")

+ var TopoServ *topo.Server

+ func ASCIITopology(clusterName string, historyTimestampPattern string, tabulated bool, ...) (result string, err error)

+ func ApplyPoolInstances(submission *PoolInstancesSubmission) error

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

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

+ func BeginDowntime(downtime *Downtime) (err error)

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

+ func ChangeTabletType(instanceKey InstanceKey, tabletType topodatapb.TabletType) (*topodatapb.Tablet, error)

+ func CheckAndInjectPseudoGTIDOnWriter(instance *Instance) (injected bool, err error)

+ func CheckMoveViaGTID(instance, otherInstance *Instance) (err error)

+ func DeduceClusterName(nameOrAlias string) (clusterName string, err error)

+ func DeleteHostnameUnresolve(instanceKey *InstanceKey) error

+ func DeleteInvalidHostnameResolves() error

+ func EmptyCommitInstance(instanceKey *InstanceKey) error

+ func EnableAuditSyslog() (err error)

+ func EndDowntime(instanceKey *InstanceKey) (wasDowntimed bool, err error)

+ func EndMaintenance(maintenanceToken int64) (wasMaintenance bool, err error)

+ func EndMaintenanceByInstanceKey(instanceKey *InstanceKey) (wasMaintenance bool, err error)

+ func ErrantGTIDInjectEmpty(instanceKey *InstanceKey) (instance *Instance, clusterMaster *Instance, countInjectedTransactions int64, ...)

+ func ExecDBWriteFunc(f func() error) error

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

+ func ExecuteOnTopology(f func())

+ func ExpireAudit() error

+ func ExpireCandidateInstances() error

+ func ExpireClusterDomainName() error

+ func ExpireDowntime() error

+ func ExpireHostnameUnresolve() error

+ func ExpireInjectedPseudoGTID() error

+ func ExpireInstanceAnalysisChangelog() error

+ func ExpireMaintenance() error

+ func ExpireMasterPositionEquivalence() error

+ func ExpirePoolInstances() error

+ func ExpireStaleInstanceBinlogCoordinates() error

+ func ExpireTableData(tableName string, timestampColumn string) error

+ func FigureClusterName(clusterHint string, instanceKey *InstanceKey, thisInstanceKey *InstanceKey) (clusterName string, err error)

+ func FlushNontrivialResolveCacheToDatabase() error

+ func ForgetCluster(clusterName string) error

+ func ForgetExpiredHostnameResolves() error

+ func ForgetInstance(instanceKey *InstanceKey) error

+ func ForgetLongUnseenInstances() error

+ func ForgetUnseenInstancesDifferentlyResolved() error

+ func GTIDSubtract(instanceKey *InstanceKey, gtidSet string, gtidSubset string) (gtidSubtract string, err error)

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

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

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

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

+ func GetClusterMasterKVKey(clusterAlias string) string

+ func GetClusterMasterKVPairs(clusterAlias string, masterKey *InstanceKey) (kvPairs [](*kv.KVPair))

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

+ 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 GetMaintenanceOwner() string

+ func GetMastersKVPairs(clusterName string) (kvPairs [](*kv.KVPair), err error)

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

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

+ func HostnameResolveMethodIsNone() bool

+ func InMaintenance(instanceKey *InstanceKey) (inMaintenance bool, err error)

+ func InjectSeed(instanceKey *InstanceKey) error

+ func InjectUnseenMasters() error

+ func InstanceIsForgotten(instanceKey *InstanceKey) bool

+ func InstanceIsMasterOf(allegedMaster, allegedReplica *Instance) bool

+ func InstanceTagExists(instanceKey *InstanceKey, tag *Tag) (tagExists bool, err error)

+ func InstancesAreSiblings(instance0, instance1 *Instance) bool

+ func IsBannedFromBeingCandidateReplica(replica *Instance) bool

+ func IsSmallerBinlogFormat(binlogFormat string, otherBinlogFormat string) bool

+ func IsSmallerMajorVersion(version string, otherVersion string) bool

+ func LoadHostnameResolveCache() error

+ func LocateErrantGTID(instanceKey *InstanceKey) (errantBinlogs []string, err error)

+ func MajorVersion(version string) []string

+ func MasterSemiSync(instanceKey InstanceKey) int

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

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

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

+ func MoveReplicasGTID(masterKey *InstanceKey, belowKey *InstanceKey, pattern string) (movedReplicas [](*Instance), unmovedReplicas [](*Instance), err error, ...)

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

+ func MultiMatchBelow(replicas [](*Instance), belowKey *InstanceKey, ...) (matchedReplicas [](*Instance), belowInstance *Instance, err error, ...)

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

+ func NewBinlogFormatSortedByCount(formatsCount map[string]int) *binlogFormatSortedByCount

+ func NewMajorVersionsSortedByCount(versionsCount map[string]int) *majorVersionsSortedByCount

+ func PopulateGroupReplicationInformation(instance *Instance, db *sql.DB) error

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

+ func PutInstanceTag(instanceKey *InstanceKey, tag *Tag) (err error)

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

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

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

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

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

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

+ func ReadInstanceTag(instanceKey *InstanceKey, tag *Tag) (tagExists bool, err error)

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

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

+ func ReadTablet(instanceKey InstanceKey) (*topodatapb.Tablet, error)

+ func ReadUnambiguousSuggestedClusterAliases() (result map[string]InstanceKey, err error)

+ func RecordInstanceCoordinatesHistory() error

+ func RecordStaleInstanceBinlogCoordinates(instanceKey *InstanceKey, binlogCoordinates *BinlogCoordinates) error

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

+ func RegexpMatchPatterns(s string, regexpPatterns []string) bool

+ func RegisterCandidateInstance(candidate *CandidateDatabaseInstance) error

+ func RegisterHostnameUnresolve(registration *HostnameRegistration) (err error)

+ func RegisterInjectedPseudoGTID(clusterName string) error

+ func RegroupReplicas(masterKey *InstanceKey, returnReplicaEvenOnFailureToRegroup bool, ...) (aheadReplicas [](*Instance), equalReplicas [](*Instance), ...)

+ func RegroupReplicasBinlogServers(masterKey *InstanceKey, returnReplicaEvenOnFailureToRegroup bool) (repointedBinlogServers [](*Instance), promotedBinlogServer *Instance, ...)

+ func RegroupReplicasGTID(masterKey *InstanceKey, returnReplicaEvenOnFailureToRegroup bool, ...) (lostReplicas [](*Instance), movedReplicas [](*Instance), ...)

+ func RegroupReplicasPseudoGTID(masterKey *InstanceKey, returnReplicaEvenOnFailureToRegroup bool, ...) (aheadReplicas [](*Instance), equalReplicas [](*Instance), ...)

+ func RegroupReplicasPseudoGTIDIncludingSubReplicasOfBinlogServers(masterKey *InstanceKey, returnReplicaEvenOnFailureToRegroup bool, ...) (aheadReplicas [](*Instance), equalReplicas [](*Instance), ...)

+ func RelocateReplicas(instanceKey, otherKey *InstanceKey, pattern string) (replicas [](*Instance), other *Instance, err error, errs []error)

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

+ func ReplaceAliasClusterName(oldClusterName string, newClusterName string) (err error)

+ func ReplaceClusterName(oldClusterName string, newClusterName string) error

+ func ReplicaSemiSync(masterKey, replicaKey InstanceKey) bool

+ func ReplicaSemiSyncFromTablet(master, replica *topodatapb.Tablet) bool

+ func ResetHostnameResolveCache() error

+ func ResetInstanceRelaylogCoordinatesHistory(instanceKey *InstanceKey) error

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

+ func ResolveHostnameIPs(hostname string) error

+ func ResolveUnknownMasterHostnameResolves() error

+ func RestartReplicationQuick(instanceKey *InstanceKey) error

+ func ReviewUnseenInstances() error

+ func SaveTablet(tablet *topodatapb.Tablet) error

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

+ func SemicolonTerminated(statement string) string

+ func SetClusterAlias(clusterName string, alias string) error

+ func SetClusterAliasManualOverride(clusterName string, alias string) error

+ func SetDurabilityPolicy(name string) error

+ func SetMaintenanceOwner(owner string)

+ func SetSemiSyncMaster(instanceKey *InstanceKey, enableMaster bool) error

+ func SetSemiSyncReplica(instanceKey *InstanceKey, enableReplica bool) error

+ func ShowBinaryLogs(instanceKey *InstanceKey) (binlogs []string, err error)

+ func ShowMasterStatus(instanceKey *InstanceKey) (masterStatusFound bool, executedGtidSet string, err error)

+ func SnapshotTopologies() error

+ func StartReplicas(replicas [](*Instance))

+ func SwitchMaster(newMasterKey, oldMasterKey InstanceKey) error

+ func TakeMasterHook(successor *Instance, demoted *Instance)

+ func UpdateClusterAliases() error

+ func UpdateInstanceLastAttemptedCheck(instanceKey *InstanceKey) error

+ func UpdateInstanceLastChecked(instanceKey *InstanceKey, partialSuccess bool) error

+ func UpdateResolvedHostname(hostname string, resolvedHostname string) bool

+ func ValidSecondsFromSeenToLastAttemptedCheck() uint

+ func WriteClusterDomainName(clusterName string, domainName string) error

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

+ func WriteInstance(instance *Instance, instanceWasActuallyFound bool, lastError error) error

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

+ func WriteResolvedHostname(hostname string, resolvedHostname string) error

+ type AggregatedWriteBufferMetric struct

+ CountInstances int

+ InstanceFlushIntervalMilliseconds int

+ InstanceWriteBufferSize int

+ MaxInstances float64

+ MaxWaitSeconds float64

+ MaxWriteSeconds float64

+ MeanInstances float64

+ MeanWaitSeconds float64

+ MeanWriteSeconds float64

+ MedianInstances float64

+ MedianWaitSeconds float64

+ MedianWriteSeconds float64

+ P95Instances float64

+ P95WaitSeconds float64

+ P95WriteSeconds float64

+ func AggregatedSince(c *collection.Collection, t time.Time) AggregatedWriteBufferMetric

+ type AnalysisCode string

+ const AllCoMasterReplicasNotReplicating

+ const AllIntermediateMasterReplicasFailingToConnectOrDead

+ const AllIntermediateMasterReplicasNotReplicating

+ const AllMasterReplicasNotReplicating

+ const AllMasterReplicasNotReplicatingOrDead

+ const BinlogServerFailingToConnectToMaster

+ const ClusterHasNoMaster

+ const ConnectedToWrongMaster

+ const DeadCoMaster

+ const DeadCoMasterAndSomeReplicas

+ const DeadIntermediateMaster

+ const DeadIntermediateMasterAndReplicas

+ const DeadIntermediateMasterAndSomeReplicas

+ const DeadIntermediateMasterWithSingleReplica

+ const DeadIntermediateMasterWithSingleReplicaFailingToConnect

+ const DeadMaster

+ const DeadMasterAndReplicas

+ const DeadMasterAndSomeReplicas

+ const DeadMasterWithoutReplicas

+ const FirstTierReplicaFailingToConnectToMaster

+ const LockedSemiSyncMaster

+ const LockedSemiSyncMasterHypothesis

+ const MasterHasMaster

+ const MasterIsReadOnly

+ const MasterSemiSyncMustBeSet

+ const MasterSemiSyncMustNotBeSet

+ const MasterSingleReplicaDead

+ const MasterSingleReplicaNotReplicating

+ const MasterWithoutReplicas

+ const NoProblem

+ const NotConnectedToMaster

+ const ReplicaIsWritable

+ const ReplicaSemiSyncMustBeSet

+ const ReplicaSemiSyncMustNotBeSet

+ const ReplicationStopped

+ const UnreachableCoMaster

+ const UnreachableIntermediateMaster

+ const UnreachableIntermediateMasterWithLaggingReplicas

+ const UnreachableMaster

+ const UnreachableMasterWithLaggingReplicas

+ type AnalysisInstanceType string

+ const AnalysisInstanceTypeCoMaster

+ const AnalysisInstanceTypeIntermediateMaster

+ const AnalysisInstanceTypeMaster

+ type AnalysisMap map[string](*ReplicationAnalysis)

+ type Audit struct

+ AuditId int64

+ AuditInstanceKey InstanceKey

+ AuditTimestamp string

+ AuditType string

+ Message string

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

+ type BinlogCoordinates struct

+ LogFile string

+ LogPos int64

+ Type BinlogType

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

+ func CorrelateRelaylogCoordinates(instance *Instance, relaylogCoordinates *BinlogCoordinates, ...) (instanceCoordinates, correlatedCoordinates, nextCoordinates *BinlogCoordinates, ...)

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

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

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

+ func GetPreviousKnownRelayLogCoordinatesForInstance(instance *Instance) (relayLogCoordinates *BinlogCoordinates, err error)

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

+ func SearchEntryInBinlog(pseudoGTIDRegexp *regexp.Regexp, instanceKey *InstanceKey, binlog string, ...) (BinlogCoordinates, bool, error)

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

+ func SearchEventInRelayLogs(searchEvent *BinlogEvent, instance *Instance, ...) (binlogCoordinates, nextCoordinates *BinlogCoordinates, found bool, err error)

+ func (this *BinlogCoordinates) Detach() (detachedCoordinates BinlogCoordinates)

+ func (this *BinlogCoordinates) DisplayString() string

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

+ func (this *BinlogCoordinates) ExtractDetachedCoordinates() (isDetached bool, detachedCoordinates BinlogCoordinates)

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

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

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

+ func (this *BinlogCoordinates) IsEmpty() bool

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

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

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

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

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

+ func (this BinlogCoordinates) String() string

+ type BinlogEvent struct

+ Coordinates BinlogCoordinates

+ EventType string

+ Info string

+ NextEventPos int64

+ func GetLastExecutedEntryInRelayLogs(instance *Instance, minBinlogCoordinates *BinlogCoordinates, ...) (binlogEvent *BinlogEvent, err error)

+ func ReadBinlogEventAtRelayLogCoordinates(instanceKey *InstanceKey, relaylogCoordinates *BinlogCoordinates) (binlogEvent *BinlogEvent, err error)

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

+ func (this *BinlogEvent) EqualsIgnoreCoordinates(other *BinlogEvent) bool

+ 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 CandidateDatabaseInstance struct

+ Hostname string

+ LastSuggestedString string

+ Port int

+ PromotionRule CandidatePromotionRule

+ PromotionRuleExpiry string

+ func BulkReadCandidateDatabaseInstance() ([]CandidateDatabaseInstance, error)

+ func NewCandidateDatabaseInstance(instanceKey *InstanceKey, promotionRule CandidatePromotionRule) *CandidateDatabaseInstance

+ func (cdi *CandidateDatabaseInstance) Key() *InstanceKey

+ func (cdi *CandidateDatabaseInstance) String() string

+ func (cdi *CandidateDatabaseInstance) WithCurrentTime() *CandidateDatabaseInstance

+ type CandidatePromotionRule string

+ const MustNotPromoteRule

+ const MustPromoteRule

+ const NeutralPromoteRule

+ const PreferNotPromoteRule

+ const PreferPromoteRule

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

+ func PromotionRule(tablet *topodatapb.Tablet) CandidatePromotionRule

+ func (this *CandidatePromotionRule) BetterThan(other CandidatePromotionRule) bool

+ type ClusterInfo struct

+ ClusterAlias string

+ ClusterDomain string

+ ClusterName string

+ CountInstances uint

+ HasAutomatedIntermediateMasterRecovery bool

+ HasAutomatedMasterRecovery bool

+ HeuristicLag int64

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

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

+ func (this *ClusterInfo) ApplyClusterAlias()

+ func (this *ClusterInfo) ReadRecoveryInfo()

+ type ClusterPoolInstance struct

+ ClusterAlias string

+ ClusterName string

+ Hostname string

+ Pool string

+ Port int

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

+ func ReadClusterPoolInstances(clusterName string, pool string) (result [](*ClusterPoolInstance), err error)

+ type Downtime struct

+ BeginsAt time.Time

+ BeginsAtString string

+ Duration time.Duration

+ EndsAt time.Time

+ EndsAtString string

+ Key *InstanceKey

+ Owner string

+ Reason string

+ func NewDowntime(instanceKey *InstanceKey, owner string, reason string, duration time.Duration) *Downtime

+ func ReadDowntime() (result []Downtime, err error)

+ func (downtime *Downtime) Ended() bool

+ func (downtime *Downtime) EndsIn() time.Duration

+ type HostnameRegistration struct

+ CreatedAt time.Time

+ Hostname string

+ Key InstanceKey

+ func NewHostnameDeregistration(instanceKey *InstanceKey) *HostnameRegistration

+ func NewHostnameRegistration(instanceKey *InstanceKey, hostname string) *HostnameRegistration

+ func ReadAllHostnameUnresolvesRegistrations() (registrations []HostnameRegistration, err error)

+ type HostnameResolve struct

+ func ReadAllHostnameResolves() ([]HostnameResolve, error)

+ func (this HostnameResolve) String() string

+ type HostnameUnresolve struct

+ func ReadAllHostnameUnresolves() ([]HostnameUnresolve, error)

+ func (this HostnameUnresolve) String() string

+ type Instance struct

+ AllowTLS bool

+ AncestryUUID string

+ BinlogRowImage string

+ Binlog_format string

+ ClusterName string

+ CountMySQLSnapshots int

+ DataCenter string

+ DowntimeEndTimestamp string

+ DowntimeOwner string

+ DowntimeReason string

+ ElapsedDowntime time.Duration

+ ExecBinlogCoordinates BinlogCoordinates

+ ExecutedGtidSet string

+ FlavorName string

+ GTIDMode string

+ GtidErrant string

+ GtidPurged string

+ HasReplicationCredentials bool

+ HasReplicationFilters bool

+ InstanceAlias string

+ IsCandidate bool

+ IsCoMaster bool

+ IsDetached bool

+ IsDetachedMaster bool

+ IsDowntimed bool

+ IsLastCheckValid bool

+ IsRecentlyChecked bool

+ IsUpToDate bool

+ Key InstanceKey

+ LastDiscoveryLatency time.Duration

+ LastIOError string

+ LastSQLError string

+ LastSeenTimestamp string

+ LogBinEnabled bool

+ LogReplicationUpdatesEnabled bool

+ LogSlaveUpdatesEnabled bool

+ MasterKey InstanceKey

+ MasterUUID string

+ PhysicalEnvironment string

+ Problems []string

+ PromotionRule CandidatePromotionRule

+ ReadBinlogCoordinates BinlogCoordinates

+ ReadOnly bool

+ Region string

+ RelaylogCoordinates BinlogCoordinates

+ Replicas InstanceKeyMap

+ ReplicationCredentialsAvailable bool

+ ReplicationDepth uint

+ ReplicationGroupIsSinglePrimary bool

+ ReplicationGroupMemberRole string

+ ReplicationGroupMemberState string

+ ReplicationGroupMembers InstanceKeyMap

+ ReplicationGroupName string

+ ReplicationGroupPrimaryInstanceKey InstanceKey

+ ReplicationIOThreadRuning bool

+ ReplicationIOThreadState ReplicationThreadState

+ ReplicationLagSeconds sql.NullInt64

+ ReplicationSQLThreadRuning bool

+ ReplicationSQLThreadState ReplicationThreadState

+ SQLDelay uint

+ SecondsBehindMaster sql.NullInt64

+ SecondsSinceLastSeen sql.NullInt64

+ SelfBinlogCoordinates BinlogCoordinates

+ SemiSyncAvailable bool

+ SemiSyncEnforced bool

+ SemiSyncMasterClients uint

+ SemiSyncMasterEnabled bool

+ SemiSyncMasterStatus bool

+ SemiSyncMasterTimeout uint64

+ SemiSyncMasterWaitForReplicaCount uint

+ SemiSyncReplicaEnabled bool

+ SemiSyncReplicaStatus bool

+ ServerID uint

+ ServerUUID string

+ SlaveHosts InstanceKeyMap

+ SlaveLagSeconds sql.NullInt64

+ Slave_IO_Running bool

+ Slave_SQL_Running bool

+ SuggestedClusterAlias string

+ SupportsOracleGTID bool

+ UnresolvedHostname string

+ Uptime uint

+ UsingMariaDBGTID bool

+ UsingOracleGTID bool

+ UsingPseudoGTID bool

+ Version string

+ VersionComment string

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

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

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

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

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

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

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

+ func FlushBinaryLogs(instanceKey *InstanceKey, count int) (*Instance, error)

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

+ func GetCandidateReplicaOfBinlogServerTopology(masterKey *InstanceKey) (candidateReplica *Instance, err error)

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

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

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

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

+ func GetSortedReplicas(masterKey *InstanceKey, stopReplicationMethod StopReplicationMethod) (replicas [](*Instance), err 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 MoveBelowGTID(instanceKey, otherKey *InstanceKey) (*Instance, error)

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

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

+ func NewInstance() *Instance

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

+ func PurgeBinaryLogsToLatest(instanceKey *InstanceKey, force bool) (*Instance, error)

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

+ func ReadClusterAliasInstances(clusterAlias string) ([](*Instance), error)

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

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

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

+ func ReadClusterNeutralPromotionRuleInstances(clusterName string) (neutralInstances [](*Instance), err error)

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

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

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

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

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

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

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

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

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

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

+ func ReadTopologyInstanceBufferable(instanceKey *InstanceKey, bufferWrites bool, latency *stopwatch.NamedStopwatch) (inst *Instance, err error)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func RetryInstanceFunction(f func() (*Instance, error)) (instance *Instance, err error)

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

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

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

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

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

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

+ func StopReplicas(replicas [](*Instance), stopReplicationMethod StopReplicationMethod, ...) [](*Instance)

+ func StopReplicasNicely(replicas [](*Instance), timeout time.Duration) [](*Instance)

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

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

+ func TakeMaster(instanceKey *InstanceKey, allowTakingCoMaster bool) (*Instance, error)

+ func TakeSiblings(instanceKey *InstanceKey) (instance *Instance, takenSiblings int, err error)

+ func WaitForExecBinlogCoordinatesToReach(instanceKey *InstanceKey, coordinates *BinlogCoordinates, ...) (instance *Instance, exactMatch bool, err error)

+ func WaitForSQLThreadUpToDate(instanceKey *InstanceKey, overallTimeout time.Duration, ...) (instance *Instance, err error)

+ func (this *Instance) AddGroupMemberKey(groupMemberKey *InstanceKey)

+ func (this *Instance) AddReplicaKey(replicaKey *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) FlavorNameAndMajorVersion() string

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

+ func (this *Instance) HasReasonableMaintenanceReplicationLag() bool

+ func (this *Instance) HumanReadableDescription() string

+ func (this *Instance) IsBinlogServer() bool

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

+ func (this *Instance) IsMariaDB() bool

+ func (this *Instance) IsMaster() bool

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

+ func (this *Instance) IsMySQL51() bool

+ func (this *Instance) IsMySQL55() bool

+ func (this *Instance) IsMySQL56() bool

+ func (this *Instance) IsMySQL57() bool

+ func (this *Instance) IsMySQL80() bool

+ func (this *Instance) IsNDB() bool

+ func (this *Instance) IsOracleMySQL() bool

+ func (this *Instance) IsPercona() bool

+ func (this *Instance) IsReplica() bool

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

+ func (this *Instance) IsReplicationGroupMember() bool

+ func (this *Instance) IsReplicationGroupPrimary() bool

+ func (this *Instance) IsReplicationGroupSecondary() bool

+ func (this *Instance) IsSeed() bool

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

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

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

+ func (this *Instance) LagStatusString() string

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

+ func (this *Instance) MajorVersionString() string

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

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

+ func (this *Instance) ReplicaRunning() bool

+ func (this *Instance) ReplicationThreadsExist() bool

+ func (this *Instance) ReplicationThreadsStopped() bool

+ func (this *Instance) SQLThreadUpToDate() bool

+ func (this *Instance) SetSeed()

+ func (this *Instance) StatusString() string

+ func (this *Instance) TabulatedDescription(separator string) string

+ func (this *Instance) UsingGTID() bool

+ type InstanceAnalysis struct

+ func NewInstanceAnalysis(instanceKey *InstanceKey, analysis AnalysisCode) *InstanceAnalysis

+ func (instanceAnalysis *InstanceAnalysis) String() string

+ type InstanceBinlogCoordinates struct

+ Coordinates BinlogCoordinates

+ Key InstanceKey

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

+ type InstanceKey struct

+ Hostname string

+ Port int

+ func BulkReadInstance() ([](*InstanceKey), error)

+ func FigureInstanceKey(instanceKey *InstanceKey, thisInstanceKey *InstanceKey) (*InstanceKey, error)

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

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

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

+ func NewResolveInstanceKey(hostname string, port int) (instanceKey *InstanceKey, err error)

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

+ func ParseRawInstanceKey(hostPort string) (instanceKey *InstanceKey, err error)

+ func ParseResolveInstanceKey(hostPort string) (instanceKey *InstanceKey, err error)

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

+ func ReadFuzzyInstanceKey(fuzzyInstanceKey *InstanceKey) *InstanceKey

+ func ReadFuzzyInstanceKeyIfPossible(fuzzyInstanceKey *InstanceKey) *InstanceKey

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

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

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

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

+ func (this *InstanceKey) DisplayString() string

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

+ func (this *InstanceKey) IsDetached() bool

+ func (this *InstanceKey) IsIPv4() bool

+ func (this *InstanceKey) IsValid() bool

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

+ func (this *InstanceKey) ResolveHostname() (*InstanceKey, error)

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

+ func (this *InstanceKey) StringCode() string

+ func (this InstanceKey) String() string

+ type InstanceKeyMap map[InstanceKey]bool

+ func GetInstanceKeysByTag(tag *Tag) (tagged *InstanceKeyMap, err error)

+ func GetInstanceKeysByTags(tagsString string) (tagged *InstanceKeyMap, err error)

+ func NewInstanceKeyMap() *InstanceKeyMap

+ func Untag(instanceKey *InstanceKey, tag *Tag) (tagged *InstanceKeyMap, err error)

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

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

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

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

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

+ func (this *InstanceKeyMap) Intersect(other *InstanceKeyMap) *InstanceKeyMap

+ 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

+ func (this *InstanceKeyMap) UnmarshalJSON(b []byte) error

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

+ type InstanceTag struct

+ Key InstanceKey

+ T Tag

+ type InstancesByCountReplicas [](*Instance)

+ func (this InstancesByCountReplicas) Len() int

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

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

+ type InstancesSorterByExec struct

+ func NewInstancesSorterByExec(instances [](*Instance), dataCenter string) *InstancesSorterByExec

+ func (this *InstancesSorterByExec) Len() int

+ func (this *InstancesSorterByExec) Less(i, j int) bool

+ func (this *InstancesSorterByExec) 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 MinimalInstance struct

+ ClusterName string

+ Key InstanceKey

+ MasterKey InstanceKey

+ func ReadAllMinimalInstances() ([]MinimalInstance, error)

+ func (this *MinimalInstance) ToInstance() *Instance

+ type OperationGTIDHint string

+ const GTIDHintDeny

+ const GTIDHintForce

+ const GTIDHintNeutral

+ type OracleGtidSet struct

+ GtidEntries [](*OracleGtidSetEntry)

+ func GetPreviousGTIDs(instanceKey *InstanceKey, binlog string) (previousGTIDs *OracleGtidSet, err error)

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

+ func (this *OracleGtidSet) Explode() (result [](*OracleGtidSetEntry))

+ func (this *OracleGtidSet) IsEmpty() bool

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

+ func (this *OracleGtidSet) RetainUUID(uuid string) (anythingRemoved bool)

+ func (this *OracleGtidSet) RetainUUIDs(uuids []string) (anythingRemoved bool)

+ func (this *OracleGtidSet) SharedUUIDs(other *OracleGtidSet) (shared []string)

+ func (this *OracleGtidSet) String() string

+ type OracleGtidSetEntry struct

+ Ranges string

+ UUID string

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

+ func (this *OracleGtidSetEntry) Explode() (result [](*OracleGtidSetEntry))

+ func (this *OracleGtidSetEntry) String() string

+ type PeerAnalysisMap map[string]int

+ func ReadPeerAnalysisMap() (peerAnalysisMap PeerAnalysisMap, err error)

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

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

+ type PoolInstancesSubmission struct

+ CreatedAt time.Time

+ DelimitedInstances string

+ Pool string

+ RegisteredAt string

+ func NewPoolInstancesSubmission(pool string, instances string) *PoolInstancesSubmission

+ func ReadAllPoolInstancesSubmissions() ([]PoolInstancesSubmission, error)

+ type PostponedFunctionsContainer struct

+ func NewPostponedFunctionsContainer() *PostponedFunctionsContainer

+ func (this *PostponedFunctionsContainer) AddPostponedFunction(postponedFunction func() error, description string)

+ func (this *PostponedFunctionsContainer) Descriptions() []string

+ func (this *PostponedFunctionsContainer) Len() int

+ func (this *PostponedFunctionsContainer) Wait()

+ 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

+ type ReplicationAnalysis struct

+ Analysis AnalysisCode

+ AnalyzedInstanceBinlogCoordinates BinlogCoordinates

+ AnalyzedInstanceDataCenter string

+ AnalyzedInstanceKey InstanceKey

+ AnalyzedInstanceMasterKey InstanceKey

+ AnalyzedInstancePhysicalEnvironment string

+ AnalyzedInstanceRegion string

+ BinlogServerImmediateTopology bool

+ ClusterDetails ClusterInfo

+ CommandHint string

+ CountAdditionalAgreeingNodes int

+ CountDelayedReplicas uint

+ CountDistinctMajorVersionsLoggingReplicas uint

+ CountDowntimedReplicas uint

+ CountLaggingReplicas uint

+ CountLoggingReplicas uint

+ CountMixedBasedLoggingReplicas uint

+ CountReplicas uint

+ CountReplicasFailingToConnectToMaster uint

+ CountRowBasedLoggingReplicas uint

+ CountSemiSyncReplicasEnabled uint

+ CountStatementBasedLoggingReplicas uint

+ CountValidReplicas uint

+ CountValidReplicatingReplicas uint

+ Description string

+ DowntimeEndTimestamp string

+ DowntimeRemainingSeconds int

+ GTIDMode string

+ IsActionableRecovery bool

+ IsBinlogServer bool

+ IsClusterMaster bool

+ IsCoMaster bool

+ IsDowntimed bool

+ IsFailingToConnectToMaster bool

+ IsMaster bool

+ IsReadOnly bool

+ IsReplicasDowntimed bool

+ LastCheckPartialSuccess bool

+ LastCheckValid bool

+ MariaDBGTIDImmediateTopology bool

+ MasterTimeStamp time.Time

+ MaxReplicaGTIDErrant string

+ MaxReplicaGTIDMode string

+ MinReplicaGTIDMode string

+ OracleGTIDImmediateTopology bool

+ ProcessingNodeHostname string

+ ProcessingNodeToken string

+ PseudoGTIDImmediateTopology bool

+ Replicas InstanceKeyMap

+ ReplicationDepth uint

+ ReplicationStopped bool

+ SemiSyncMasterClients uint

+ SemiSyncMasterEnabled bool

+ SemiSyncMasterStatus bool

+ SemiSyncMasterWaitForReplicaCount uint

+ SemiSyncReplicaEnabled bool

+ SkippableDueToDowntime bool

+ SlaveHosts InstanceKeyMap

+ StartActivePeriod string

+ StructureAnalysis []StructureAnalysisCode

+ SuggestedClusterAlias string

+ TabletType topodatapb.TabletType

+ func GetReplicationAnalysis(clusterName string, hints *ReplicationAnalysisHints) ([]ReplicationAnalysis, error)

+ func (this *ReplicationAnalysis) AnalysisString() string

+ func (this *ReplicationAnalysis) GetAnalysisInstanceType() AnalysisInstanceType

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

+ func (this *ReplicationAnalysis) ReadReplicaHostsFromString(replicaHostsString string) error

+ type ReplicationAnalysisChangelog struct

+ AnalyzedInstanceKey InstanceKey

+ Changelog []string

+ func ReadReplicationAnalysisChangelog() (res [](*ReplicationAnalysisChangelog), err error)

+ type ReplicationAnalysisHints struct

+ AuditAnalysis bool

+ IncludeDowntimed bool

+ IncludeNoProblem bool

+ type ReplicationThreadState int

+ const ReplicationThreadStateNoThread

+ const ReplicationThreadStateOther

+ const ReplicationThreadStateRunning

+ const ReplicationThreadStateStopped

+ func ReplicationThreadStateFromStatus(status string) ReplicationThreadState

+ func (this *ReplicationThreadState) Exists() bool

+ func (this *ReplicationThreadState) IsRunning() bool

+ func (this *ReplicationThreadState) IsStopped() bool

+ type StopReplicationMethod string

+ const NoStopReplication

+ const StopReplicationNice

+ const StopReplicationNormal

+ type StructureAnalysisCode string

+ const DifferentGTIDModesStructureWarning

+ const ErrantGTIDStructureWarning

+ const MixedAndRowLoggingReplicasStructureWarning

+ const MultipleMajorVersionsLoggingReplicasStructureWarning

+ const NoFailoverSupportStructureWarning

+ const NoLoggingReplicasStructureWarning

+ const NoWriteableMasterStructureWarning

+ const NotEnoughValidSemiSyncReplicasStructureWarning

+ const StatementAndMixedLoggingReplicasStructureWarning

+ const StatementAndRowLoggingReplicasStructureWarning

+ type Tag struct

+ HasValue bool

+ Negate bool

+ TagName string

+ TagValue string

+ func NewTag(tagName string, tagValue string) (*Tag, error)

+ func ParseIntersectTags(tagsString string) (tags [](*Tag), err error)

+ func ParseTag(tagString string) (*Tag, error)

+ func ReadInstanceTags(instanceKey *InstanceKey) (tags [](*Tag), err error)

+ func (tag *Tag) Display() string

+ func (tag *Tag) String() string

+ type WriteBufferMetric struct

+ Instances int

+ Timestamp time.Time

+ WaitLatency time.Duration

+ WriteLatency time.Duration

+ func (m WriteBufferMetric) When() time.Time

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