func()

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
}