func()

in api/om/volume.go [23:48]


func (om *OmClient) ListVolumes() ([]common.Volume, error) {
	scope := ozone_proto.ListVolumeRequest_VOLUMES_BY_USER
	req := ozone_proto.ListVolumeRequest{
		Scope:    &scope,
		UserName: ptr("hadoop"),
		Prefix:   ptr(""),
	}

	listKeys := ozone_proto.Type_ListVolume
	clientId := "goClient"
	wrapperRequest := ozone_proto.OMRequest{
		CmdType:           &listKeys,
		ListVolumeRequest: &req,
		ClientId:          &clientId,
	}

	volumes := make([]common.Volume, 0)
	resp, err := om.submitRequest(&wrapperRequest)
	if err != nil {
		return nil, err
	}
	for _, volProto := range resp.GetListVolumeResponse().GetVolumeInfo() {
		volumes = append(volumes, common.Volume{Name: *volProto.Volume})
	}
	return volumes, nil
}