package membership

import "github.com/moby/swarmkit/v2/manager/state/raft/membership"

Index ¶

• Variables
• type Cluster
• func NewCluster() *Cluster
• func (c *Cluster) AddMember(member *Member) error
• func (c *Cluster) Clear()
• func (c *Cluster) ClearMember(id uint64) error
• func (c *Cluster) GetMember(id uint64) *Member
• func (c *Cluster) IsIDRemoved(id uint64) bool
• func (c *Cluster) Members() map[uint64]*Member
• func (c *Cluster) RemoveMember(id uint64) error
• func (c *Cluster) Removed() []uint64
• func (c *Cluster) UpdateMember(id uint64, m *api.RaftMember) error
• func (c *Cluster) ValidateConfigurationChange(cc raftpb.ConfChange) error
• type Member

Variables ¶

var (
	// ErrIDExists is thrown when a node wants to join the existing cluster but its ID already exists
	ErrIDExists = errors.New("membership: can't add node to cluster, node id is a duplicate")
	// ErrIDRemoved is thrown when a node tries to perform an operation on an existing cluster but was removed
	ErrIDRemoved = errors.New("membership: node was removed during cluster lifetime")
	// ErrIDNotFound is thrown when we try an operation on a member that does not exist in the cluster list
	ErrIDNotFound = errors.New("membership: member not found in cluster list")
	// ErrConfigChangeInvalid is thrown when a configuration change we received looks invalid in form
	ErrConfigChangeInvalid = errors.New("membership: ConfChange type should be either AddNode, RemoveNode or UpdateNode")
	// ErrCannotUnmarshalConfig is thrown when a node cannot unmarshal a configuration change
	ErrCannotUnmarshalConfig = errors.New("membership: cannot unmarshal configuration change")
	// ErrMemberRemoved is thrown when a node was removed from the cluster
	ErrMemberRemoved = errors.New("raft: member was removed from the cluster")
)

Types ¶

type Cluster ¶

type Cluster struct {
	PeersBroadcast *watch.Queue
	// contains filtered or unexported fields
}

Cluster represents a set of active raft Members

func NewCluster ¶

func NewCluster() *Cluster

NewCluster creates a new Cluster neighbors list for a raft Member.

func (*Cluster) AddMember ¶

func (c *Cluster) AddMember(member *Member) error

AddMember adds a node to the Cluster Memberlist.

func (*Cluster) Clear ¶

func (c *Cluster) Clear()

Clear resets the list of active Members and removed Members.

func (*Cluster) ClearMember ¶

func (c *Cluster) ClearMember(id uint64) error

ClearMember removes a node from the Cluster Memberlist, but does NOT add it to the removed list.

func (*Cluster) GetMember ¶

func (c *Cluster) GetMember(id uint64) *Member

GetMember returns informations on a given Member.

func (*Cluster) IsIDRemoved ¶

func (c *Cluster) IsIDRemoved(id uint64) bool

IsIDRemoved checks if a Member is in the remove set.

func (*Cluster) Members ¶

func (c *Cluster) Members() map[uint64]*Member

Members returns the list of raft Members in the Cluster.

func (*Cluster) RemoveMember ¶

func (c *Cluster) RemoveMember(id uint64) error

RemoveMember removes a node from the Cluster Memberlist, and adds it to the removed list.

func (*Cluster) Removed ¶

func (c *Cluster) Removed() []uint64

Removed returns the list of raft Members removed from the Cluster.

func (*Cluster) UpdateMember ¶

func (c *Cluster) UpdateMember(id uint64, m *api.RaftMember) error

UpdateMember updates member address.

func (*Cluster) ValidateConfigurationChange ¶

func (c *Cluster) ValidateConfigurationChange(cc raftpb.ConfChange) error

ValidateConfigurationChange takes a proposed ConfChange and ensures that it is valid.

type Member ¶

type Member struct {
	*api.RaftMember
}

Member represents a raft Cluster Member

Source Files ¶

cluster.go