forked from TrueCloudLab/frostfs-node
52 lines
1.4 KiB
Go
52 lines
1.4 KiB
Go
|
package storagegroup
|
||
|
|
|
||
|
|
import (
|
||
|
|
internalclient "github.com/nspcc-dev/neofs-node/cmd/neofs-cli/internal/client"
|
||
|
|
"github.com/nspcc-dev/neofs-node/cmd/neofs-cli/internal/common"
|
||
|
|
"github.com/nspcc-dev/neofs-node/cmd/neofs-cli/internal/commonflags"
|
||
|
|
"github.com/nspcc-dev/neofs-node/cmd/neofs-cli/internal/key"
|
||
|
|
objectCli "github.com/nspcc-dev/neofs-node/cmd/neofs-cli/modules/object"
|
||
|
|
sessionCli "github.com/nspcc-dev/neofs-node/cmd/neofs-cli/modules/session"
|
||
|
|
"github.com/nspcc-dev/neofs-node/pkg/services/object_manager/storagegroup"
|
||
|
|
cid "github.com/nspcc-dev/neofs-sdk-go/container/id"
|
||
|
|
"github.com/spf13/cobra"
|
||
|
|
)
|
||
|
|
|
||
|
|
var sgListCmd = &cobra.Command{
|
||
|
|
Use: "list",
|
||
|
|
Short: "List storage groups in NeoFS container",
|
||
|
|
Long: "List storage groups in NeoFS container",
|
||
|
|
Run: listSG,
|
||
|
|
}
|
||
|
|
|
||
|
|
func initSGListCmd() {
|
||
|
|
commonflags.Init(sgListCmd)
|
||
|
|
|
||
|
|
sgListCmd.Flags().String("cid", "", "Container ID")
|
||
|
|
_ = sgListCmd.MarkFlagRequired("cid")
|
||
|
|
}
|
||
|
|
|
||
|
|
func listSG(cmd *cobra.Command, _ []string) {
|
||
|
|
var cnr cid.ID
|
||
|
|
readCID(cmd, &cnr)
|
||
|
|
|
||
|
|
pk := key.GetOrGenerate(cmd)
|
||
|
|
|
||
|
|
var prm internalclient.SearchObjectsPrm
|
||
|
|
sessionCli.Prepare(cmd, cnr, nil, pk, &prm)
|
||
|
|
objectCli.Prepare(cmd, &prm)
|
||
|
|
prm.SetContainerID(cnr)
|
||
|
|
prm.SetFilters(storagegroup.SearchQuery())
|
||
|
|
|
||
|
|
res, err := internalclient.SearchObjects(prm)
|
||
|
|
common.ExitOnErr(cmd, "rpc error: %w", err)
|
||
|
|
|
||
|
|
ids := res.IDList()
|
||
|
|
|
||
|
|
cmd.Printf("Found %d storage groups.\n", len(ids))
|
||
|
|
|
||
|
|
for i := range ids {
|
||
|
|
cmd.Println(ids[i].String())
|
||
|
|
}
|
||
|
|
}
|