logic

Documentation

Index

• Constants
• Variables
• func AttemptFailureDetectionRegistration(analysisEntry *inst.ReplicationAnalysis) (bool, error)
• func AttemptRecoveryRegistration(analysisEntry *inst.ReplicationAnalysis) (bool, error)
• func CheckAndRecover(specificInstance *inst.InstanceKey, candidateInstanceKey *inst.InstanceKey, ...) (actionTaken bool, instance *inst.Instance, err error)
• func ClearActiveFailureDetections() error
• func ClearActiveRecoveries() error
• func ContinuousAgentsPoll()
• func ContinuousDiscovery()
• func ElectedNode() (hostname string, token string, isElected bool, err error)
• func GetCandidateSiblingOfIntermediateMaster(intermediateMasterInstance *inst.Instance) (*inst.Instance, error)
• func GetHash(input []byte) string
• func GetRandomData() []byte
• func GrabElection() error
• func RecoverDeadIntermediateMaster(analysisEntry inst.ReplicationAnalysis, skipProcesses bool) (recoveryResolved bool, successorInstance *inst.Instance, err error)
• func RecoverDeadMaster(analysisEntry inst.ReplicationAnalysis, skipProcesses bool) (promotedSlave *inst.Instance, lostSlaves [](*inst.Instance), err error)
• func Reelect() error
• func ResolveRecovery(failedKey *inst.InstanceKey, successorInstance *inst.Instance) error
• func StartDiscovery(instanceKey inst.InstanceKey)
• type HealthStatus
  • func HealthTest() (*HealthStatus, error)
  • func SimpleHealthTest() (*HealthStatus, error)
• type InstancesByCountSlaves
  • func (this InstancesByCountSlaves) Len() int
  • func (this InstancesByCountSlaves) Less(i, j int) bool
  • func (this InstancesByCountSlaves) Swap(i, j int)
• type MasterRecoveryType
• type Token
  • func NewToken() *Token
• type TopologyRecovery
  • func ReadActiveClusterRecovery(clusterName string) ([]TopologyRecovery, error)
  • func ReadActiveRecoveries() ([]TopologyRecovery, error)
  • func ReadCompletedRecoveries(page int) ([]TopologyRecovery, error)
  • func ReadRecentFailureDetections(page int) ([]TopologyRecovery, error)
  • func ReadRecentRecoveries(clusterName string, page int) ([]TopologyRecovery, error)
  • func ReadRecentlyActiveClusterRecovery(clusterName string) ([]TopologyRecovery, error)
  • func ReadRecentlyActiveInstanceRecovery(instanceKey *inst.InstanceKey) ([]TopologyRecovery, error)

Constants

const (
	MasterRecoveryGTID         MasterRecoveryType = "MasterRecoveryGTID"
	MasterRecoveryPseudoGTID                      = "MasterRecoveryPseudoGTID"
	MasterRecoveryBinlogServer                    = "MasterRecoveryBinlogServer"
)

Variables

var ThisHostname string

Functions

func AttemptFailureDetectionRegistration

func AttemptFailureDetectionRegistration(analysisEntry *inst.ReplicationAnalysis) (bool, error)

AttemptFailureDetectionRegistration tries to add a failure-detection entry; if this fails that means the problem has already been detected

func AttemptRecoveryRegistration

func AttemptRecoveryRegistration(analysisEntry *inst.ReplicationAnalysis) (bool, error)

AttemptRecoveryRegistration tries to add a recovery entry; if this fails that means recovery is already in place.

func CheckAndRecover

func CheckAndRecover(specificInstance *inst.InstanceKey, candidateInstanceKey *inst.InstanceKey, skipFilters bool, skipProcesses bool) (actionTaken bool, instance *inst.Instance, err error)

CheckAndRecover is the main entry point for the recovery mechanism

func ClearActiveFailureDetections

func ClearActiveFailureDetections() error

ClearActiveFailureDetections clears the "in_active_period" flag for old-enough detections, thereby allowing for further detections on cleared instances.

func ClearActiveRecoveries

func ClearActiveRecoveries() error

ClearActiveRecoveries clears the "in_active_period" flag for old-enough recoveries, thereby allowing for further recoveries on cleared instances.

func ContinuousAgentsPoll

func ContinuousAgentsPoll()

ContinuousAgentsPoll starts an asynchronuous infinite process where agents are periodically investigated and their status captured, and long since unseen agents are purged and forgotten.

func ContinuousDiscovery

func ContinuousDiscovery()

ContinuousDiscovery starts an asynchronuous infinite discovery process where instances are periodically investigated and their status captured, and long since unseen instances are purged and forgotten.

func ElectedNode

func ElectedNode() (hostname string, token string, isElected bool, err error)

ElectedNode returns the details of the elected node, as well as answering the question "is this process the elected one"?

func GetCandidateSiblingOfIntermediateMaster

