ccfg

Documentation

Overview

Package ccfg is responsible for the cluster config

It subscribes on msgbus.ConfigFileUpdated for cluster to provide:

cluster configuration reload:
  => cluster.ConfigData update => .cluster.config
  => clusternode update (for node selector, clusternodes dereference)
  => publication of msgbus.ClusterConfigUpdated for local node

Index

• type Manager
  • func New(drainDuration time.Duration, subQS pubsub.QueueSizer) *Manager
  • func (t *Manager) Start(parent context.Context) error
  • func (t *Manager) Stop() error
• type NodeDB
  • func (*NodeDB) AuthenticateNode(nodename, password string) error

Types

type Manager

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

func New

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

func (*Manager) Start

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

Start launches the ccfg worker goroutine

func (*Manager) Stop

func (t *Manager) Stop() error

type NodeDB

type NodeDB struct{}

NodeDB implements AuthenticateNode

func (*NodeDB) AuthenticateNode

func (*NodeDB) AuthenticateNode(nodename, password string) error

AuthenticateNode returns nil if nodename is a cluster node and password is cluster secret