Lines Matching defs:cluster
61 type cluster struct { struct
62 id types.ID
63 token string
64 store store.Store
66 sync.Mutex // guards the fields below
67 version *semver.Version
68 members map[types.ID]*Member
71 removed map[types.ID]bool
107 func (c *cluster) ID() types.ID { return c.id }
109 func (c *cluster) Members() []*Member {
120 func (c *cluster) Member(id types.ID) *Member {
128 func (c *cluster) MemberByName(name string) *Member {
143 func (c *cluster) MemberIDs() []types.ID {
154 func (c *cluster) IsIDRemoved(id types.ID) bool {
162 func (c *cluster) PeerURLs() []string {
177 func (c *cluster) ClientURLs() []string {
190 func (c *cluster) String() string {
208 func (c *cluster) genID() {
218 func (c *cluster) SetID(id types.ID) { c.id = id }
220 func (c *cluster) SetStore(st store.Store) { c.store = st }
222 func (c *cluster) Recover() {
240 func (c *cluster) ValidateConfigurationChange(cc raftpb.ConfChange) error {
301 func (c *cluster) AddMember(m *Member) {
317 func (c *cluster) RemoveMember(id types.ID) {
330 func (c *cluster) UpdateAttributes(id types.ID, attr Attributes) bool {
347 func (c *cluster) UpdateRaftAttributes(id types.ID, raftAttr RaftAttributes) {
361 func (c *cluster) Version() *semver.Version {
370 func (c *cluster) SetVersion(ver *semver.Version) {
382 func (c *cluster) isReadyToAddNewMember() bool {
410 func (c *cluster) isReadyToRemoveMember(id uint64) bool {
481 func ValidateClusterAndAssignIDs(local *cluster, existing *cluster) error {