in api/om/volume.go [50:75]
func (om *OmClient) CreateVolume(name string) error {
onegig := uint64(1024 * 1024 * 1024)
volumeInfo := ozone_proto.VolumeInfo{
AdminName: ptr("hadoop"),
OwnerName: ptr("hadoop"),
Volume: ptr(name),
QuotaInBytes: &onegig,
}
req := ozone_proto.CreateVolumeRequest{
VolumeInfo: &volumeInfo,
}
cmdType := ozone_proto.Type_CreateVolume
clientId := "goClient"
wrapperRequest := ozone_proto.OMRequest{
CmdType: &cmdType,
CreateVolumeRequest: &req,
ClientId: &clientId,
}
_, err := om.submitRequest(&wrapperRequest)
if err != nil {
return err
}
return nil
}