summaryrefslogtreecommitdiff
path: root/clawflake.rs
diff options
context:
space:
mode:
Diffstat (limited to 'clawflake.rs')
-rw-r--r--clawflake.rs83
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
+ }
+ }
+}