orchestrator

Documentation

Index

• Variables
• func AccountedDiscoverInstance(instanceKey inst.InstanceKey, pendingTokens chan bool, ...)
• func AttemptElection() (bool, error)
• func ContinuousAgentsPoll()
• func ContinuousDiscovery()
• func DiscoverInstance(instanceKey inst.InstanceKey)
• func GetHash(input []byte) string
• func GetRandomData() []byte
• func HealthTest() (bool, error)
• func IsElected() (bool, error)
• func StartDiscovery(instanceKey inst.InstanceKey)
• type Token
  • func NewToken() *Token

Variables

var ThisHostname string

Functions

func AccountedDiscoverInstance

func AccountedDiscoverInstance(instanceKey inst.InstanceKey, pendingTokens chan bool, completedTokens chan bool)

AccountedDiscoverInstance will call upon DiscoverInstance and will keep track of discovery tokens such that management of multiple discoveries can figure out whether all instances in a topology are accounted for.

func AttemptElection

func AttemptElection() (bool, error)

WriteResolvedHostname stores a hostname and the resolved hostname to backend database

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 DiscoverInstance

func DiscoverInstance(instanceKey inst.InstanceKey)

DiscoverInstance will attempt discovering an instance (unless it is already up to date) and will list down its master and slaves (if any) for further discovery.

func GetHash

func GetHash(input []byte) string

func GetRandomData

func GetRandomData() []byte

func HealthTest

func HealthTest() (bool, error)

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

func IsElected

func IsElected() (bool, error)

ReadResolvedHostname returns the resolved hostname given a hostname, or empty if not exists

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 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