func GetCandidateSiblingOfIntermediateMaster(intermediateMasterInstance *inst.Instance) (*inst.Instance, error)

GetCandidateSiblingOfIntermediateMaster chooses the best sibling of a dead intermediate master to whom the IM's slaves can be moved.

func GetHash

func GetHash(input []byte) string

func GetRandomData

func GetRandomData() []byte

func GrabElection

func GrabElection() error

GrabElection forcibly grabs leadership. Use with care!!

func RecoverDeadIntermediateMaster

func RecoverDeadIntermediateMaster(analysisEntry inst.ReplicationAnalysis, skipProcesses bool) (recoveryResolved bool, successorInstance *inst.Instance, err error)

RecoverDeadIntermediateMaster performs intermediate master recovery; complete logic inside

func RecoverDeadMaster

func RecoverDeadMaster(analysisEntry inst.ReplicationAnalysis, skipProcesses bool) (promotedSlave *inst.Instance, lostSlaves [](*inst.Instance), err error)

RecoverDeadMaster recovers a dead master, complete logic inside

func Reelect

func Reelect() error

Reelect clears the way for re-elections. Active node is immediately demoted.

func ResolveRecovery

func ResolveRecovery(failedKey *inst.InstanceKey, successorInstance *inst.Instance) error

ResolveRecovery is called on completion of a recovery process and updates the recovery status. It does not clear the "active period" as this still takes place in order to avoid flapping.

func StartDiscovery

func StartDiscovery(instanceKey inst.InstanceKey)

Start discovery begins a one time asynchronuous discovery process for the given instance and all of its topology connected instances. That is, the instance will be investigated for master and slaves, and the routines will follow on each and every such found master/slave. In essense, assuming all slaves in a replication topology are running, and given a single instance in such topology, this function will detect the entire topology.

Types

type HealthStatus

type HealthStatus struct {
	Healthy        bool
	Hostname       string
	Token          string
	IsActiveNode   bool
	ActiveNode     string
	Error          error
	AvailableNodes []string
}

func HealthTest

func HealthTest() (*HealthStatus, error)

HealthTest attempts to write to the backend database and get a result

func SimpleHealthTest

func SimpleHealthTest() (*HealthStatus, error)

Just check to make sure we can connect to the database

type InstancesByCountSlaves

type InstancesByCountSlaves [](*inst.Instance)

InstancesByCountSlaves sorts instances by umber of slaves, descending

func (InstancesByCountSlaves) Len

func (this InstancesByCountSlaves) Len() int

func (InstancesByCountSlaves) Less

func (this InstancesByCountSlaves) Less(i, j int) bool

func (InstancesByCountSlaves) Swap

func (this InstancesByCountSlaves) Swap(i, j int)

type MasterRecoveryType

type MasterRecoveryType string

type Token

type Token struct {
	Hash string
}

Token is used to identify and validate requests to this service

var ProcessToken *Token = NewToken()

func NewToken

func NewToken() *Token

type TopologyRecovery

type TopologyRecovery struct {
	Id                     int64
	AnalysisEntry          inst.ReplicationAnalysis
	SuccessorKey           inst.InstanceKey
	IsActive               bool
	RecoveryStartTimestamp string
	RecoveryEndTimestamp   string
	ProcessingNodeHostname string
	ProcessingNodeToken    string
}

TopologyRecovery represents an entry in the topology_recovery table

func ReadActiveClusterRecovery

func ReadActiveClusterRecovery(clusterName string) ([]TopologyRecovery, error)

ReadActiveRecoveries reads active recovery entry/audit entires from topology_recovery

func ReadActiveRecoveries

func ReadActiveRecoveries() ([]TopologyRecovery, error)

ReadActiveRecoveries reads active recovery entry/audit entires from topology_recovery

func ReadCompletedRecoveries

func ReadCompletedRecoveries(page int) ([]TopologyRecovery, error)

ReadCompletedRecoveries reads completed recovery entry/audit entires from topology_recovery

func ReadRecentFailureDetections

func ReadRecentFailureDetections(page int) ([]TopologyRecovery, error)

ReadCRecoveries reads latest recovery entreis from topology_recovery

func ReadRecentRecoveries

func ReadRecentRecoveries(clusterName string, page int) ([]TopologyRecovery, error)

ReadCRecoveries reads latest recovery entreis from topology_recovery

func ReadRecentlyActiveClusterRecovery

func ReadRecentlyActiveClusterRecovery(clusterName string) ([]TopologyRecovery, error)

ReadRecentlyActiveInstanceRecovery reads recently completed entries for a given cluster

func ReadRecentlyActiveInstanceRecovery

func ReadRecentlyActiveInstanceRecovery(instanceKey *inst.InstanceKey) ([]TopologyRecovery, error)

ReadRecentlyActiveInstanceRecovery reads recently completed entries for a given instance