#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct LocalFileSource {
#[prost(string, tag = "1")]
pub filename: ::prost::alloc::string::String,
#[prost(enumeration = "FileFormat", tag = "2")]
pub file_format: i32,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GcsSource {
#[prost(string, tag = "1")]
pub input_uri: ::prost::alloc::string::String,
#[prost(enumeration = "FileFormat", tag = "2")]
pub file_format: i32,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum FileFormat {
Unspecified = 0,
Geojson = 1,
Kml = 2,
Csv = 3,
}
impl FileFormat {
pub fn as_str_name(&self) -> &'static str {
match self {
FileFormat::Unspecified => "FILE_FORMAT_UNSPECIFIED",
FileFormat::Geojson => "FILE_FORMAT_GEOJSON",
FileFormat::Kml => "FILE_FORMAT_KML",
FileFormat::Csv => "FILE_FORMAT_CSV",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"FILE_FORMAT_UNSPECIFIED" => Some(Self::Unspecified),
"FILE_FORMAT_GEOJSON" => Some(Self::Geojson),
"FILE_FORMAT_KML" => Some(Self::Kml),
"FILE_FORMAT_CSV" => Some(Self::Csv),
_ => None,
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Dataset {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
#[prost(string, tag = "2")]
pub display_name: ::prost::alloc::string::String,
#[prost(string, tag = "3")]
pub description: ::prost::alloc::string::String,
#[prost(string, tag = "4")]
pub version_id: ::prost::alloc::string::String,
#[prost(enumeration = "Usage", repeated, tag = "5")]
pub usage: ::prost::alloc::vec::Vec<i32>,
#[prost(message, optional, tag = "12")]
pub status: ::core::option::Option<Status>,
#[prost(message, optional, tag = "8")]
pub create_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "9")]
pub update_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(message, optional, tag = "10")]
pub version_create_time: ::core::option::Option<::prost_types::Timestamp>,
#[prost(string, tag = "11")]
pub version_description: ::prost::alloc::string::String,
#[prost(oneof = "dataset::DataSource", tags = "6, 7")]
pub data_source: ::core::option::Option<dataset::DataSource>,
}
pub mod dataset {
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Oneof)]
pub enum DataSource {
#[prost(message, tag = "6")]
LocalFileSource(super::LocalFileSource),
#[prost(message, tag = "7")]
GcsSource(super::GcsSource),
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct Status {
#[prost(enumeration = "status::State", tag = "1")]
pub state: i32,
#[prost(string, tag = "2")]
pub error_message: ::prost::alloc::string::String,
}
pub mod status {
#[derive(
Clone,
Copy,
Debug,
PartialEq,
Eq,
Hash,
PartialOrd,
Ord,
::prost::Enumeration
)]
#[repr(i32)]
pub enum State {
Unspecified = 0,
Importing = 1,
ImportSucceeded = 2,
ImportFailed = 3,
Deleting = 4,
DeletionFailed = 5,
Processing = 6,
ProcessingFailed = 7,
NeedsReview = 8,
Publishing = 9,
PublishingFailed = 10,
Completed = 11,
}
impl State {
pub fn as_str_name(&self) -> &'static str {
match self {
State::Unspecified => "STATE_UNSPECIFIED",
State::Importing => "STATE_IMPORTING",
State::ImportSucceeded => "STATE_IMPORT_SUCCEEDED",
State::ImportFailed => "STATE_IMPORT_FAILED",
State::Deleting => "STATE_DELETING",
State::DeletionFailed => "STATE_DELETION_FAILED",
State::Processing => "STATE_PROCESSING",
State::ProcessingFailed => "STATE_PROCESSING_FAILED",
State::NeedsReview => "STATE_NEEDS_REVIEW",
State::Publishing => "STATE_PUBLISHING",
State::PublishingFailed => "STATE_PUBLISHING_FAILED",
State::Completed => "STATE_COMPLETED",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"STATE_UNSPECIFIED" => Some(Self::Unspecified),
"STATE_IMPORTING" => Some(Self::Importing),
"STATE_IMPORT_SUCCEEDED" => Some(Self::ImportSucceeded),
"STATE_IMPORT_FAILED" => Some(Self::ImportFailed),
"STATE_DELETING" => Some(Self::Deleting),
"STATE_DELETION_FAILED" => Some(Self::DeletionFailed),
"STATE_PROCESSING" => Some(Self::Processing),
"STATE_PROCESSING_FAILED" => Some(Self::ProcessingFailed),
"STATE_NEEDS_REVIEW" => Some(Self::NeedsReview),
"STATE_PUBLISHING" => Some(Self::Publishing),
"STATE_PUBLISHING_FAILED" => Some(Self::PublishingFailed),
"STATE_COMPLETED" => Some(Self::Completed),
_ => None,
}
}
}
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
#[repr(i32)]
pub enum Usage {
Unspecified = 0,
DataDrivenStyling = 1,
}
impl Usage {
pub fn as_str_name(&self) -> &'static str {
match self {
Usage::Unspecified => "USAGE_UNSPECIFIED",
Usage::DataDrivenStyling => "USAGE_DATA_DRIVEN_STYLING",
}
}
pub fn from_str_name(value: &str) -> ::core::option::Option<Self> {
match value {
"USAGE_UNSPECIFIED" => Some(Self::Unspecified),
"USAGE_DATA_DRIVEN_STYLING" => Some(Self::DataDrivenStyling),
_ => None,
}
}
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct CreateDatasetRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(message, optional, tag = "2")]
pub dataset: ::core::option::Option<Dataset>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct UpdateDatasetMetadataRequest {
#[prost(message, optional, tag = "1")]
pub dataset: ::core::option::Option<Dataset>,
#[prost(message, optional, tag = "2")]
pub update_mask: ::core::option::Option<::prost_types::FieldMask>,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct GetDatasetRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListDatasetsRequest {
#[prost(string, tag = "1")]
pub parent: ::prost::alloc::string::String,
#[prost(int32, tag = "2")]
pub page_size: i32,
#[prost(string, tag = "3")]
pub page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct ListDatasetsResponse {
#[prost(message, repeated, tag = "1")]
pub datasets: ::prost::alloc::vec::Vec<Dataset>,
#[prost(string, tag = "2")]
pub next_page_token: ::prost::alloc::string::String,
}
#[allow(clippy::derive_partial_eq_without_eq)]
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct DeleteDatasetRequest {
#[prost(string, tag = "1")]
pub name: ::prost::alloc::string::String,
}
pub mod maps_platform_datasets_client {
#![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)]
use tonic::codegen::*;
use tonic::codegen::http::Uri;
#[derive(Debug, Clone)]
pub struct MapsPlatformDatasetsClient<T> {
inner: tonic::client::Grpc<T>,
}
impl<T> MapsPlatformDatasetsClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
{
pub fn new(inner: T) -> Self {
let inner = tonic::client::Grpc::new(inner);
Self { inner }
}
pub fn with_origin(inner: T, origin: Uri) -> Self {
let inner = tonic::client::Grpc::with_origin(inner, origin);
Self { inner }
}
pub fn with_interceptor<F>(
inner: T,
interceptor: F,
) -> MapsPlatformDatasetsClient<InterceptedService<T, F>>
where
F: tonic::service::Interceptor,
T::ResponseBody: Default,
T: tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
Response = http::Response<
<T as tonic::client::GrpcService<tonic::body::BoxBody>>::ResponseBody,
>,
>,
<T as tonic::codegen::Service<
http::Request<tonic::body::BoxBody>,
>>::Error: Into<StdError> + Send + Sync,
{
MapsPlatformDatasetsClient::new(InterceptedService::new(inner, interceptor))
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.send_compressed(encoding);
self
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.inner = self.inner.accept_compressed(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_decoding_message_size(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.inner = self.inner.max_encoding_message_size(limit);
self
}
pub async fn create_dataset(
&mut self,
request: impl tonic::IntoRequest<super::CreateDatasetRequest>,
) -> std::result::Result<tonic::Response<super::Dataset>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.maps.mapsplatformdatasets.v1.MapsPlatformDatasets/CreateDataset",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.maps.mapsplatformdatasets.v1.MapsPlatformDatasets",
"CreateDataset",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn update_dataset_metadata(
&mut self,
request: impl tonic::IntoRequest<super::UpdateDatasetMetadataRequest>,
) -> std::result::Result<tonic::Response<super::Dataset>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.maps.mapsplatformdatasets.v1.MapsPlatformDatasets/UpdateDatasetMetadata",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.maps.mapsplatformdatasets.v1.MapsPlatformDatasets",
"UpdateDatasetMetadata",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn get_dataset(
&mut self,
request: impl tonic::IntoRequest<super::GetDatasetRequest>,
) -> std::result::Result<tonic::Response<super::Dataset>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.maps.mapsplatformdatasets.v1.MapsPlatformDatasets/GetDataset",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.maps.mapsplatformdatasets.v1.MapsPlatformDatasets",
"GetDataset",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn list_datasets(
&mut self,
request: impl tonic::IntoRequest<super::ListDatasetsRequest>,
) -> std::result::Result<
tonic::Response<super::ListDatasetsResponse>,
tonic::Status,
> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.maps.mapsplatformdatasets.v1.MapsPlatformDatasets/ListDatasets",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.maps.mapsplatformdatasets.v1.MapsPlatformDatasets",
"ListDatasets",
),
);
self.inner.unary(req, path, codec).await
}
pub async fn delete_dataset(
&mut self,
request: impl tonic::IntoRequest<super::DeleteDatasetRequest>,
) -> std::result::Result<tonic::Response<()>, tonic::Status> {
self.inner
.ready()
.await
.map_err(|e| {
tonic::Status::new(
tonic::Code::Unknown,
format!("Service was not ready: {}", e.into()),
)
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/google.maps.mapsplatformdatasets.v1.MapsPlatformDatasets/DeleteDataset",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(
GrpcMethod::new(
"google.maps.mapsplatformdatasets.v1.MapsPlatformDatasets",
"DeleteDataset",
),
);
self.inner.unary(req, path, codec).await
}
}
}