in api/om/bucket.go [23:48]
func (om *OmClient) CreateBucket(volume string, bucket string) error {
isVersionEnabled := false
storageType := ozone_proto.StorageTypeProto_DISK
bucketInfo := ozone_proto.BucketInfo{
BucketName: &bucket,
VolumeName: &volume,
IsVersionEnabled: &isVersionEnabled,
StorageType: &storageType,
}
req := ozone_proto.CreateBucketRequest{
BucketInfo: &bucketInfo,
}
cmdType := ozone_proto.Type_CreateBucket
wrapperRequest := ozone_proto.OMRequest{
CmdType: &cmdType,
CreateBucketRequest: &req,
ClientId: &om.clientId,
}
_, err := om.submitRequest(&wrapperRequest)
if err != nil {
return err
}
return nil
}