aboutsummaryrefslogtreecommitdiff
path: root/weed/topology/topology.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/topology/topology.go')
-rw-r--r--weed/topology/topology.go11
1 files changed, 7 insertions, 4 deletions
diff --git a/weed/topology/topology.go b/weed/topology/topology.go
index 6d5b373e9..f82f63379 100644
--- a/weed/topology/topology.go
+++ b/weed/topology/topology.go
@@ -4,12 +4,13 @@ import (
"encoding/json"
"errors"
"fmt"
- "github.com/chrislusf/seaweedfs/weed/pb"
- "github.com/chrislusf/seaweedfs/weed/storage/types"
"math/rand"
"sync"
"time"
+ "github.com/chrislusf/seaweedfs/weed/pb"
+ "github.com/chrislusf/seaweedfs/weed/storage/types"
+
"github.com/chrislusf/raft"
hashicorpRaft "github.com/hashicorp/raft"
@@ -42,8 +43,10 @@ type Topology struct {
Configuration *Configuration
- RaftServer raft.Server
- HashicorpRaft *hashicorpRaft.Raft
+ RaftServer raft.Server
+ HashicorpRaft *hashicorpRaft.Raft
+ UUIDAccessLock sync.RWMutex
+ UUIDMap map[string][]string
}
func NewTopology(id string, seq sequence.Sequencer, volumeSizeLimit uint64, pulse int, replicationAsMin bool) *Topology {