func()

in api/om/bucket.go [74:102]


func (om *OmClient) ListBucket(volume string) ([]common.Bucket, error) {
	res := make([]common.Bucket, 0)

	req := ozone_proto.ListBucketsRequest{
		VolumeName: &volume,
		StartKey:   ptr(""),
		Count:      ptri(100),
	}

	cmdType := ozone_proto.Type_ListBuckets
	wrapperRequest := ozone_proto.OMRequest{
		CmdType:            &cmdType,
		ListBucketsRequest: &req,
		ClientId:           &om.clientId,
	}

	resp, err := om.submitRequest(&wrapperRequest)
	if err != nil {
		return res, err
	}
	for _, b := range resp.ListBucketsResponse.BucketInfo {
		cb := common.Bucket{
			Name:       *b.BucketName,
			VolumeName: *b.VolumeName,
		}
		res = append(res, cb)
	}
	return res, nil
}