diff options
| author | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-11-30 19:30:55 +0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-11-30 06:30:55 -0800 |
| commit | f59c3acd5f3619f7377726effd03d7f3da98817b (patch) | |
| tree | 1d9c1389e73cdbd0953cd1a07bc810acc03ed4be | |
| parent | 1422684a9e7f945476c3b67f20e2dcdf217c3c3d (diff) | |
| download | seaweedfs-f59c3acd5f3619f7377726effd03d7f3da98817b.tar.xz seaweedfs-f59c3acd5f3619f7377726effd03d7f3da98817b.zip | |
volume.list show volumes only from the specified dc/rack/dn (#4024)
| -rw-r--r-- | weed/shell/command_volume_list.go | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/weed/shell/command_volume_list.go b/weed/shell/command_volume_list.go index 408bb02f7..b4f94df1a 100644 --- a/weed/shell/command_volume_list.go +++ b/weed/shell/command_volume_list.go @@ -18,6 +18,9 @@ func init() { type commandVolumeList struct { collectionPattern *string + dataCenter *string + rack *string + dataNode *string readonly *bool volumeId *uint64 } @@ -41,6 +44,9 @@ func (c *commandVolumeList) Do(args []string, commandEnv *CommandEnv, writer io. c.collectionPattern = volumeListCommand.String("collectionPattern", "", "match with wildcard characters '*' and '?'") c.readonly = volumeListCommand.Bool("readonly", false, "show only readonly") c.volumeId = volumeListCommand.Uint64("volumeId", 0, "show only volume id") + c.dataCenter = volumeListCommand.String("dataCenter", "", "show volumes only from the specified data center") + c.rack = volumeListCommand.String("rack", "", "show volumes only from the specified rack") + c.dataNode = volumeListCommand.String("dataNode", "", "show volumes only from the specified data node") if err = volumeListCommand.Parse(args); err != nil { return nil @@ -80,6 +86,9 @@ func (c *commandVolumeList) writeTopologyInfo(writer io.Writer, t *master_pb.Top }) var s statistics for _, dc := range t.DataCenterInfos { + if *c.dataCenter != "" && *c.dataCenter != dc.Id { + continue + } s = s.plus(c.writeDataCenterInfo(writer, dc, verbosityLevel)) } output(verbosityLevel >= 0, writer, "%+v \n", s) @@ -93,6 +102,9 @@ func (c *commandVolumeList) writeDataCenterInfo(writer io.Writer, t *master_pb.D return a.Id < b.Id }) for _, r := range t.RackInfos { + if *c.rack != "" && *c.rack != r.Id { + continue + } s = s.plus(c.writeRackInfo(writer, r, verbosityLevel)) } output(verbosityLevel >= 1, writer, " DataCenter %s %+v \n", t.Id, s) @@ -106,6 +118,9 @@ func (c *commandVolumeList) writeRackInfo(writer io.Writer, t *master_pb.RackInf return a.Id < b.Id }) for _, dn := range t.DataNodeInfos { + if *c.dataNode != "" && *c.dataNode != dn.Id { + continue + } s = s.plus(c.writeDataNodeInfo(writer, dn, verbosityLevel)) } output(verbosityLevel >= 2, writer, " Rack %s %+v \n", t.Id, s) |