diff options
Diffstat (limited to 'clawflake.rs')
| -rw-r--r-- | clawflake.rs | 83 |
1 files changed, 83 insertions, 0 deletions
diff --git a/clawflake.rs b/clawflake.rs new file mode 100644 index 0000000..c3c894b --- /dev/null +++ b/clawflake.rs @@ -0,0 +1,83 @@ +#[derive(Clone, PartialEq, ::prost::Message)] +pub struct IdRequest {} +#[derive(Clone, PartialEq, ::prost::Message)] +pub struct IdReply { + #[prost(string, tag = "1")] + pub id: ::prost::alloc::string::String, +} +#[doc = r" Generated client implementations."] +pub mod clawflake_client { + #![allow(unused_variables, dead_code, missing_docs, clippy::let_unit_value)] + use tonic::codegen::*; + #[derive(Debug, Clone)] + pub struct ClawflakeClient<T> { + inner: tonic::client::Grpc<T>, + } + impl ClawflakeClient<tonic::transport::Channel> { + #[doc = r" Attempt to create a new client by connecting to a given endpoint."] + pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error> + where + D: std::convert::TryInto<tonic::transport::Endpoint>, + D::Error: Into<StdError>, + { + let conn = tonic::transport::Endpoint::new(dst)?.connect().await?; + Ok(Self::new(conn)) + } + } + impl<T> ClawflakeClient<T> + where + T: tonic::client::GrpcService<tonic::body::BoxBody>, + T::ResponseBody: Body + Send + Sync + 'static, + T::Error: Into<StdError>, + <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_interceptor<F>( + inner: T, + interceptor: F, + ) -> ClawflakeClient<InterceptedService<T, F>> + where + F: FnMut(tonic::Request<()>) -> Result<tonic::Request<()>, tonic::Status>, + 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, + { + ClawflakeClient::new(InterceptedService::new(inner, interceptor)) + } + #[doc = r" Compress requests with `gzip`."] + #[doc = r""] + #[doc = r" This requires the server to support it otherwise it might respond with an"] + #[doc = r" error."] + pub fn send_gzip(mut self) -> Self { + self.inner = self.inner.send_gzip(); + self + } + #[doc = r" Enable decompressing responses with `gzip`."] + pub fn accept_gzip(mut self) -> Self { + self.inner = self.inner.accept_gzip(); + self + } + pub async fn get_id( + &mut self, + request: impl tonic::IntoRequest<super::IdRequest>, + ) -> Result<tonic::Response<super::IdReply>, 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("/clawflake.Clawflake/GetID"); + self.inner.unary(request.into_request(), path, codec).await + } + } +} |
