cluster

Documentation

Overview

Package cluster implements low-level clustering logic, especially logic regarding to bootstrapping, registering into and joining a cluster. Its goal is to provide the rest of the node code with the following:

• A mounted plaintext storage.
• Node credentials/identity.
• A locally running etcd server if the node is supposed to run one, and a client connection to that etcd cluster if so.
• The state of the cluster as seen by the node, to enable code to respond to node lifecycle changes.

Index

• type Manager
  • func NewManager(storageRoot *localstorage.Root, networkService *network.Service, ...) *Manager
  • func (m *Manager) Run(ctx context.Context) error

Types

type Manager

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

func NewManager

func NewManager(storageRoot *localstorage.Root, networkService *network.Service, rs *roleserve.Service, updateService *update.Service, nodeParams *apb.NodeParameters, haveTPM bool) *Manager

NewManager creates a new cluster Manager. The given localstorage Root must be places, but not yet started (and will be started as the Manager makes progress). The given network Service must already be running.

func (*Manager) Run

func (m *Manager) Run(ctx context.Context) error

Run is the runnable of the Manager, to be started using the Supervisor. It is one-shot, and should not be restarted.