aboutsummaryrefslogtreecommitdiff
path: root/go/topology/cluster_commands.go
diff options
context:
space:
mode:
Diffstat (limited to 'go/topology/cluster_commands.go')
-rw-r--r--go/topology/cluster_commands.go31
1 files changed, 0 insertions, 31 deletions
diff --git a/go/topology/cluster_commands.go b/go/topology/cluster_commands.go
deleted file mode 100644
index eac93c13c..000000000
--- a/go/topology/cluster_commands.go
+++ /dev/null
@@ -1,31 +0,0 @@
-package topology
-
-import (
- "github.com/chrislusf/raft"
- "github.com/chrislusf/seaweedfs/go/glog"
- "github.com/chrislusf/seaweedfs/go/storage"
-)
-
-type MaxVolumeIdCommand struct {
- MaxVolumeId storage.VolumeId `json:"maxVolumeId"`
-}
-
-func NewMaxVolumeIdCommand(value storage.VolumeId) *MaxVolumeIdCommand {
- return &MaxVolumeIdCommand{
- MaxVolumeId: value,
- }
-}
-
-func (c *MaxVolumeIdCommand) CommandName() string {
- return "MaxVolumeId"
-}
-
-func (c *MaxVolumeIdCommand) Apply(server raft.Server) (interface{}, error) {
- topo := server.Context().(*Topology)
- before := topo.GetMaxVolumeId()
- topo.UpAdjustMaxVolumeId(c.MaxVolumeId)
-
- glog.V(4).Infoln("max volume id", before, "==>", topo.GetMaxVolumeId())
-
- return nil, nil
-}