in api/om/om.go [161:183]
func (om *OmClient) ListKeysPrefix(volume string, bucket string, prefix string) ([]*ozone_proto.KeyInfo, error) {
req := ozone_proto.ListKeysRequest{
VolumeName: &volume,
BucketName: &bucket,
Prefix: ptr(prefix),
Count: ptri(1000),
}
listKeys := ozone_proto.Type_ListKeys
wrapperRequest := ozone_proto.OMRequest{
CmdType: &listKeys,
ListKeysRequest: &req,
ClientId: &om.clientId,
}
resp, err := om.submitRequest(&wrapperRequest)
if err != nil {
return nil, err
}
return resp.GetListKeysResponse().GetKeyInfo(), nil
}