nmon

package

v3.0.0-rc1 Latest Latest Go to latest Published: Feb 18, 2026 License: Apache-2.0 Imports: 48 Imported by: 0

Details

Rendered for

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)

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

This section is empty.

View Source

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

func SetCmdPathForTest(s string)

SetCmdPathForTest set the opensvc command path for tests

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

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

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

Start launches the nmon worker goroutine

func (t *Manager) Stop() error