imon

Documentation

Overview

Package imon is responsible for of local instance state

It provides the cluster data:
	["cluster", "node", <localhost>, "services", "status", <instance>, "monitor"]
	["cluster", "node", <localhost>, "services", "imon", <instance>]

imon are created by the local instcfg, with parent context instcfg context.
instcfg done => imon done

worker watches on local instance status updates to clear reached status
	=> unsetStatusWhenReached
	=> orchestrate
	=> pub new state if change

worker watches on remote instance imon updates converge global expects
	=> convergeGlobalExpectFromRemote
	=> orchestrate
	=> pub new state if change

Index

• func SetCmdPathForTest(s string)
• type Factory
  • func (f Factory) Start(parent context.Context, p naming.Path, nodes []string) error
• type Manager
  • func (t *Manager) AllInstanceMonitorState(s instance.MonitorState) bool
  • func (t *Manager) AllInstanceMonitors() map[string]instance.Monitor
  • func (t *Manager) GetInstanceMonitor(node string) (instance.Monitor, bool)
  • func (t *Manager) IsInstanceStartFailed(node string) (bool, bool)
  • func (t *Manager) IsInstanceStatusNotApplicable(node string) (bool, bool)
  • func (t *Manager) IsNodeMonitorStatusRankable(node string) (bool, bool)
  • func (t *Manager) ThawedFromIdle()
  • func (t *Manager) UnprovisionedFromIdle()
  • func (t *Manager) UnprovisionedFromWaitNonLeader()

Functions

func SetCmdPathForTest

func SetCmdPathForTest(s string)

SetCmdPathForTest set the opensvc command path for tests

Types

type Factory

type Factory struct {
	DrainDuration time.Duration
	SubQS         pubsub.QueueSizer
	DelayDuration time.Duration
}

func (Factory) Start

func (f Factory) Start(parent context.Context, p naming.Path, nodes []string) error

Start creates a new imon and starts worker goroutine to manage local instance monitor

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

func (*Manager) AllInstanceMonitorState

func (t *Manager) AllInstanceMonitorState(s instance.MonitorState) bool

func (*Manager) AllInstanceMonitors

func (t *Manager) AllInstanceMonitors() map[string]instance.Monitor

func (*Manager) GetInstanceMonitor

func (t *Manager) GetInstanceMonitor(node string) (instance.Monitor, bool)

func (*Manager) IsInstanceStartFailed

func (t *Manager) IsInstanceStartFailed(node string) (bool, bool)

func (*Manager) IsInstanceStatusNotApplicable

func (t *Manager) IsInstanceStatusNotApplicable(node string) (bool, bool)

func (*Manager) IsNodeMonitorStatusRankable

func (t *Manager) IsNodeMonitorStatusRankable(node string) (bool, bool)

func (*Manager) ThawedFromIdle

func (t *Manager) ThawedFromIdle()

func (*Manager) UnprovisionedFromIdle

func (t *Manager) UnprovisionedFromIdle()

func (*Manager) UnprovisionedFromWaitNonLeader

func (t *Manager) UnprovisionedFromWaitNonLeader()