kubernetes/vendor/go.etcd.io/etcd/server/v3/etcdserver/api/membership/cluster.go

const maxLearners …

type RaftCluster …

type ConfigChangeContext …

type ShouldApplyV3 …

const ApplyBoth …

const ApplyV2storeOnly …

// NewClusterFromURLsMap creates a new raft cluster using provided urls map. Currently, it does not support creating
// cluster with raft learner member.
func NewClusterFromURLsMap(lg *zap.Logger, token string, urlsmap types.URLsMap) (*RaftCluster, error) { … }

func NewClusterFromMembers(lg *zap.Logger, id types.ID, membs []*Member) *RaftCluster { … }

func NewCluster(lg *zap.Logger) *RaftCluster { … }

func (c *RaftCluster) ID() types.ID { … }

func (c *RaftCluster) Members() []*Member { … }

func (c *RaftCluster) Member(id types.ID) *Member { … }

func (c *RaftCluster) VotingMembers() []*Member { … }

// MemberByName returns a Member with the given name if exists.
// If more than one member has the given name, it will panic.
func (c *RaftCluster) MemberByName(name string) *Member { … }

func (c *RaftCluster) MemberIDs() []types.ID { … }

func (c *RaftCluster) IsIDRemoved(id types.ID) bool { … }

// PeerURLs returns a list of all peer addresses.
// The returned list is sorted in ascending lexicographical order.
func (c *RaftCluster) PeerURLs() []string { … }

// ClientURLs returns a list of all client addresses.
// The returned list is sorted in ascending lexicographical order.
func (c *RaftCluster) ClientURLs() []string { … }

func (c *RaftCluster) String() string { … }

func (c *RaftCluster) genID() { … }

func (c *RaftCluster) SetID(localID, cid types.ID) { … }

func (c *RaftCluster) SetStore(st v2store.Store) { … }

func (c *RaftCluster) SetBackend(be backend.Backend) { … }

func (c *RaftCluster) Recover(onSet func(*zap.Logger, *semver.Version)) { … }

// ValidateConfigurationChange takes a proposed ConfChange and
// ensures that it is still valid.
func (c *RaftCluster) ValidateConfigurationChange(cc raftpb.ConfChange) error { … }

// AddMember adds a new Member into the cluster, and saves the given member's
// raftAttributes into the store. The given member should have empty attributes.
// A Member with a matching id must not exist.
func (c *RaftCluster) AddMember(m *Member, shouldApplyV3 ShouldApplyV3) { … }

// RemoveMember removes a member from the store.
// The given id MUST exist, or the function panics.
func (c *RaftCluster) RemoveMember(id types.ID, shouldApplyV3 ShouldApplyV3) { … }

func (c *RaftCluster) UpdateAttributes(id types.ID, attr Attributes, shouldApplyV3 ShouldApplyV3) { … }

// PromoteMember marks the member's IsLearner RaftAttributes to false.
func (c *RaftCluster) PromoteMember(id types.ID, shouldApplyV3 ShouldApplyV3) { … }

func (c *RaftCluster) UpdateRaftAttributes(id types.ID, raftAttr RaftAttributes, shouldApplyV3 ShouldApplyV3) { … }

func (c *RaftCluster) Version() *semver.Version { … }

func (c *RaftCluster) SetVersion(ver *semver.Version, onSet func(*zap.Logger, *semver.Version), shouldApplyV3 ShouldApplyV3) { … }

func (c *RaftCluster) IsReadyToAddVotingMember() bool { … }

func (c *RaftCluster) IsReadyToRemoveVotingMember(id uint64) bool { … }

func (c *RaftCluster) IsReadyToPromoteMember(id uint64) bool { … }

func membersFromStore(lg *zap.Logger, st v2store.Store) (map[types.ID]*Member, map[types.ID]bool) { … }

func membersFromBackend(lg *zap.Logger, be backend.Backend) (map[types.ID]*Member, map[types.ID]bool) { … }

func clusterVersionFromStore(lg *zap.Logger, st v2store.Store) *semver.Version { … }

// The field is populated since etcd v3.5.
func clusterVersionFromBackend(lg *zap.Logger, be backend.Backend) *semver.Version { … }

// The field is populated since etcd v3.5.
func downgradeInfoFromBackend(lg *zap.Logger, be backend.Backend) *DowngradeInfo { … }

// ValidateClusterAndAssignIDs validates the local cluster by matching the PeerURLs
// with the existing cluster. If the validation succeeds, it assigns the IDs
// from the existing cluster to the local cluster.
// If the validation fails, an error will be returned.
func ValidateClusterAndAssignIDs(lg *zap.Logger, local *RaftCluster, existing *RaftCluster) error { … }

// IsValidVersionChange checks the two scenario when version is valid to change:
// 1. Downgrade: cluster version is 1 minor version higher than local version,
// cluster version should change.
// 2. Cluster start: when not all members version are available, cluster version
// is set to MinVersion(3.0), when all members are at higher version, cluster version
// is lower than local version, cluster version should change
func IsValidVersionChange(cv *semver.Version, lv *semver.Version) bool { … }

// IsLocalMemberLearner returns if the local member is raft learner
func (c *RaftCluster) IsLocalMemberLearner() bool { … }

// DowngradeInfo returns the downgrade status of the cluster
func (c *RaftCluster) DowngradeInfo() *DowngradeInfo { … }

func (c *RaftCluster) SetDowngradeInfo(d *DowngradeInfo, shouldApplyV3 ShouldApplyV3) { … }

// IsMemberExist returns if the member with the given id exists in cluster.
func (c *RaftCluster) IsMemberExist(id types.ID) bool { … }

// VotingMemberIDs returns the ID of voting members in cluster.
func (c *RaftCluster) VotingMemberIDs() []types.ID { … }

// PushMembershipToStorage is overriding storage information about cluster's
// members, such that they fully reflect internal RaftCluster's storage.
func (c *RaftCluster) PushMembershipToStorage() { … }