nmon

Documentation

Overview

Package nmon is responsible for the local node states

It provides the cluster data:

.cluster.node.<localhost>.monitor
.cluster.node.<localhost>.stats
.cluster.node.<localhost>.status (except gen)

It maintains the nodesinfo.json

The worker watches local status updates and clear reached status

=> unsetStatusWhenReached
=> orchestrate
=> pub new state if change

The worker watches remote nmon updates and converge global expects

=> convergeGlobalExpectFromRemote
=> orchestrate
=> pub new state if change

Index

• Variables
• func SetCmdPathForTest(s string)
• type Manager
  • func NewManager(drainDuration time.Duration, subQS pubsub.QueueSizer) *Manager
  • func (t *Manager) Start(parent context.Context) error
  • func (t *Manager) Stop() error
  • func (t *Manager) ThawedFromIdle()

Variables

var (
	// MinMaxParallel is the minimum value of the setting of maximum number of CRM
	// actions allowed to run in parallel.
	MinMaxParallel = 2
)

Functions

func SetCmdPathForTest

func SetCmdPathForTest(s string)

SetCmdPathForTest set the opensvc command path for tests

Types

type Manager

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

func NewManager

func NewManager(drainDuration time.Duration, subQS pubsub.QueueSizer) *Manager

func (*Manager) Start

func (t *Manager) Start(parent context.Context) error

Start launches the nmon worker goroutine

func (*Manager) Stop

func (t *Manager) Stop() error

func (*Manager) ThawedFromIdle

func (t *Manager) ThawedFromIdle()