diff options
| author | chrislu <chris.lu@gmail.com> | 2023-06-20 00:12:59 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2023-06-20 00:12:59 -0700 |
| commit | a82c44972b122ff869ae70e53eea1f8bcc5a67e3 (patch) | |
| tree | 24fc53ac0963845b2afa08c63005dd3ae5cf8c76 /weed/cluster/group_members.go | |
| parent | 14a19170e2f11866c6b590444f771bd60deb8b54 (diff) | |
| download | seaweedfs-a82c44972b122ff869ae70e53eea1f8bcc5a67e3.tar.xz seaweedfs-a82c44972b122ff869ae70e53eea1f8bcc5a67e3.zip | |
refactor
Diffstat (limited to 'weed/cluster/group_members.go')
| -rw-r--r-- | weed/cluster/group_members.go | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/weed/cluster/group_members.go b/weed/cluster/group_members.go index 01b97feae..79bd78790 100644 --- a/weed/cluster/group_members.go +++ b/weed/cluster/group_members.go @@ -9,6 +9,12 @@ type GroupMembers struct { members map[pb.ServerAddress]*ClusterNode } +func newGroupMembers() *GroupMembers { + return &GroupMembers{ + members: make(map[pb.ServerAddress]*ClusterNode), + } +} + func (m *GroupMembers) addMember(dataCenter DataCenter, rack Rack, address pb.ServerAddress, version string) *ClusterNode { if existingNode, found := m.members[address]; found { existingNode.counter++ |