diff options
| author | Chris Lu <chris.lu@gmail.com> | 2013-11-10 01:31:50 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2013-11-10 01:31:50 -0800 |
| commit | 1888d01fa0329f60732ab6d7defc95ee257af4e0 (patch) | |
| tree | 8444dbaaf0c3fd5c4ac33c31e177bc9b883cdd58 /go/topology/topology.go | |
| parent | 5cb6590eaee59bd02fbe3e58084aba8079861112 (diff) | |
| download | seaweedfs-1888d01fa0329f60732ab6d7defc95ee257af4e0.tar.xz seaweedfs-1888d01fa0329f60732ab6d7defc95ee257af4e0.zip | |
adding etcd storage support for cluster meta data. Currently just
sequence. More to come...
Diffstat (limited to 'go/topology/topology.go')
| -rw-r--r-- | go/topology/topology.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/go/topology/topology.go b/go/topology/topology.go index d0e9fb42b..b21601210 100644 --- a/go/topology/topology.go +++ b/go/topology/topology.go @@ -28,7 +28,7 @@ type Topology struct { configuration *Configuration } -func NewTopology(id string, confFile string, dirname string, sequenceFilename string, volumeSizeLimit uint64, pulse int) (*Topology, error) { +func NewTopology(id string, confFile string, seq sequence.Sequencer, volumeSizeLimit uint64, pulse int) (*Topology, error) { t := &Topology{} t.id = NodeId(id) t.nodeType = "Topology" @@ -38,7 +38,7 @@ func NewTopology(id string, confFile string, dirname string, sequenceFilename st t.pulse = int64(pulse) t.volumeSizeLimit = volumeSizeLimit - t.sequence = sequence.NewSequencer(dirname, sequenceFilename) + t.sequence = seq t.chanDeadDataNodes = make(chan *DataNode) t.chanRecoveredDataNodes = make(chan *DataNode) |