package
3.0.3+incompatible
Repository: https://github.com/cloudmode/orchestrator.git
Documentation: pkg.go.dev
# Functions
AcknowledgeClusterRecoveries marks active recoveries for given cluster as acknowledged.
AcknowledgeCrashedRecoveries marks recoveries whose processing nodes has crashed as acknowledged.
AcknowledgeInstanceCompletedRecoveries marks active and COMPLETED recoveries for given instane as acknowledged.
AcknowledgeInstanceRecoveries marks active recoveries for given instane as acknowledged.
AcknowledgeRecovery acknowledges a particular recovery.
AttemptFailureDetectionRegistration tries to add a failure-detection entry; if this fails that means the problem has already been detected.
AttemptRecoveryRegistration tries to add a recovery entry; if this fails that means recovery is already in place.
AuditTopologyRecovery audits a single step in a topology recovery process.
CheckAndRecover is the main entry point for the recovery mechanism.
ClearActiveFailureDetections clears the "in_active_period" flag for old-enough detections, thereby allowing for further detections on cleared instances.
ClearActiveRecoveries clears the "in_active_period" flag for old-enough recoveries, thereby allowing for further recoveries on cleared instances.
ContinuousAgentsPoll starts an asynchronuous infinite process where agents are periodically investigated and their status captured, and long since unseen agents are purged and forgotten.
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.
No description provided by the author
DisableRecovery ensures recoveries are disabled globally.
EnableRecovery ensures recoveries are enabled globally.
ExpireBlockedRecoveries clears listing of blocked recoveries that are no longer actually blocked.
ExpireFailureDetectionHistory removes old rows from the topology_failure_detection table.
ExpireTopologyRecoveryHistory removes old rows from the topology_failure_detection table.
ExpireTopologyRecoveryStepsHistory removes old rows from the topology_failure_detection table.
ForceExecuteRecovery can be called to issue a recovery process even if analysis says there is no recovery case.
ForceMasterFailover *trusts* master of given cluster is dead and initiates a failover.
ForceMasterTakeover *trusts* master of given cluster is dead and fails over to designated instance, which has to be its direct child.
No description provided by the author
GetCandidateSiblingOfIntermediateMaster chooses the best sibling of a dead intermediate master to whom the IM's replicas can be moved.
GracefulMasterTakeover will demote master of existing topology and promote its direct replica instead.
No description provided by the author
No description provided by the author
IsRecoveryDisabled returns true if Recoveries are disabled globally.
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
ReadActiveRecoveries reads active recovery entry/audit entires from topology_recovery.
ReadActiveRecoveries reads active recovery entry/audit entires from topology_recovery.
ReadBlockedRecoveries reads blocked recovery entries, potentially filtered by cluster name (empty to unfilter).
ReadCompletedRecoveries reads completed recovery entry/audit entires from topology_recovery.
ReadFailureDetection.
ReadInActivePeriodClusterRecovery reads recoveries (possibly complete!) that are in active period.
ReadInActivePeriodSuccessorInstanceRecovery reads completed recoveries for a given instance, where said instance was promoted as result, still in active period (may be used to block further recoveries should this instance die).
ReadRecentFailureDetections.
ReadRecentlyActiveClusterRecovery reads recently completed entries for a given cluster.
ReadRecentlyActiveInstanceRecovery reads recently completed entries for a given instance.
ReadCRecoveries reads latest recovery entries from topology_recovery.
ReadRecovery reads completed recovery entry/audit entires from topology_recovery.
ReadRecoveryByUID reads completed recovery entry/audit entires from topology_recovery.
ReadTopologyRecoverySteps reads recovery steps for a given recovery.
RecoverDeadCoMaster recovers a dead co-master, complete logic inside.
RecoverDeadIntermediateMaster performs intermediate master recovery; complete logic inside.
RecoverDeadMaster recovers a dead master, complete logic inside.
RegisterBlockedRecoveries writes down currently blocked recoveries, and indicates what recovery they are blocked on.
ResolveRecovery is called on completion of a recovery process and updates the recovery status.
No description provided by the author
# Constants
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
# Structs
BlockedTopologyRecovery represents an entry in the blocked_topology_recovery table.
AsyncRequest represents an entry in the async_request table.
No description provided by the author
No description provided by the author
No description provided by the author
TopologyRecovery represents an entry in the topology_recovery table.
No description provided by the author
# Type aliases
InstancesByCountReplicas sorts instances by umber of replicas, descending.
No description provided by the author