process

Documentation

Index

• Variables
• func AttemptElection() (bool, error)
• func ContinuousRegistration(extraInfo string, command string)
• func ExpireAvailableNodes()
• func ExpireNodesHistory() error
• func GrabElection() error
• func Reelect() error
• func RegisterNode(nodeHealth *NodeHealth) (healthy bool, err error)
• func SinceLastGoodHealthCheck() time.Duration
• func SinceLastHealthCheck() time.Duration
• func TokenBelongsToHealthyHttpService(token string) (result bool, err error)
• func WriteRegisterNode(nodeHealth *NodeHealth) (healthy bool, err error)
• type ExecutionMode
• type HealthStatus
  • func HealthTest() (health *HealthStatus, err error)
• type NodeHealth
  • func ElectedNode() (node NodeHealth, isElected bool, err error)
  • func NewNodeHealth() *NodeHealth
  • func ReadAvailableNodes(onlyHttpNodes bool) (nodes [](*NodeHealth), err error)
  • func (nodeHealth *NodeHealth) Update() *NodeHealth

Variables

var LastContinousCheckHealthy int64

var ThisNodeHealth = NewNodeHealth()

Functions

func AttemptElection

func AttemptElection() (bool, error)

AttemptElection tries to grab leadership (become active node)

func ContinuousRegistration

func ContinuousRegistration(extraInfo string, command string)

ContinuousRegistration will continuously update the ham_node_health table showing that the current process is still running.

func ExpireAvailableNodes

func ExpireAvailableNodes()

ExpireAvailableNodes is an aggressive purging method to remove node entries who have skipped their keepalive for two times.

func ExpireNodesHistory

func ExpireNodesHistory() error

ExpireNodesHistory cleans up the nodes history and is run by the ham4db active node.

func GrabElection

func GrabElection() error

GrabElection forcibly grabs leadership. Use with care!!

func Reelect

func Reelect() error

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

func RegisterNode

func RegisterNode(nodeHealth *NodeHealth) (healthy bool, err error)

func SinceLastGoodHealthCheck

func SinceLastGoodHealthCheck() time.Duration

func SinceLastHealthCheck

func SinceLastHealthCheck() time.Duration

func TokenBelongsToHealthyHttpService

func TokenBelongsToHealthyHttpService(token string) (result bool, err error)

func WriteRegisterNode

func WriteRegisterNode(nodeHealth *NodeHealth) (healthy bool, err error)

RegisterNode writes down this node in the ham_node_health table

Types

type ExecutionMode

type ExecutionMode string

const (
	ExecutionCliMode  ExecutionMode = "CLIMode"
	ExecutionHttpMode               = "HttpMode"
)

type HealthStatus

type HealthStatus struct {
	Healthy            bool
	Hostname           string
	Token              string
	IsActiveNode       bool
	ActiveNode         NodeHealth
	Error              error
	AvailableNodes     [](*NodeHealth)
	RaftLeader         string
	IsRaftLeader       bool
	RaftLeaderURI      string
	RaftAdvertise      string
	RaftHealthyMembers []string
}

func HealthTest

func HealthTest() (health *HealthStatus, err error)

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

type NodeHealth

type NodeHealth struct {
	Hostname        string
	Token           string
	AppVersion      string
	FirstSeenActive string
	LastSeenActive  string
	ExtraInfo       string
	Command         string
	DBBackend       string

	LastReported time.Time
	// contains filtered or unexported fields
}

func ElectedNode

func ElectedNode() (node NodeHealth, 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 NewNodeHealth

func NewNodeHealth() *NodeHealth

func ReadAvailableNodes

func ReadAvailableNodes(onlyHttpNodes bool) (nodes [](*NodeHealth), err error)

func (*NodeHealth) Update

func (nodeHealth *NodeHealth) Update() *NodeHealth