in api/om/volume.go [23:48]
func (om *OmClient) ListVolumes() ([]common.Volume, error) {
scope := ozone_proto.ListVolumeRequest_VOLUMES_BY_USER
req := ozone_proto.ListVolumeRequest{
Scope: &scope,
UserName: ptr("hadoop"),
Prefix: ptr(""),
}
listKeys := ozone_proto.Type_ListVolume
clientId := "goClient"
wrapperRequest := ozone_proto.OMRequest{
CmdType: &listKeys,
ListVolumeRequest: &req,
ClientId: &clientId,
}
volumes := make([]common.Volume, 0)
resp, err := om.submitRequest(&wrapperRequest)
if err != nil {
return nil, err
}
for _, volProto := range resp.GetListVolumeResponse().GetVolumeInfo() {
volumes = append(volumes, common.Volume{Name: *volProto.Volume})
}
return volumes, nil
}