pub mod prover_network_client {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value
)]
use tonic::codegen::http::Uri;
use tonic::codegen::*;
#[derive(Debug, Clone)]
pub struct ProverNetworkClient<T> {
inner: tonic::client::Grpc<T>,
}
impl ProverNetworkClient<tonic::transport::Channel> {
pub async fn connect<D>(dst: D) -> Result<Self, tonic::transport::Error>
where
D: TryInto<tonic::transport::Endpoint>,
D::Error: Into<StdError>,
{
let conn = tonic::transport::Endpoint::new(dst)?.connect().await?;
Ok(Self::new(conn))
}
}
impl<T> ProverNetworkClient<T>
where
T: tonic::client::GrpcService<tonic::body::BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + std::marker::Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + std::marker::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,
) -> ProverNetworkClient<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> + std::marker::Send + std::marker::Sync,
{
ProverNetworkClient::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 request_proof(
&mut self,
request: impl tonic::IntoRequest<super::super::types::RequestProofRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::RequestProofResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/RequestProof");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "RequestProof"));
self.inner.unary(req, path, codec).await
}
pub async fn fulfill_proof(
&mut self,
request: impl tonic::IntoRequest<super::super::types::FulfillProofRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::FulfillProofResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/FulfillProof");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "FulfillProof"));
self.inner.unary(req, path, codec).await
}
pub async fn execute_proof(
&mut self,
request: impl tonic::IntoRequest<super::super::types::ExecuteProofRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::ExecuteProofResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/ExecuteProof");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "ExecuteProof"));
self.inner.unary(req, path, codec).await
}
pub async fn fail_fulfillment(
&mut self,
request: impl tonic::IntoRequest<super::super::types::FailFulfillmentRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::FailFulfillmentResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/FailFulfillment");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "FailFulfillment"));
self.inner.unary(req, path, codec).await
}
pub async fn cancel_request(
&mut self,
request: impl tonic::IntoRequest<super::super::types::CancelRequestRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::CancelRequestResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/CancelRequest");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "CancelRequest"));
self.inner.unary(req, path, codec).await
}
pub async fn get_proof_request_status(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProofRequestStatusRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProofRequestStatusResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetProofRequestStatus",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetProofRequestStatus"));
self.inner.unary(req, path, codec).await
}
pub async fn get_proof_request_details(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProofRequestDetailsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProofRequestDetailsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetProofRequestDetails",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetProofRequestDetails"));
self.inner.unary(req, path, codec).await
}
pub async fn get_stdin_uri(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetStdinUriRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetStdinUriResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetStdinUri");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "GetStdinUri"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_proof_requests(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetFilteredProofRequestsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredProofRequestsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredProofRequests",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetFilteredProofRequests"));
self.inner.unary(req, path, codec).await
}
pub async fn subscribe_proof_requests(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetFilteredProofRequestsRequest>,
) -> std::result::Result<
tonic::Response<tonic::codec::Streaming<super::super::types::ProofRequest>>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/SubscribeProofRequests",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "SubscribeProofRequests"));
self.inner.server_streaming(req, path, codec).await
}
pub async fn get_search_results(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetSearchResultsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetSearchResultsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetSearchResults");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetSearchResults"));
self.inner.unary(req, path, codec).await
}
pub async fn get_proof_request_metrics(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProofRequestMetricsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProofRequestMetricsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetProofRequestMetrics",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetProofRequestMetrics"));
self.inner.unary(req, path, codec).await
}
pub async fn get_proof_request_graph(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProofRequestGraphRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProofRequestGraphResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetProofRequestGraph");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetProofRequestGraph"));
self.inner.unary(req, path, codec).await
}
pub async fn get_analytics_graphs(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetAnalyticsGraphsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetAnalyticsGraphsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetAnalyticsGraphs");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetAnalyticsGraphs"));
self.inner.unary(req, path, codec).await
}
pub async fn get_overview_graphs(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetOverviewGraphsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetOverviewGraphsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetOverviewGraphs");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetOverviewGraphs"));
self.inner.unary(req, path, codec).await
}
pub async fn get_proof_request_params(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProofRequestParamsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProofRequestParamsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetProofRequestParams",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetProofRequestParams"));
self.inner.unary(req, path, codec).await
}
pub async fn get_nonce(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetNonceRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetNonceResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetNonce");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "GetNonce"));
self.inner.unary(req, path, codec).await
}
pub async fn set_account_name(
&mut self,
request: impl tonic::IntoRequest<super::super::types::SetAccountNameRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetAccountNameResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/SetAccountName");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "SetAccountName"));
self.inner.unary(req, path, codec).await
}
pub async fn get_account_name(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetAccountNameRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetAccountNameResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetAccountName");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "GetAccountName"));
self.inner.unary(req, path, codec).await
}
pub async fn get_terms_signature(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTermsSignatureRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTermsSignatureResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetTermsSignature");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTermsSignature"));
self.inner.unary(req, path, codec).await
}
pub async fn set_terms_signature(
&mut self,
request: impl tonic::IntoRequest<super::super::types::SetTermsSignatureRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetTermsSignatureResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/SetTermsSignature");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "SetTermsSignature"));
self.inner.unary(req, path, codec).await
}
pub async fn get_account(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetAccountRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetAccountResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetAccount");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "GetAccount"));
self.inner.unary(req, path, codec).await
}
pub async fn get_owner(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetOwnerRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetOwnerResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetOwner");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "GetOwner"));
self.inner.unary(req, path, codec).await
}
pub async fn get_program(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProgramRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProgramResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetProgram");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "GetProgram"));
self.inner.unary(req, path, codec).await
}
pub async fn create_program(
&mut self,
request: impl tonic::IntoRequest<super::super::types::CreateProgramRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::CreateProgramResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/CreateProgram");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "CreateProgram"));
self.inner.unary(req, path, codec).await
}
pub async fn set_program_name(
&mut self,
request: impl tonic::IntoRequest<super::super::types::SetProgramNameRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetProgramNameResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/SetProgramName");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "SetProgramName"));
self.inner.unary(req, path, codec).await
}
pub async fn get_balance(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetBalanceRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetBalanceResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetBalance");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "GetBalance"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_balance_logs(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetFilteredBalanceLogsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredBalanceLogsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredBalanceLogs",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetFilteredBalanceLogs"));
self.inner.unary(req, path, codec).await
}
pub async fn get_latest_bridge_block(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetLatestBridgeBlockRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetLatestBridgeBlockResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetLatestBridgeBlock");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetLatestBridgeBlock"));
self.inner.unary(req, path, codec).await
}
pub async fn get_gas_price_estimate(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetGasPriceEstimateRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetGasPriceEstimateResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetGasPriceEstimate");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetGasPriceEstimate"));
self.inner.unary(req, path, codec).await
}
pub async fn get_transaction_details(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTransactionDetailsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTransactionDetailsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetTransactionDetails",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTransactionDetails"));
self.inner.unary(req, path, codec).await
}
pub async fn transfer(
&mut self,
request: impl tonic::IntoRequest<super::super::types::TransferRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::TransferResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/Transfer");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "Transfer"));
self.inner.unary(req, path, codec).await
}
pub async fn get_transfer_params(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTransferParamsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTransferParamsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetTransferParams");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTransferParams"));
self.inner.unary(req, path, codec).await
}
pub async fn get_withdraw_params(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetWithdrawParamsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetWithdrawParamsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetWithdrawParams");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetWithdrawParams"));
self.inner.unary(req, path, codec).await
}
pub async fn withdraw(
&mut self,
request: impl tonic::IntoRequest<super::super::types::WithdrawRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::WithdrawResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/Withdraw");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "Withdraw"));
self.inner.unary(req, path, codec).await
}
pub async fn get_prove_price(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProvePriceRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProvePriceResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetProvePrice");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "GetProvePrice"));
self.inner.unary(req, path, codec).await
}
pub async fn get_price_info(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetPriceInfoRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetPriceInfoResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetPriceInfo");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "GetPriceInfo"));
self.inner.unary(req, path, codec).await
}
pub async fn bid(
&mut self,
request: impl tonic::IntoRequest<super::super::types::BidRequest>,
) -> std::result::Result<tonic::Response<super::super::types::BidResponse>, tonic::Status>
{
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/Bid");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "Bid"));
self.inner.unary(req, path, codec).await
}
pub async fn settle(
&mut self,
request: impl tonic::IntoRequest<super::super::types::SettleRequest>,
) -> std::result::Result<tonic::Response<super::super::types::SettleResponse>, tonic::Status>
{
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/Settle");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "Settle"));
self.inner.unary(req, path, codec).await
}
pub async fn get_provers_by_uptime(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProversByUptimeRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProversByUptimeResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetProversByUptime");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetProversByUptime"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_settleable_requests(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetFilteredSettleableRequestsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredSettleableRequestsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredSettleableRequests",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetFilteredSettleableRequests"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_suspendable_provers(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetFilteredSuspendableProversRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredSuspendableProversResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredSuspendableProvers",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetFilteredSuspendableProvers"));
self.inner.unary(req, path, codec).await
}
pub async fn suspend_prover(
&mut self,
request: impl tonic::IntoRequest<super::super::types::SuspendProverRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SuspendProverResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/SuspendProver");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "SuspendProver"));
self.inner.unary(req, path, codec).await
}
pub async fn sign_in(
&mut self,
request: impl tonic::IntoRequest<super::super::types::SignInRequest>,
) -> std::result::Result<tonic::Response<super::super::types::SignInResponse>, tonic::Status>
{
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/SignIn");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "SignIn"));
self.inner.unary(req, path, codec).await
}
pub async fn connect_twitter(
&mut self,
request: impl tonic::IntoRequest<super::super::types::ConnectTwitterRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::ConnectTwitterResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/ConnectTwitter");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "ConnectTwitter"));
self.inner.unary(req, path, codec).await
}
pub async fn get_prover_stats(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProverStatsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProverStatsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetProverStats");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "GetProverStats"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_prover_stats(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetFilteredProverStatsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredProverStatsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredProverStats",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetFilteredProverStats"));
self.inner.unary(req, path, codec).await
}
pub async fn get_prover_stats_detail(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProverStatsDetailRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProverStatsDetailResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetProverStatsDetail");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetProverStatsDetail"));
self.inner.unary(req, path, codec).await
}
pub async fn get_prover_search_results(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProverSearchResultsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProverSearchResultsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetProverSearchResults",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetProverSearchResults"));
self.inner.unary(req, path, codec).await
}
pub async fn get_staking_prover_search(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetStakingProverSearchRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetStakingProverSearchResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetStakingProverSearch",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetStakingProverSearch"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_bid_history(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetFilteredBidHistoryRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredBidHistoryResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredBidHistory",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetFilteredBidHistory"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_prover_bid_history(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetFilteredProverBidHistoryRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredProverBidHistoryResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredProverBidHistory",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetFilteredProverBidHistory"));
self.inner.unary(req, path, codec).await
}
pub async fn update_staker_fee(
&mut self,
request: impl tonic::IntoRequest<super::super::types::UpdateStakerFeeRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::UpdateStakerFeeResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/UpdateStakerFee");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "UpdateStakerFee"));
self.inner.unary(req, path, codec).await
}
pub async fn get_staker_fee_update_time(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetStakerFeeUpdateTimeRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetStakerFeeUpdateTimeResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetStakerFeeUpdateTime",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetStakerFeeUpdateTime"));
self.inner.unary(req, path, codec).await
}
pub async fn get_update_staker_fee_params(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetUpdateStakerFeeParamsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetUpdateStakerFeeParamsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetUpdateStakerFeeParams",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetUpdateStakerFeeParams"));
self.inner.unary(req, path, codec).await
}
pub async fn update_delegator_fee(
&mut self,
request: impl tonic::IntoRequest<super::super::types::UpdateDelegatorFeeRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::UpdateDelegatorFeeResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/UpdateDelegatorFee");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "UpdateDelegatorFee"));
self.inner.unary(req, path, codec).await
}
pub async fn get_tee_whitelist_status(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTeeWhitelistStatusRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTeeWhitelistStatusResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetTEEWhitelistStatus",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTEEWhitelistStatus"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_provers(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetFilteredProversRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredProversResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetFilteredProvers");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetFilteredProvers"));
self.inner.unary(req, path, codec).await
}
pub async fn get_prover_stake_balance(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProverStakeBalanceRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProverStakeBalanceResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetProverStakeBalance",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetProverStakeBalance"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_staker_stake_balance_logs(
&mut self,
request: impl tonic::IntoRequest<
super::super::types::GetFilteredStakerStakeBalanceLogsRequest,
>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredStakerStakeBalanceLogsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredStakerStakeBalanceLogs",
);
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new(
"network.ProverNetwork",
"GetFilteredStakerStakeBalanceLogs",
));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_prover_stake_balance_logs(
&mut self,
request: impl tonic::IntoRequest<
super::super::types::GetFilteredProverStakeBalanceLogsRequest,
>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredProverStakeBalanceLogsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredProverStakeBalanceLogs",
);
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new(
"network.ProverNetwork",
"GetFilteredProverStakeBalanceLogs",
));
self.inner.unary(req, path, codec).await
}
pub async fn get_staking_points(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetStakingPointsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetStakingPointsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetStakingPoints");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetStakingPoints"));
self.inner.unary(req, path, codec).await
}
pub async fn get_network_filtered_staker_leaderboard(
&mut self,
request: impl tonic::IntoRequest<
super::super::types::GetNetworkFilteredStakerLeaderboardRequest,
>,
) -> std::result::Result<
tonic::Response<super::super::types::GetNetworkFilteredStakerLeaderboardResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetNetworkFilteredStakerLeaderboard",
);
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new(
"network.ProverNetwork",
"GetNetworkFilteredStakerLeaderboard",
));
self.inner.unary(req, path, codec).await
}
pub async fn get_network_staker_leaderboard_dashboard(
&mut self,
request: impl tonic::IntoRequest<
super::super::types::GetNetworkStakerLeaderboardDashboardRequest,
>,
) -> std::result::Result<
tonic::Response<super::super::types::GetNetworkStakerLeaderboardDashboardResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetNetworkStakerLeaderboardDashboard",
);
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new(
"network.ProverNetwork",
"GetNetworkStakerLeaderboardDashboard",
));
self.inner.unary(req, path, codec).await
}
pub async fn get_delegation_params(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetDelegationParamsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetDelegationParamsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetDelegationParams");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetDelegationParams"));
self.inner.unary(req, path, codec).await
}
pub async fn get_titan_config_params(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTitanConfigParamsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitanConfigParamsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetTitanConfigParams");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTitanConfigParams"));
self.inner.unary(req, path, codec).await
}
pub async fn set_delegation(
&mut self,
request: impl tonic::IntoRequest<super::super::types::SetDelegationRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetDelegationResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/SetDelegation");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "SetDelegation"));
self.inner.unary(req, path, codec).await
}
pub async fn get_delegation(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetDelegationRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetDelegationResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetDelegation");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "GetDelegation"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_withdrawal_receipts(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetFilteredWithdrawalReceiptsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredWithdrawalReceiptsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredWithdrawalReceipts",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetFilteredWithdrawalReceipts"));
self.inner.unary(req, path, codec).await
}
pub async fn get_epoch(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetEpochRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetEpochResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetEpoch");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "GetEpoch"));
self.inner.unary(req, path, codec).await
}
pub async fn get_prover_work(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProverWorkRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProverWorkResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetProverWork");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "GetProverWork"));
self.inner.unary(req, path, codec).await
}
pub async fn get_provers_with_work(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProversWithWorkRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProversWithWorkResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetProversWithWork");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetProversWithWork"));
self.inner.unary(req, path, codec).await
}
pub async fn get_rewards_dashboard(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetRewardsDashboardRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetRewardsDashboardResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetRewardsDashboard");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetRewardsDashboard"));
self.inner.unary(req, path, codec).await
}
pub async fn get_recent_rewards_graph(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetRecentRewardsGraphRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetRecentRewardsGraphResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetRecentRewardsGraph",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetRecentRewardsGraph"));
self.inner.unary(req, path, codec).await
}
pub async fn get_recent_performance_graph(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetRecentPerformanceGraphRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetRecentPerformanceGraphResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetRecentPerformanceGraph",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetRecentPerformanceGraph"));
self.inner.unary(req, path, codec).await
}
pub async fn get_titan1_whitelist_allocation(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTitan1WhitelistAllocationRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1WhitelistAllocationResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetTitan1WhitelistAllocation",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTitan1WhitelistAllocation"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_titan1_nfts(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetFilteredTitan1NftsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredTitan1NftsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredTitan1Nfts",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetFilteredTitan1Nfts"));
self.inner.unary(req, path, codec).await
}
pub async fn set_titan1_delegation(
&mut self,
request: impl tonic::IntoRequest<super::super::types::SetTitan1DelegationRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetTitan1DelegationResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/SetTitan1Delegation");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "SetTitan1Delegation"));
self.inner.unary(req, path, codec).await
}
pub async fn set_titan1_delegation_limit(
&mut self,
request: impl tonic::IntoRequest<super::super::types::SetTitan1DelegationLimitRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetTitan1DelegationLimitResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/SetTitan1DelegationLimit",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "SetTitan1DelegationLimit"));
self.inner.unary(req, path, codec).await
}
pub async fn set_titan1_auto_accept(
&mut self,
request: impl tonic::IntoRequest<super::super::types::SetTitan1AutoAcceptRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetTitan1AutoAcceptResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/SetTitan1AutoAccept");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "SetTitan1AutoAccept"));
self.inner.unary(req, path, codec).await
}
pub async fn get_titan1_delegation_settings(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTitan1DelegationSettingsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1DelegationSettingsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetTitan1DelegationSettings",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTitan1DelegationSettings"));
self.inner.unary(req, path, codec).await
}
pub async fn set_titan1_delegation_settings(
&mut self,
request: impl tonic::IntoRequest<super::super::types::SetTitan1DelegationSettingsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetTitan1DelegationSettingsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/SetTitan1DelegationSettings",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "SetTitan1DelegationSettings"));
self.inner.unary(req, path, codec).await
}
pub async fn get_titan1_recent_sales(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTitan1RecentSalesRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1RecentSalesResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetTitan1RecentSales");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTitan1RecentSales"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_titan1_delegates(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetFilteredTitan1DelegatesRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredTitan1DelegatesResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredTitan1Delegates",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetFilteredTitan1Delegates"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_titan1_delegate_requests(
&mut self,
request: impl tonic::IntoRequest<
super::super::types::GetFilteredTitan1DelegateRequestsRequest,
>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredTitan1DelegateRequestsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredTitan1DelegateRequests",
);
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new(
"network.ProverNetwork",
"GetFilteredTitan1DelegateRequests",
));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_titan1_delegate_removals(
&mut self,
request: impl tonic::IntoRequest<
super::super::types::GetFilteredTitan1DelegateRemovalsRequest,
>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredTitan1DelegateRemovalsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredTitan1DelegateRemovals",
);
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new(
"network.ProverNetwork",
"GetFilteredTitan1DelegateRemovals",
));
self.inner.unary(req, path, codec).await
}
pub async fn get_titan1_recent_activity(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTitan1RecentActivityRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1RecentActivityResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetTitan1RecentActivity",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTitan1RecentActivity"));
self.inner.unary(req, path, codec).await
}
pub async fn accept_titan1_delegates(
&mut self,
request: impl tonic::IntoRequest<super::super::types::AcceptTitan1DelegatesRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::AcceptTitan1DelegatesResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/AcceptTitan1Delegates",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "AcceptTitan1Delegates"));
self.inner.unary(req, path, codec).await
}
pub async fn reject_titan1_delegates(
&mut self,
request: impl tonic::IntoRequest<super::super::types::RejectTitan1DelegatesRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::RejectTitan1DelegatesResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/RejectTitan1Delegates",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "RejectTitan1Delegates"));
self.inner.unary(req, path, codec).await
}
pub async fn remove_titan1_delegates(
&mut self,
request: impl tonic::IntoRequest<super::super::types::RemoveTitan1DelegatesRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::RemoveTitan1DelegatesResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/RemoveTitan1Delegates",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "RemoveTitan1Delegates"));
self.inner.unary(req, path, codec).await
}
pub async fn check_titan_whitelist(
&mut self,
request: impl tonic::IntoRequest<super::super::types::CheckTitanWhitelistRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::CheckTitanWhitelistResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/CheckTitanWhitelist");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "CheckTitanWhitelist"));
self.inner.unary(req, path, codec).await
}
pub async fn get_titan_whitelist_details(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTitanWhitelistDetailsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitanWhitelistDetailsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetTitanWhitelistDetails",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTitanWhitelistDetails"));
self.inner.unary(req, path, codec).await
}
pub async fn join_titan_queue(
&mut self,
request: impl tonic::IntoRequest<super::super::types::JoinTitanQueueRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::JoinTitanQueueResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/JoinTitanQueue");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "JoinTitanQueue"));
self.inner.unary(req, path, codec).await
}
pub async fn claim_titan_whitelist_spot(
&mut self,
request: impl tonic::IntoRequest<super::super::types::ClaimTitanWhitelistSpotRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::ClaimTitanWhitelistSpotResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/ClaimTitanWhitelistSpot",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "ClaimTitanWhitelistSpot"));
self.inner.unary(req, path, codec).await
}
pub async fn claim_titan_whitelist_spot_by_address(
&mut self,
request: impl tonic::IntoRequest<
super::super::types::ClaimTitanWhitelistSpotByAddressRequest,
>,
) -> std::result::Result<
tonic::Response<super::super::types::ClaimTitanWhitelistSpotByAddressResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/ClaimTitanWhitelistSpotByAddress",
);
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new(
"network.ProverNetwork",
"ClaimTitanWhitelistSpotByAddress",
));
self.inner.unary(req, path, codec).await
}
pub async fn get_prover_delegated_slot_balance(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProverDelegatedSlotBalanceRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProverDelegatedSlotBalanceResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetProverDelegatedSlotBalance",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetProverDelegatedSlotBalance"));
self.inner.unary(req, path, codec).await
}
pub async fn get_slot_delegation_details(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetSlotDelegationDetailsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetSlotDelegationDetailsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetSlotDelegationDetails",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetSlotDelegationDetails"));
self.inner.unary(req, path, codec).await
}
pub async fn get_titan1_delegation_limit(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTitan1DelegationLimitRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1DelegationLimitResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetTitan1DelegationLimit",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTitan1DelegationLimit"));
self.inner.unary(req, path, codec).await
}
pub async fn add_ref_visit(
&mut self,
request: impl tonic::IntoRequest<super::super::types::AddRefVisitRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::AddRefVisitResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static("/network.ProverNetwork/AddRefVisit");
let mut req = request.into_request();
req.extensions_mut().insert(GrpcMethod::new("network.ProverNetwork", "AddRefVisit"));
self.inner.unary(req, path, codec).await
}
pub async fn get_prover_delegate_request_count(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetProverDelegateRequestCountRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProverDelegateRequestCountResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetProverDelegateRequestCount",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetProverDelegateRequestCount"));
self.inner.unary(req, path, codec).await
}
pub async fn get_titan_cloud_provers(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTitanCloudProversRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitanCloudProversResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetTitanCloudProvers");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTitanCloudProvers"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_titan1_ids(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetFilteredTitan1IdsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredTitan1IdsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetFilteredTitan1Ids");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetFilteredTitan1Ids"));
self.inner.unary(req, path, codec).await
}
pub async fn get_filtered_titan1_slots(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetFilteredTitan1SlotsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredTitan1SlotsResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path = http::uri::PathAndQuery::from_static(
"/network.ProverNetwork/GetFilteredTitan1Slots",
);
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetFilteredTitan1Slots"));
self.inner.unary(req, path, codec).await
}
pub async fn get_titan1_rewards_data(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTitan1RewardsDataRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1RewardsDataResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetTitan1RewardsData");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTitan1RewardsData"));
self.inner.unary(req, path, codec).await
}
pub async fn get_titan1_work_graph(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTitan1WorkGraphRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1WorkGraphResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetTitan1WorkGraph");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTitan1WorkGraph"));
self.inner.unary(req, path, codec).await
}
pub async fn get_titan1_claim_proof(
&mut self,
request: impl tonic::IntoRequest<super::super::types::GetTitan1ClaimProofRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1ClaimProofResponse>,
tonic::Status,
> {
self.inner.ready().await.map_err(|e| {
tonic::Status::unknown(format!("Service was not ready: {}", e.into()))
})?;
let codec = tonic::codec::ProstCodec::default();
let path =
http::uri::PathAndQuery::from_static("/network.ProverNetwork/GetTitan1ClaimProof");
let mut req = request.into_request();
req.extensions_mut()
.insert(GrpcMethod::new("network.ProverNetwork", "GetTitan1ClaimProof"));
self.inner.unary(req, path, codec).await
}
}
}
pub mod prover_network_server {
#![allow(
unused_variables,
dead_code,
missing_docs,
clippy::wildcard_imports,
clippy::let_unit_value
)]
use tonic::codegen::*;
#[async_trait]
pub trait ProverNetwork: std::marker::Send + std::marker::Sync + 'static {
async fn request_proof(
&self,
request: tonic::Request<super::super::types::RequestProofRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::RequestProofResponse>,
tonic::Status,
>;
async fn fulfill_proof(
&self,
request: tonic::Request<super::super::types::FulfillProofRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::FulfillProofResponse>,
tonic::Status,
>;
async fn execute_proof(
&self,
request: tonic::Request<super::super::types::ExecuteProofRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::ExecuteProofResponse>,
tonic::Status,
>;
async fn fail_fulfillment(
&self,
request: tonic::Request<super::super::types::FailFulfillmentRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::FailFulfillmentResponse>,
tonic::Status,
>;
async fn cancel_request(
&self,
request: tonic::Request<super::super::types::CancelRequestRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::CancelRequestResponse>,
tonic::Status,
>;
async fn get_proof_request_status(
&self,
request: tonic::Request<super::super::types::GetProofRequestStatusRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProofRequestStatusResponse>,
tonic::Status,
>;
async fn get_proof_request_details(
&self,
request: tonic::Request<super::super::types::GetProofRequestDetailsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProofRequestDetailsResponse>,
tonic::Status,
>;
async fn get_stdin_uri(
&self,
request: tonic::Request<super::super::types::GetStdinUriRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetStdinUriResponse>,
tonic::Status,
>;
async fn get_filtered_proof_requests(
&self,
request: tonic::Request<super::super::types::GetFilteredProofRequestsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredProofRequestsResponse>,
tonic::Status,
>;
type SubscribeProofRequestsStream: tonic::codegen::tokio_stream::Stream<
Item = std::result::Result<super::super::types::ProofRequest, tonic::Status>,
> + std::marker::Send
+ 'static;
async fn subscribe_proof_requests(
&self,
request: tonic::Request<super::super::types::GetFilteredProofRequestsRequest>,
) -> std::result::Result<tonic::Response<Self::SubscribeProofRequestsStream>, tonic::Status>;
async fn get_search_results(
&self,
request: tonic::Request<super::super::types::GetSearchResultsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetSearchResultsResponse>,
tonic::Status,
>;
async fn get_proof_request_metrics(
&self,
request: tonic::Request<super::super::types::GetProofRequestMetricsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProofRequestMetricsResponse>,
tonic::Status,
>;
async fn get_proof_request_graph(
&self,
request: tonic::Request<super::super::types::GetProofRequestGraphRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProofRequestGraphResponse>,
tonic::Status,
>;
async fn get_analytics_graphs(
&self,
request: tonic::Request<super::super::types::GetAnalyticsGraphsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetAnalyticsGraphsResponse>,
tonic::Status,
>;
async fn get_overview_graphs(
&self,
request: tonic::Request<super::super::types::GetOverviewGraphsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetOverviewGraphsResponse>,
tonic::Status,
>;
async fn get_proof_request_params(
&self,
request: tonic::Request<super::super::types::GetProofRequestParamsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProofRequestParamsResponse>,
tonic::Status,
>;
async fn get_nonce(
&self,
request: tonic::Request<super::super::types::GetNonceRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetNonceResponse>,
tonic::Status,
>;
async fn set_account_name(
&self,
request: tonic::Request<super::super::types::SetAccountNameRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetAccountNameResponse>,
tonic::Status,
>;
async fn get_account_name(
&self,
request: tonic::Request<super::super::types::GetAccountNameRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetAccountNameResponse>,
tonic::Status,
>;
async fn get_terms_signature(
&self,
request: tonic::Request<super::super::types::GetTermsSignatureRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTermsSignatureResponse>,
tonic::Status,
>;
async fn set_terms_signature(
&self,
request: tonic::Request<super::super::types::SetTermsSignatureRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetTermsSignatureResponse>,
tonic::Status,
>;
async fn get_account(
&self,
request: tonic::Request<super::super::types::GetAccountRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetAccountResponse>,
tonic::Status,
>;
async fn get_owner(
&self,
request: tonic::Request<super::super::types::GetOwnerRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetOwnerResponse>,
tonic::Status,
>;
async fn get_program(
&self,
request: tonic::Request<super::super::types::GetProgramRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProgramResponse>,
tonic::Status,
>;
async fn create_program(
&self,
request: tonic::Request<super::super::types::CreateProgramRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::CreateProgramResponse>,
tonic::Status,
>;
async fn set_program_name(
&self,
request: tonic::Request<super::super::types::SetProgramNameRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetProgramNameResponse>,
tonic::Status,
>;
async fn get_balance(
&self,
request: tonic::Request<super::super::types::GetBalanceRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetBalanceResponse>,
tonic::Status,
>;
async fn get_filtered_balance_logs(
&self,
request: tonic::Request<super::super::types::GetFilteredBalanceLogsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredBalanceLogsResponse>,
tonic::Status,
>;
async fn get_latest_bridge_block(
&self,
request: tonic::Request<super::super::types::GetLatestBridgeBlockRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetLatestBridgeBlockResponse>,
tonic::Status,
>;
async fn get_gas_price_estimate(
&self,
request: tonic::Request<super::super::types::GetGasPriceEstimateRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetGasPriceEstimateResponse>,
tonic::Status,
>;
async fn get_transaction_details(
&self,
request: tonic::Request<super::super::types::GetTransactionDetailsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTransactionDetailsResponse>,
tonic::Status,
>;
async fn transfer(
&self,
request: tonic::Request<super::super::types::TransferRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::TransferResponse>,
tonic::Status,
>;
async fn get_transfer_params(
&self,
request: tonic::Request<super::super::types::GetTransferParamsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTransferParamsResponse>,
tonic::Status,
>;
async fn get_withdraw_params(
&self,
request: tonic::Request<super::super::types::GetWithdrawParamsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetWithdrawParamsResponse>,
tonic::Status,
>;
async fn withdraw(
&self,
request: tonic::Request<super::super::types::WithdrawRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::WithdrawResponse>,
tonic::Status,
>;
async fn get_prove_price(
&self,
request: tonic::Request<super::super::types::GetProvePriceRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProvePriceResponse>,
tonic::Status,
>;
async fn get_price_info(
&self,
request: tonic::Request<super::super::types::GetPriceInfoRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetPriceInfoResponse>,
tonic::Status,
>;
async fn bid(
&self,
request: tonic::Request<super::super::types::BidRequest>,
) -> std::result::Result<tonic::Response<super::super::types::BidResponse>, tonic::Status>;
async fn settle(
&self,
request: tonic::Request<super::super::types::SettleRequest>,
) -> std::result::Result<tonic::Response<super::super::types::SettleResponse>, tonic::Status>;
async fn get_provers_by_uptime(
&self,
request: tonic::Request<super::super::types::GetProversByUptimeRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProversByUptimeResponse>,
tonic::Status,
>;
async fn get_filtered_settleable_requests(
&self,
request: tonic::Request<super::super::types::GetFilteredSettleableRequestsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredSettleableRequestsResponse>,
tonic::Status,
>;
async fn get_filtered_suspendable_provers(
&self,
request: tonic::Request<super::super::types::GetFilteredSuspendableProversRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredSuspendableProversResponse>,
tonic::Status,
>;
async fn suspend_prover(
&self,
request: tonic::Request<super::super::types::SuspendProverRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SuspendProverResponse>,
tonic::Status,
>;
async fn sign_in(
&self,
request: tonic::Request<super::super::types::SignInRequest>,
) -> std::result::Result<tonic::Response<super::super::types::SignInResponse>, tonic::Status>;
async fn connect_twitter(
&self,
request: tonic::Request<super::super::types::ConnectTwitterRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::ConnectTwitterResponse>,
tonic::Status,
>;
async fn get_prover_stats(
&self,
request: tonic::Request<super::super::types::GetProverStatsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProverStatsResponse>,
tonic::Status,
>;
async fn get_filtered_prover_stats(
&self,
request: tonic::Request<super::super::types::GetFilteredProverStatsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredProverStatsResponse>,
tonic::Status,
>;
async fn get_prover_stats_detail(
&self,
request: tonic::Request<super::super::types::GetProverStatsDetailRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProverStatsDetailResponse>,
tonic::Status,
>;
async fn get_prover_search_results(
&self,
request: tonic::Request<super::super::types::GetProverSearchResultsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProverSearchResultsResponse>,
tonic::Status,
>;
async fn get_staking_prover_search(
&self,
request: tonic::Request<super::super::types::GetStakingProverSearchRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetStakingProverSearchResponse>,
tonic::Status,
>;
async fn get_filtered_bid_history(
&self,
request: tonic::Request<super::super::types::GetFilteredBidHistoryRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredBidHistoryResponse>,
tonic::Status,
>;
async fn get_filtered_prover_bid_history(
&self,
request: tonic::Request<super::super::types::GetFilteredProverBidHistoryRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredProverBidHistoryResponse>,
tonic::Status,
>;
async fn update_staker_fee(
&self,
request: tonic::Request<super::super::types::UpdateStakerFeeRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::UpdateStakerFeeResponse>,
tonic::Status,
>;
async fn get_staker_fee_update_time(
&self,
request: tonic::Request<super::super::types::GetStakerFeeUpdateTimeRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetStakerFeeUpdateTimeResponse>,
tonic::Status,
>;
async fn get_update_staker_fee_params(
&self,
request: tonic::Request<super::super::types::GetUpdateStakerFeeParamsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetUpdateStakerFeeParamsResponse>,
tonic::Status,
>;
async fn update_delegator_fee(
&self,
request: tonic::Request<super::super::types::UpdateDelegatorFeeRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::UpdateDelegatorFeeResponse>,
tonic::Status,
>;
async fn get_tee_whitelist_status(
&self,
request: tonic::Request<super::super::types::GetTeeWhitelistStatusRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTeeWhitelistStatusResponse>,
tonic::Status,
>;
async fn get_filtered_provers(
&self,
request: tonic::Request<super::super::types::GetFilteredProversRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredProversResponse>,
tonic::Status,
>;
async fn get_prover_stake_balance(
&self,
request: tonic::Request<super::super::types::GetProverStakeBalanceRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProverStakeBalanceResponse>,
tonic::Status,
>;
async fn get_filtered_staker_stake_balance_logs(
&self,
request: tonic::Request<super::super::types::GetFilteredStakerStakeBalanceLogsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredStakerStakeBalanceLogsResponse>,
tonic::Status,
>;
async fn get_filtered_prover_stake_balance_logs(
&self,
request: tonic::Request<super::super::types::GetFilteredProverStakeBalanceLogsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredProverStakeBalanceLogsResponse>,
tonic::Status,
>;
async fn get_staking_points(
&self,
request: tonic::Request<super::super::types::GetStakingPointsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetStakingPointsResponse>,
tonic::Status,
>;
async fn get_network_filtered_staker_leaderboard(
&self,
request: tonic::Request<
super::super::types::GetNetworkFilteredStakerLeaderboardRequest,
>,
) -> std::result::Result<
tonic::Response<super::super::types::GetNetworkFilteredStakerLeaderboardResponse>,
tonic::Status,
>;
async fn get_network_staker_leaderboard_dashboard(
&self,
request: tonic::Request<
super::super::types::GetNetworkStakerLeaderboardDashboardRequest,
>,
) -> std::result::Result<
tonic::Response<super::super::types::GetNetworkStakerLeaderboardDashboardResponse>,
tonic::Status,
>;
async fn get_delegation_params(
&self,
request: tonic::Request<super::super::types::GetDelegationParamsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetDelegationParamsResponse>,
tonic::Status,
>;
async fn get_titan_config_params(
&self,
request: tonic::Request<super::super::types::GetTitanConfigParamsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitanConfigParamsResponse>,
tonic::Status,
>;
async fn set_delegation(
&self,
request: tonic::Request<super::super::types::SetDelegationRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetDelegationResponse>,
tonic::Status,
>;
async fn get_delegation(
&self,
request: tonic::Request<super::super::types::GetDelegationRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetDelegationResponse>,
tonic::Status,
>;
async fn get_filtered_withdrawal_receipts(
&self,
request: tonic::Request<super::super::types::GetFilteredWithdrawalReceiptsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredWithdrawalReceiptsResponse>,
tonic::Status,
>;
async fn get_epoch(
&self,
request: tonic::Request<super::super::types::GetEpochRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetEpochResponse>,
tonic::Status,
>;
async fn get_prover_work(
&self,
request: tonic::Request<super::super::types::GetProverWorkRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProverWorkResponse>,
tonic::Status,
>;
async fn get_provers_with_work(
&self,
request: tonic::Request<super::super::types::GetProversWithWorkRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProversWithWorkResponse>,
tonic::Status,
>;
async fn get_rewards_dashboard(
&self,
request: tonic::Request<super::super::types::GetRewardsDashboardRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetRewardsDashboardResponse>,
tonic::Status,
>;
async fn get_recent_rewards_graph(
&self,
request: tonic::Request<super::super::types::GetRecentRewardsGraphRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetRecentRewardsGraphResponse>,
tonic::Status,
>;
async fn get_recent_performance_graph(
&self,
request: tonic::Request<super::super::types::GetRecentPerformanceGraphRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetRecentPerformanceGraphResponse>,
tonic::Status,
>;
async fn get_titan1_whitelist_allocation(
&self,
request: tonic::Request<super::super::types::GetTitan1WhitelistAllocationRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1WhitelistAllocationResponse>,
tonic::Status,
>;
async fn get_filtered_titan1_nfts(
&self,
request: tonic::Request<super::super::types::GetFilteredTitan1NftsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredTitan1NftsResponse>,
tonic::Status,
>;
async fn set_titan1_delegation(
&self,
request: tonic::Request<super::super::types::SetTitan1DelegationRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetTitan1DelegationResponse>,
tonic::Status,
>;
async fn set_titan1_delegation_limit(
&self,
request: tonic::Request<super::super::types::SetTitan1DelegationLimitRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetTitan1DelegationLimitResponse>,
tonic::Status,
>;
async fn set_titan1_auto_accept(
&self,
request: tonic::Request<super::super::types::SetTitan1AutoAcceptRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetTitan1AutoAcceptResponse>,
tonic::Status,
>;
async fn get_titan1_delegation_settings(
&self,
request: tonic::Request<super::super::types::GetTitan1DelegationSettingsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1DelegationSettingsResponse>,
tonic::Status,
>;
async fn set_titan1_delegation_settings(
&self,
request: tonic::Request<super::super::types::SetTitan1DelegationSettingsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::SetTitan1DelegationSettingsResponse>,
tonic::Status,
>;
async fn get_titan1_recent_sales(
&self,
request: tonic::Request<super::super::types::GetTitan1RecentSalesRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1RecentSalesResponse>,
tonic::Status,
>;
async fn get_filtered_titan1_delegates(
&self,
request: tonic::Request<super::super::types::GetFilteredTitan1DelegatesRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredTitan1DelegatesResponse>,
tonic::Status,
>;
async fn get_filtered_titan1_delegate_requests(
&self,
request: tonic::Request<super::super::types::GetFilteredTitan1DelegateRequestsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredTitan1DelegateRequestsResponse>,
tonic::Status,
>;
async fn get_filtered_titan1_delegate_removals(
&self,
request: tonic::Request<super::super::types::GetFilteredTitan1DelegateRemovalsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredTitan1DelegateRemovalsResponse>,
tonic::Status,
>;
async fn get_titan1_recent_activity(
&self,
request: tonic::Request<super::super::types::GetTitan1RecentActivityRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1RecentActivityResponse>,
tonic::Status,
>;
async fn accept_titan1_delegates(
&self,
request: tonic::Request<super::super::types::AcceptTitan1DelegatesRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::AcceptTitan1DelegatesResponse>,
tonic::Status,
>;
async fn reject_titan1_delegates(
&self,
request: tonic::Request<super::super::types::RejectTitan1DelegatesRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::RejectTitan1DelegatesResponse>,
tonic::Status,
>;
async fn remove_titan1_delegates(
&self,
request: tonic::Request<super::super::types::RemoveTitan1DelegatesRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::RemoveTitan1DelegatesResponse>,
tonic::Status,
>;
async fn check_titan_whitelist(
&self,
request: tonic::Request<super::super::types::CheckTitanWhitelistRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::CheckTitanWhitelistResponse>,
tonic::Status,
>;
async fn get_titan_whitelist_details(
&self,
request: tonic::Request<super::super::types::GetTitanWhitelistDetailsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitanWhitelistDetailsResponse>,
tonic::Status,
>;
async fn join_titan_queue(
&self,
request: tonic::Request<super::super::types::JoinTitanQueueRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::JoinTitanQueueResponse>,
tonic::Status,
>;
async fn claim_titan_whitelist_spot(
&self,
request: tonic::Request<super::super::types::ClaimTitanWhitelistSpotRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::ClaimTitanWhitelistSpotResponse>,
tonic::Status,
>;
async fn claim_titan_whitelist_spot_by_address(
&self,
request: tonic::Request<super::super::types::ClaimTitanWhitelistSpotByAddressRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::ClaimTitanWhitelistSpotByAddressResponse>,
tonic::Status,
>;
async fn get_prover_delegated_slot_balance(
&self,
request: tonic::Request<super::super::types::GetProverDelegatedSlotBalanceRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProverDelegatedSlotBalanceResponse>,
tonic::Status,
>;
async fn get_slot_delegation_details(
&self,
request: tonic::Request<super::super::types::GetSlotDelegationDetailsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetSlotDelegationDetailsResponse>,
tonic::Status,
>;
async fn get_titan1_delegation_limit(
&self,
request: tonic::Request<super::super::types::GetTitan1DelegationLimitRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1DelegationLimitResponse>,
tonic::Status,
>;
async fn add_ref_visit(
&self,
request: tonic::Request<super::super::types::AddRefVisitRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::AddRefVisitResponse>,
tonic::Status,
>;
async fn get_prover_delegate_request_count(
&self,
request: tonic::Request<super::super::types::GetProverDelegateRequestCountRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetProverDelegateRequestCountResponse>,
tonic::Status,
>;
async fn get_titan_cloud_provers(
&self,
request: tonic::Request<super::super::types::GetTitanCloudProversRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitanCloudProversResponse>,
tonic::Status,
>;
async fn get_filtered_titan1_ids(
&self,
request: tonic::Request<super::super::types::GetFilteredTitan1IdsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredTitan1IdsResponse>,
tonic::Status,
>;
async fn get_filtered_titan1_slots(
&self,
request: tonic::Request<super::super::types::GetFilteredTitan1SlotsRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetFilteredTitan1SlotsResponse>,
tonic::Status,
>;
async fn get_titan1_rewards_data(
&self,
request: tonic::Request<super::super::types::GetTitan1RewardsDataRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1RewardsDataResponse>,
tonic::Status,
>;
async fn get_titan1_work_graph(
&self,
request: tonic::Request<super::super::types::GetTitan1WorkGraphRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1WorkGraphResponse>,
tonic::Status,
>;
async fn get_titan1_claim_proof(
&self,
request: tonic::Request<super::super::types::GetTitan1ClaimProofRequest>,
) -> std::result::Result<
tonic::Response<super::super::types::GetTitan1ClaimProofResponse>,
tonic::Status,
>;
}
#[derive(Debug)]
pub struct ProverNetworkServer<T> {
inner: Arc<T>,
accept_compression_encodings: EnabledCompressionEncodings,
send_compression_encodings: EnabledCompressionEncodings,
max_decoding_message_size: Option<usize>,
max_encoding_message_size: Option<usize>,
}
impl<T> ProverNetworkServer<T> {
pub fn new(inner: T) -> Self {
Self::from_arc(Arc::new(inner))
}
pub fn from_arc(inner: Arc<T>) -> Self {
Self {
inner,
accept_compression_encodings: Default::default(),
send_compression_encodings: Default::default(),
max_decoding_message_size: None,
max_encoding_message_size: None,
}
}
pub fn with_interceptor<F>(inner: T, interceptor: F) -> InterceptedService<Self, F>
where
F: tonic::service::Interceptor,
{
InterceptedService::new(Self::new(inner), interceptor)
}
#[must_use]
pub fn accept_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.accept_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn send_compressed(mut self, encoding: CompressionEncoding) -> Self {
self.send_compression_encodings.enable(encoding);
self
}
#[must_use]
pub fn max_decoding_message_size(mut self, limit: usize) -> Self {
self.max_decoding_message_size = Some(limit);
self
}
#[must_use]
pub fn max_encoding_message_size(mut self, limit: usize) -> Self {
self.max_encoding_message_size = Some(limit);
self
}
}
impl<T, B> tonic::codegen::Service<http::Request<B>> for ProverNetworkServer<T>
where
T: ProverNetwork,
B: Body + std::marker::Send + 'static,
B::Error: Into<StdError> + std::marker::Send + 'static,
{
type Response = http::Response<tonic::body::BoxBody>;
type Error = std::convert::Infallible;
type Future = BoxFuture<Self::Response, Self::Error>;
fn poll_ready(
&mut self,
_cx: &mut Context<'_>,
) -> Poll<std::result::Result<(), Self::Error>> {
Poll::Ready(Ok(()))
}
fn call(&mut self, req: http::Request<B>) -> Self::Future {
match req.uri().path() {
"/network.ProverNetwork/RequestProof" => {
#[allow(non_camel_case_types)]
struct RequestProofSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::RequestProofRequest>
for RequestProofSvc<T>
{
type Response = super::super::types::RequestProofResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::RequestProofRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::request_proof(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = RequestProofSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/FulfillProof" => {
#[allow(non_camel_case_types)]
struct FulfillProofSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::FulfillProofRequest>
for FulfillProofSvc<T>
{
type Response = super::super::types::FulfillProofResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::FulfillProofRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::fulfill_proof(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = FulfillProofSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/ExecuteProof" => {
#[allow(non_camel_case_types)]
struct ExecuteProofSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::ExecuteProofRequest>
for ExecuteProofSvc<T>
{
type Response = super::super::types::ExecuteProofResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::ExecuteProofRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::execute_proof(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = ExecuteProofSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/FailFulfillment" => {
#[allow(non_camel_case_types)]
struct FailFulfillmentSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::FailFulfillmentRequest>
for FailFulfillmentSvc<T>
{
type Response = super::super::types::FailFulfillmentResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::FailFulfillmentRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::fail_fulfillment(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = FailFulfillmentSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/CancelRequest" => {
#[allow(non_camel_case_types)]
struct CancelRequestSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::CancelRequestRequest>
for CancelRequestSvc<T>
{
type Response = super::super::types::CancelRequestResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::CancelRequestRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::cancel_request(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = CancelRequestSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProofRequestStatus" => {
#[allow(non_camel_case_types)]
struct GetProofRequestStatusSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetProofRequestStatusRequest,
> for GetProofRequestStatusSvc<T>
{
type Response = super::super::types::GetProofRequestStatusResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetProofRequestStatusRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_proof_request_status(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProofRequestStatusSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProofRequestDetails" => {
#[allow(non_camel_case_types)]
struct GetProofRequestDetailsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetProofRequestDetailsRequest,
> for GetProofRequestDetailsSvc<T>
{
type Response = super::super::types::GetProofRequestDetailsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetProofRequestDetailsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_proof_request_details(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProofRequestDetailsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetStdinUri" => {
#[allow(non_camel_case_types)]
struct GetStdinUriSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetStdinUriRequest>
for GetStdinUriSvc<T>
{
type Response = super::super::types::GetStdinUriResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetStdinUriRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_stdin_uri(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetStdinUriSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredProofRequests" => {
#[allow(non_camel_case_types)]
struct GetFilteredProofRequestsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredProofRequestsRequest,
> for GetFilteredProofRequestsSvc<T>
{
type Response = super::super::types::GetFilteredProofRequestsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredProofRequestsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_proof_requests(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredProofRequestsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/SubscribeProofRequests" => {
#[allow(non_camel_case_types)]
struct SubscribeProofRequestsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::ServerStreamingService<
super::super::types::GetFilteredProofRequestsRequest,
> for SubscribeProofRequestsSvc<T>
{
type Response = super::super::types::ProofRequest;
type ResponseStream = T::SubscribeProofRequestsStream;
type Future =
BoxFuture<tonic::Response<Self::ResponseStream>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredProofRequestsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::subscribe_proof_requests(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = SubscribeProofRequestsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.server_streaming(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetSearchResults" => {
#[allow(non_camel_case_types)]
struct GetSearchResultsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetSearchResultsRequest>
for GetSearchResultsSvc<T>
{
type Response = super::super::types::GetSearchResultsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetSearchResultsRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_search_results(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetSearchResultsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProofRequestMetrics" => {
#[allow(non_camel_case_types)]
struct GetProofRequestMetricsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetProofRequestMetricsRequest,
> for GetProofRequestMetricsSvc<T>
{
type Response = super::super::types::GetProofRequestMetricsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetProofRequestMetricsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_proof_request_metrics(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProofRequestMetricsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProofRequestGraph" => {
#[allow(non_camel_case_types)]
struct GetProofRequestGraphSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetProofRequestGraphRequest,
> for GetProofRequestGraphSvc<T>
{
type Response = super::super::types::GetProofRequestGraphResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetProofRequestGraphRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_proof_request_graph(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProofRequestGraphSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetAnalyticsGraphs" => {
#[allow(non_camel_case_types)]
struct GetAnalyticsGraphsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetAnalyticsGraphsRequest>
for GetAnalyticsGraphsSvc<T>
{
type Response = super::super::types::GetAnalyticsGraphsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetAnalyticsGraphsRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_analytics_graphs(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetAnalyticsGraphsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetOverviewGraphs" => {
#[allow(non_camel_case_types)]
struct GetOverviewGraphsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetOverviewGraphsRequest>
for GetOverviewGraphsSvc<T>
{
type Response = super::super::types::GetOverviewGraphsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetOverviewGraphsRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_overview_graphs(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetOverviewGraphsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProofRequestParams" => {
#[allow(non_camel_case_types)]
struct GetProofRequestParamsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetProofRequestParamsRequest,
> for GetProofRequestParamsSvc<T>
{
type Response = super::super::types::GetProofRequestParamsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetProofRequestParamsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_proof_request_params(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProofRequestParamsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetNonce" => {
#[allow(non_camel_case_types)]
struct GetNonceSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetNonceRequest>
for GetNonceSvc<T>
{
type Response = super::super::types::GetNonceResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetNonceRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_nonce(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetNonceSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/SetAccountName" => {
#[allow(non_camel_case_types)]
struct SetAccountNameSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::SetAccountNameRequest>
for SetAccountNameSvc<T>
{
type Response = super::super::types::SetAccountNameResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::SetAccountNameRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::set_account_name(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = SetAccountNameSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetAccountName" => {
#[allow(non_camel_case_types)]
struct GetAccountNameSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetAccountNameRequest>
for GetAccountNameSvc<T>
{
type Response = super::super::types::GetAccountNameResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetAccountNameRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_account_name(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetAccountNameSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTermsSignature" => {
#[allow(non_camel_case_types)]
struct GetTermsSignatureSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetTermsSignatureRequest>
for GetTermsSignatureSvc<T>
{
type Response = super::super::types::GetTermsSignatureResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetTermsSignatureRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_terms_signature(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTermsSignatureSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/SetTermsSignature" => {
#[allow(non_camel_case_types)]
struct SetTermsSignatureSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::SetTermsSignatureRequest>
for SetTermsSignatureSvc<T>
{
type Response = super::super::types::SetTermsSignatureResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::SetTermsSignatureRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::set_terms_signature(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = SetTermsSignatureSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetAccount" => {
#[allow(non_camel_case_types)]
struct GetAccountSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetAccountRequest>
for GetAccountSvc<T>
{
type Response = super::super::types::GetAccountResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetAccountRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_account(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetAccountSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetOwner" => {
#[allow(non_camel_case_types)]
struct GetOwnerSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetOwnerRequest>
for GetOwnerSvc<T>
{
type Response = super::super::types::GetOwnerResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetOwnerRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_owner(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetOwnerSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProgram" => {
#[allow(non_camel_case_types)]
struct GetProgramSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetProgramRequest>
for GetProgramSvc<T>
{
type Response = super::super::types::GetProgramResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetProgramRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_program(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProgramSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/CreateProgram" => {
#[allow(non_camel_case_types)]
struct CreateProgramSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::CreateProgramRequest>
for CreateProgramSvc<T>
{
type Response = super::super::types::CreateProgramResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::CreateProgramRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::create_program(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = CreateProgramSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/SetProgramName" => {
#[allow(non_camel_case_types)]
struct SetProgramNameSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::SetProgramNameRequest>
for SetProgramNameSvc<T>
{
type Response = super::super::types::SetProgramNameResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::SetProgramNameRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::set_program_name(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = SetProgramNameSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetBalance" => {
#[allow(non_camel_case_types)]
struct GetBalanceSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetBalanceRequest>
for GetBalanceSvc<T>
{
type Response = super::super::types::GetBalanceResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetBalanceRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_balance(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetBalanceSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredBalanceLogs" => {
#[allow(non_camel_case_types)]
struct GetFilteredBalanceLogsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredBalanceLogsRequest,
> for GetFilteredBalanceLogsSvc<T>
{
type Response = super::super::types::GetFilteredBalanceLogsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredBalanceLogsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_balance_logs(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredBalanceLogsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetLatestBridgeBlock" => {
#[allow(non_camel_case_types)]
struct GetLatestBridgeBlockSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetLatestBridgeBlockRequest,
> for GetLatestBridgeBlockSvc<T>
{
type Response = super::super::types::GetLatestBridgeBlockResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetLatestBridgeBlockRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_latest_bridge_block(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetLatestBridgeBlockSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetGasPriceEstimate" => {
#[allow(non_camel_case_types)]
struct GetGasPriceEstimateSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetGasPriceEstimateRequest>
for GetGasPriceEstimateSvc<T>
{
type Response = super::super::types::GetGasPriceEstimateResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetGasPriceEstimateRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_gas_price_estimate(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetGasPriceEstimateSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTransactionDetails" => {
#[allow(non_camel_case_types)]
struct GetTransactionDetailsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetTransactionDetailsRequest,
> for GetTransactionDetailsSvc<T>
{
type Response = super::super::types::GetTransactionDetailsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetTransactionDetailsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_transaction_details(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTransactionDetailsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/Transfer" => {
#[allow(non_camel_case_types)]
struct TransferSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::TransferRequest>
for TransferSvc<T>
{
type Response = super::super::types::TransferResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::TransferRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::transfer(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = TransferSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTransferParams" => {
#[allow(non_camel_case_types)]
struct GetTransferParamsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetTransferParamsRequest>
for GetTransferParamsSvc<T>
{
type Response = super::super::types::GetTransferParamsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetTransferParamsRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_transfer_params(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTransferParamsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetWithdrawParams" => {
#[allow(non_camel_case_types)]
struct GetWithdrawParamsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetWithdrawParamsRequest>
for GetWithdrawParamsSvc<T>
{
type Response = super::super::types::GetWithdrawParamsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetWithdrawParamsRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_withdraw_params(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetWithdrawParamsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/Withdraw" => {
#[allow(non_camel_case_types)]
struct WithdrawSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::WithdrawRequest>
for WithdrawSvc<T>
{
type Response = super::super::types::WithdrawResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::WithdrawRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::withdraw(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = WithdrawSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProvePrice" => {
#[allow(non_camel_case_types)]
struct GetProvePriceSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetProvePriceRequest>
for GetProvePriceSvc<T>
{
type Response = super::super::types::GetProvePriceResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetProvePriceRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_prove_price(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProvePriceSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetPriceInfo" => {
#[allow(non_camel_case_types)]
struct GetPriceInfoSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetPriceInfoRequest>
for GetPriceInfoSvc<T>
{
type Response = super::super::types::GetPriceInfoResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetPriceInfoRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_price_info(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetPriceInfoSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/Bid" => {
#[allow(non_camel_case_types)]
struct BidSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::BidRequest> for BidSvc<T>
{
type Response = super::super::types::BidResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::BidRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut =
async move { <T as ProverNetwork>::bid(&inner, request).await };
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = BidSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/Settle" => {
#[allow(non_camel_case_types)]
struct SettleSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::SettleRequest>
for SettleSvc<T>
{
type Response = super::super::types::SettleResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::SettleRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut =
async move { <T as ProverNetwork>::settle(&inner, request).await };
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = SettleSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProversByUptime" => {
#[allow(non_camel_case_types)]
struct GetProversByUptimeSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetProversByUptimeRequest>
for GetProversByUptimeSvc<T>
{
type Response = super::super::types::GetProversByUptimeResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetProversByUptimeRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_provers_by_uptime(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProversByUptimeSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredSettleableRequests" => {
#[allow(non_camel_case_types)]
struct GetFilteredSettleableRequestsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredSettleableRequestsRequest,
> for GetFilteredSettleableRequestsSvc<T>
{
type Response = super::super::types::GetFilteredSettleableRequestsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredSettleableRequestsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_settleable_requests(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredSettleableRequestsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredSuspendableProvers" => {
#[allow(non_camel_case_types)]
struct GetFilteredSuspendableProversSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredSuspendableProversRequest,
> for GetFilteredSuspendableProversSvc<T>
{
type Response = super::super::types::GetFilteredSuspendableProversResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredSuspendableProversRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_suspendable_provers(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredSuspendableProversSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/SuspendProver" => {
#[allow(non_camel_case_types)]
struct SuspendProverSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::SuspendProverRequest>
for SuspendProverSvc<T>
{
type Response = super::super::types::SuspendProverResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::SuspendProverRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::suspend_prover(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = SuspendProverSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/SignIn" => {
#[allow(non_camel_case_types)]
struct SignInSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::SignInRequest>
for SignInSvc<T>
{
type Response = super::super::types::SignInResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::SignInRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut =
async move { <T as ProverNetwork>::sign_in(&inner, request).await };
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = SignInSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/ConnectTwitter" => {
#[allow(non_camel_case_types)]
struct ConnectTwitterSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::ConnectTwitterRequest>
for ConnectTwitterSvc<T>
{
type Response = super::super::types::ConnectTwitterResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::ConnectTwitterRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::connect_twitter(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = ConnectTwitterSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProverStats" => {
#[allow(non_camel_case_types)]
struct GetProverStatsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetProverStatsRequest>
for GetProverStatsSvc<T>
{
type Response = super::super::types::GetProverStatsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetProverStatsRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_prover_stats(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProverStatsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredProverStats" => {
#[allow(non_camel_case_types)]
struct GetFilteredProverStatsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredProverStatsRequest,
> for GetFilteredProverStatsSvc<T>
{
type Response = super::super::types::GetFilteredProverStatsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredProverStatsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_prover_stats(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredProverStatsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProverStatsDetail" => {
#[allow(non_camel_case_types)]
struct GetProverStatsDetailSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetProverStatsDetailRequest,
> for GetProverStatsDetailSvc<T>
{
type Response = super::super::types::GetProverStatsDetailResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetProverStatsDetailRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_prover_stats_detail(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProverStatsDetailSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProverSearchResults" => {
#[allow(non_camel_case_types)]
struct GetProverSearchResultsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetProverSearchResultsRequest,
> for GetProverSearchResultsSvc<T>
{
type Response = super::super::types::GetProverSearchResultsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetProverSearchResultsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_prover_search_results(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProverSearchResultsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetStakingProverSearch" => {
#[allow(non_camel_case_types)]
struct GetStakingProverSearchSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetStakingProverSearchRequest,
> for GetStakingProverSearchSvc<T>
{
type Response = super::super::types::GetStakingProverSearchResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetStakingProverSearchRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_staking_prover_search(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetStakingProverSearchSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredBidHistory" => {
#[allow(non_camel_case_types)]
struct GetFilteredBidHistorySvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredBidHistoryRequest,
> for GetFilteredBidHistorySvc<T>
{
type Response = super::super::types::GetFilteredBidHistoryResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredBidHistoryRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_bid_history(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredBidHistorySvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredProverBidHistory" => {
#[allow(non_camel_case_types)]
struct GetFilteredProverBidHistorySvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredProverBidHistoryRequest,
> for GetFilteredProverBidHistorySvc<T>
{
type Response = super::super::types::GetFilteredProverBidHistoryResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredProverBidHistoryRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_prover_bid_history(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredProverBidHistorySvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/UpdateStakerFee" => {
#[allow(non_camel_case_types)]
struct UpdateStakerFeeSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::UpdateStakerFeeRequest>
for UpdateStakerFeeSvc<T>
{
type Response = super::super::types::UpdateStakerFeeResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::UpdateStakerFeeRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::update_staker_fee(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = UpdateStakerFeeSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetStakerFeeUpdateTime" => {
#[allow(non_camel_case_types)]
struct GetStakerFeeUpdateTimeSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetStakerFeeUpdateTimeRequest,
> for GetStakerFeeUpdateTimeSvc<T>
{
type Response = super::super::types::GetStakerFeeUpdateTimeResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetStakerFeeUpdateTimeRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_staker_fee_update_time(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetStakerFeeUpdateTimeSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetUpdateStakerFeeParams" => {
#[allow(non_camel_case_types)]
struct GetUpdateStakerFeeParamsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetUpdateStakerFeeParamsRequest,
> for GetUpdateStakerFeeParamsSvc<T>
{
type Response = super::super::types::GetUpdateStakerFeeParamsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetUpdateStakerFeeParamsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_update_staker_fee_params(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetUpdateStakerFeeParamsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/UpdateDelegatorFee" => {
#[allow(non_camel_case_types)]
struct UpdateDelegatorFeeSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::UpdateDelegatorFeeRequest>
for UpdateDelegatorFeeSvc<T>
{
type Response = super::super::types::UpdateDelegatorFeeResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::UpdateDelegatorFeeRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::update_delegator_fee(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = UpdateDelegatorFeeSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTEEWhitelistStatus" => {
#[allow(non_camel_case_types)]
struct GetTEEWhitelistStatusSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetTeeWhitelistStatusRequest,
> for GetTEEWhitelistStatusSvc<T>
{
type Response = super::super::types::GetTeeWhitelistStatusResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetTeeWhitelistStatusRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_tee_whitelist_status(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTEEWhitelistStatusSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredProvers" => {
#[allow(non_camel_case_types)]
struct GetFilteredProversSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetFilteredProversRequest>
for GetFilteredProversSvc<T>
{
type Response = super::super::types::GetFilteredProversResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetFilteredProversRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_provers(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredProversSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProverStakeBalance" => {
#[allow(non_camel_case_types)]
struct GetProverStakeBalanceSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetProverStakeBalanceRequest,
> for GetProverStakeBalanceSvc<T>
{
type Response = super::super::types::GetProverStakeBalanceResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetProverStakeBalanceRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_prover_stake_balance(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProverStakeBalanceSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredStakerStakeBalanceLogs" => {
#[allow(non_camel_case_types)]
struct GetFilteredStakerStakeBalanceLogsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredStakerStakeBalanceLogsRequest,
> for GetFilteredStakerStakeBalanceLogsSvc<T>
{
type Response =
super::super::types::GetFilteredStakerStakeBalanceLogsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredStakerStakeBalanceLogsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_staker_stake_balance_logs(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredStakerStakeBalanceLogsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredProverStakeBalanceLogs" => {
#[allow(non_camel_case_types)]
struct GetFilteredProverStakeBalanceLogsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredProverStakeBalanceLogsRequest,
> for GetFilteredProverStakeBalanceLogsSvc<T>
{
type Response =
super::super::types::GetFilteredProverStakeBalanceLogsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredProverStakeBalanceLogsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_prover_stake_balance_logs(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredProverStakeBalanceLogsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetStakingPoints" => {
#[allow(non_camel_case_types)]
struct GetStakingPointsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetStakingPointsRequest>
for GetStakingPointsSvc<T>
{
type Response = super::super::types::GetStakingPointsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetStakingPointsRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_staking_points(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetStakingPointsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetNetworkFilteredStakerLeaderboard" => {
#[allow(non_camel_case_types)]
struct GetNetworkFilteredStakerLeaderboardSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetNetworkFilteredStakerLeaderboardRequest,
> for GetNetworkFilteredStakerLeaderboardSvc<T>
{
type Response =
super::super::types::GetNetworkFilteredStakerLeaderboardResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetNetworkFilteredStakerLeaderboardRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_network_filtered_staker_leaderboard(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetNetworkFilteredStakerLeaderboardSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetNetworkStakerLeaderboardDashboard" => {
#[allow(non_camel_case_types)]
struct GetNetworkStakerLeaderboardDashboardSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetNetworkStakerLeaderboardDashboardRequest,
> for GetNetworkStakerLeaderboardDashboardSvc<T>
{
type Response =
super::super::types::GetNetworkStakerLeaderboardDashboardResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetNetworkStakerLeaderboardDashboardRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_network_staker_leaderboard_dashboard(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetNetworkStakerLeaderboardDashboardSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetDelegationParams" => {
#[allow(non_camel_case_types)]
struct GetDelegationParamsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetDelegationParamsRequest>
for GetDelegationParamsSvc<T>
{
type Response = super::super::types::GetDelegationParamsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetDelegationParamsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_delegation_params(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetDelegationParamsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTitanConfigParams" => {
#[allow(non_camel_case_types)]
struct GetTitanConfigParamsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetTitanConfigParamsRequest,
> for GetTitanConfigParamsSvc<T>
{
type Response = super::super::types::GetTitanConfigParamsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetTitanConfigParamsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_titan_config_params(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTitanConfigParamsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/SetDelegation" => {
#[allow(non_camel_case_types)]
struct SetDelegationSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::SetDelegationRequest>
for SetDelegationSvc<T>
{
type Response = super::super::types::SetDelegationResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::SetDelegationRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::set_delegation(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = SetDelegationSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetDelegation" => {
#[allow(non_camel_case_types)]
struct GetDelegationSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetDelegationRequest>
for GetDelegationSvc<T>
{
type Response = super::super::types::GetDelegationResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetDelegationRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_delegation(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetDelegationSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredWithdrawalReceipts" => {
#[allow(non_camel_case_types)]
struct GetFilteredWithdrawalReceiptsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredWithdrawalReceiptsRequest,
> for GetFilteredWithdrawalReceiptsSvc<T>
{
type Response = super::super::types::GetFilteredWithdrawalReceiptsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredWithdrawalReceiptsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_withdrawal_receipts(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredWithdrawalReceiptsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetEpoch" => {
#[allow(non_camel_case_types)]
struct GetEpochSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetEpochRequest>
for GetEpochSvc<T>
{
type Response = super::super::types::GetEpochResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetEpochRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_epoch(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetEpochSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProverWork" => {
#[allow(non_camel_case_types)]
struct GetProverWorkSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetProverWorkRequest>
for GetProverWorkSvc<T>
{
type Response = super::super::types::GetProverWorkResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetProverWorkRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_prover_work(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProverWorkSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProversWithWork" => {
#[allow(non_camel_case_types)]
struct GetProversWithWorkSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetProversWithWorkRequest>
for GetProversWithWorkSvc<T>
{
type Response = super::super::types::GetProversWithWorkResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetProversWithWorkRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_provers_with_work(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProversWithWorkSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetRewardsDashboard" => {
#[allow(non_camel_case_types)]
struct GetRewardsDashboardSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetRewardsDashboardRequest>
for GetRewardsDashboardSvc<T>
{
type Response = super::super::types::GetRewardsDashboardResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetRewardsDashboardRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_rewards_dashboard(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetRewardsDashboardSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetRecentRewardsGraph" => {
#[allow(non_camel_case_types)]
struct GetRecentRewardsGraphSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetRecentRewardsGraphRequest,
> for GetRecentRewardsGraphSvc<T>
{
type Response = super::super::types::GetRecentRewardsGraphResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetRecentRewardsGraphRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_recent_rewards_graph(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetRecentRewardsGraphSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetRecentPerformanceGraph" => {
#[allow(non_camel_case_types)]
struct GetRecentPerformanceGraphSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetRecentPerformanceGraphRequest,
> for GetRecentPerformanceGraphSvc<T>
{
type Response = super::super::types::GetRecentPerformanceGraphResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetRecentPerformanceGraphRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_recent_performance_graph(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetRecentPerformanceGraphSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTitan1WhitelistAllocation" => {
#[allow(non_camel_case_types)]
struct GetTitan1WhitelistAllocationSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetTitan1WhitelistAllocationRequest,
> for GetTitan1WhitelistAllocationSvc<T>
{
type Response = super::super::types::GetTitan1WhitelistAllocationResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetTitan1WhitelistAllocationRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_titan1_whitelist_allocation(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTitan1WhitelistAllocationSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredTitan1Nfts" => {
#[allow(non_camel_case_types)]
struct GetFilteredTitan1NftsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredTitan1NftsRequest,
> for GetFilteredTitan1NftsSvc<T>
{
type Response = super::super::types::GetFilteredTitan1NftsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredTitan1NftsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_titan1_nfts(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredTitan1NftsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/SetTitan1Delegation" => {
#[allow(non_camel_case_types)]
struct SetTitan1DelegationSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::SetTitan1DelegationRequest>
for SetTitan1DelegationSvc<T>
{
type Response = super::super::types::SetTitan1DelegationResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::SetTitan1DelegationRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::set_titan1_delegation(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = SetTitan1DelegationSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/SetTitan1DelegationLimit" => {
#[allow(non_camel_case_types)]
struct SetTitan1DelegationLimitSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::SetTitan1DelegationLimitRequest,
> for SetTitan1DelegationLimitSvc<T>
{
type Response = super::super::types::SetTitan1DelegationLimitResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::SetTitan1DelegationLimitRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::set_titan1_delegation_limit(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = SetTitan1DelegationLimitSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/SetTitan1AutoAccept" => {
#[allow(non_camel_case_types)]
struct SetTitan1AutoAcceptSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::SetTitan1AutoAcceptRequest>
for SetTitan1AutoAcceptSvc<T>
{
type Response = super::super::types::SetTitan1AutoAcceptResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::SetTitan1AutoAcceptRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::set_titan1_auto_accept(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = SetTitan1AutoAcceptSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTitan1DelegationSettings" => {
#[allow(non_camel_case_types)]
struct GetTitan1DelegationSettingsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetTitan1DelegationSettingsRequest,
> for GetTitan1DelegationSettingsSvc<T>
{
type Response = super::super::types::GetTitan1DelegationSettingsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetTitan1DelegationSettingsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_titan1_delegation_settings(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTitan1DelegationSettingsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/SetTitan1DelegationSettings" => {
#[allow(non_camel_case_types)]
struct SetTitan1DelegationSettingsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::SetTitan1DelegationSettingsRequest,
> for SetTitan1DelegationSettingsSvc<T>
{
type Response = super::super::types::SetTitan1DelegationSettingsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::SetTitan1DelegationSettingsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::set_titan1_delegation_settings(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = SetTitan1DelegationSettingsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTitan1RecentSales" => {
#[allow(non_camel_case_types)]
struct GetTitan1RecentSalesSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetTitan1RecentSalesRequest,
> for GetTitan1RecentSalesSvc<T>
{
type Response = super::super::types::GetTitan1RecentSalesResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetTitan1RecentSalesRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_titan1_recent_sales(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTitan1RecentSalesSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredTitan1Delegates" => {
#[allow(non_camel_case_types)]
struct GetFilteredTitan1DelegatesSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredTitan1DelegatesRequest,
> for GetFilteredTitan1DelegatesSvc<T>
{
type Response = super::super::types::GetFilteredTitan1DelegatesResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredTitan1DelegatesRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_titan1_delegates(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredTitan1DelegatesSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredTitan1DelegateRequests" => {
#[allow(non_camel_case_types)]
struct GetFilteredTitan1DelegateRequestsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredTitan1DelegateRequestsRequest,
> for GetFilteredTitan1DelegateRequestsSvc<T>
{
type Response =
super::super::types::GetFilteredTitan1DelegateRequestsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredTitan1DelegateRequestsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_titan1_delegate_requests(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredTitan1DelegateRequestsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredTitan1DelegateRemovals" => {
#[allow(non_camel_case_types)]
struct GetFilteredTitan1DelegateRemovalsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredTitan1DelegateRemovalsRequest,
> for GetFilteredTitan1DelegateRemovalsSvc<T>
{
type Response =
super::super::types::GetFilteredTitan1DelegateRemovalsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredTitan1DelegateRemovalsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_titan1_delegate_removals(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredTitan1DelegateRemovalsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTitan1RecentActivity" => {
#[allow(non_camel_case_types)]
struct GetTitan1RecentActivitySvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetTitan1RecentActivityRequest,
> for GetTitan1RecentActivitySvc<T>
{
type Response = super::super::types::GetTitan1RecentActivityResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetTitan1RecentActivityRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_titan1_recent_activity(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTitan1RecentActivitySvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/AcceptTitan1Delegates" => {
#[allow(non_camel_case_types)]
struct AcceptTitan1DelegatesSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::AcceptTitan1DelegatesRequest,
> for AcceptTitan1DelegatesSvc<T>
{
type Response = super::super::types::AcceptTitan1DelegatesResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::AcceptTitan1DelegatesRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::accept_titan1_delegates(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = AcceptTitan1DelegatesSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/RejectTitan1Delegates" => {
#[allow(non_camel_case_types)]
struct RejectTitan1DelegatesSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::RejectTitan1DelegatesRequest,
> for RejectTitan1DelegatesSvc<T>
{
type Response = super::super::types::RejectTitan1DelegatesResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::RejectTitan1DelegatesRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::reject_titan1_delegates(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = RejectTitan1DelegatesSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/RemoveTitan1Delegates" => {
#[allow(non_camel_case_types)]
struct RemoveTitan1DelegatesSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::RemoveTitan1DelegatesRequest,
> for RemoveTitan1DelegatesSvc<T>
{
type Response = super::super::types::RemoveTitan1DelegatesResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::RemoveTitan1DelegatesRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::remove_titan1_delegates(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = RemoveTitan1DelegatesSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/CheckTitanWhitelist" => {
#[allow(non_camel_case_types)]
struct CheckTitanWhitelistSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::CheckTitanWhitelistRequest>
for CheckTitanWhitelistSvc<T>
{
type Response = super::super::types::CheckTitanWhitelistResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::CheckTitanWhitelistRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::check_titan_whitelist(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = CheckTitanWhitelistSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTitanWhitelistDetails" => {
#[allow(non_camel_case_types)]
struct GetTitanWhitelistDetailsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetTitanWhitelistDetailsRequest,
> for GetTitanWhitelistDetailsSvc<T>
{
type Response = super::super::types::GetTitanWhitelistDetailsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetTitanWhitelistDetailsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_titan_whitelist_details(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTitanWhitelistDetailsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/JoinTitanQueue" => {
#[allow(non_camel_case_types)]
struct JoinTitanQueueSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::JoinTitanQueueRequest>
for JoinTitanQueueSvc<T>
{
type Response = super::super::types::JoinTitanQueueResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::JoinTitanQueueRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::join_titan_queue(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = JoinTitanQueueSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/ClaimTitanWhitelistSpot" => {
#[allow(non_camel_case_types)]
struct ClaimTitanWhitelistSpotSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::ClaimTitanWhitelistSpotRequest,
> for ClaimTitanWhitelistSpotSvc<T>
{
type Response = super::super::types::ClaimTitanWhitelistSpotResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::ClaimTitanWhitelistSpotRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::claim_titan_whitelist_spot(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = ClaimTitanWhitelistSpotSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/ClaimTitanWhitelistSpotByAddress" => {
#[allow(non_camel_case_types)]
struct ClaimTitanWhitelistSpotByAddressSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::ClaimTitanWhitelistSpotByAddressRequest,
> for ClaimTitanWhitelistSpotByAddressSvc<T>
{
type Response =
super::super::types::ClaimTitanWhitelistSpotByAddressResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::ClaimTitanWhitelistSpotByAddressRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::claim_titan_whitelist_spot_by_address(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = ClaimTitanWhitelistSpotByAddressSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProverDelegatedSlotBalance" => {
#[allow(non_camel_case_types)]
struct GetProverDelegatedSlotBalanceSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetProverDelegatedSlotBalanceRequest,
> for GetProverDelegatedSlotBalanceSvc<T>
{
type Response = super::super::types::GetProverDelegatedSlotBalanceResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetProverDelegatedSlotBalanceRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_prover_delegated_slot_balance(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProverDelegatedSlotBalanceSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetSlotDelegationDetails" => {
#[allow(non_camel_case_types)]
struct GetSlotDelegationDetailsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetSlotDelegationDetailsRequest,
> for GetSlotDelegationDetailsSvc<T>
{
type Response = super::super::types::GetSlotDelegationDetailsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetSlotDelegationDetailsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_slot_delegation_details(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetSlotDelegationDetailsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTitan1DelegationLimit" => {
#[allow(non_camel_case_types)]
struct GetTitan1DelegationLimitSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetTitan1DelegationLimitRequest,
> for GetTitan1DelegationLimitSvc<T>
{
type Response = super::super::types::GetTitan1DelegationLimitResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetTitan1DelegationLimitRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_titan1_delegation_limit(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTitan1DelegationLimitSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/AddRefVisit" => {
#[allow(non_camel_case_types)]
struct AddRefVisitSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::AddRefVisitRequest>
for AddRefVisitSvc<T>
{
type Response = super::super::types::AddRefVisitResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::AddRefVisitRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::add_ref_visit(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = AddRefVisitSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetProverDelegateRequestCount" => {
#[allow(non_camel_case_types)]
struct GetProverDelegateRequestCountSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetProverDelegateRequestCountRequest,
> for GetProverDelegateRequestCountSvc<T>
{
type Response = super::super::types::GetProverDelegateRequestCountResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetProverDelegateRequestCountRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_prover_delegate_request_count(
&inner, request,
)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetProverDelegateRequestCountSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTitanCloudProvers" => {
#[allow(non_camel_case_types)]
struct GetTitanCloudProversSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetTitanCloudProversRequest,
> for GetTitanCloudProversSvc<T>
{
type Response = super::super::types::GetTitanCloudProversResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetTitanCloudProversRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_titan_cloud_provers(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTitanCloudProversSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredTitan1Ids" => {
#[allow(non_camel_case_types)]
struct GetFilteredTitan1IdsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredTitan1IdsRequest,
> for GetFilteredTitan1IdsSvc<T>
{
type Response = super::super::types::GetFilteredTitan1IdsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredTitan1IdsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_titan1_ids(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredTitan1IdsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetFilteredTitan1Slots" => {
#[allow(non_camel_case_types)]
struct GetFilteredTitan1SlotsSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetFilteredTitan1SlotsRequest,
> for GetFilteredTitan1SlotsSvc<T>
{
type Response = super::super::types::GetFilteredTitan1SlotsResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetFilteredTitan1SlotsRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_filtered_titan1_slots(&inner, request)
.await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetFilteredTitan1SlotsSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTitan1RewardsData" => {
#[allow(non_camel_case_types)]
struct GetTitan1RewardsDataSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<
super::super::types::GetTitan1RewardsDataRequest,
> for GetTitan1RewardsDataSvc<T>
{
type Response = super::super::types::GetTitan1RewardsDataResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetTitan1RewardsDataRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_titan1_rewards_data(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTitan1RewardsDataSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTitan1WorkGraph" => {
#[allow(non_camel_case_types)]
struct GetTitan1WorkGraphSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetTitan1WorkGraphRequest>
for GetTitan1WorkGraphSvc<T>
{
type Response = super::super::types::GetTitan1WorkGraphResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<super::super::types::GetTitan1WorkGraphRequest>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_titan1_work_graph(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTitan1WorkGraphSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
"/network.ProverNetwork/GetTitan1ClaimProof" => {
#[allow(non_camel_case_types)]
struct GetTitan1ClaimProofSvc<T: ProverNetwork>(pub Arc<T>);
impl<T: ProverNetwork>
tonic::server::UnaryService<super::super::types::GetTitan1ClaimProofRequest>
for GetTitan1ClaimProofSvc<T>
{
type Response = super::super::types::GetTitan1ClaimProofResponse;
type Future = BoxFuture<tonic::Response<Self::Response>, tonic::Status>;
fn call(
&mut self,
request: tonic::Request<
super::super::types::GetTitan1ClaimProofRequest,
>,
) -> Self::Future {
let inner = Arc::clone(&self.0);
let fut = async move {
<T as ProverNetwork>::get_titan1_claim_proof(&inner, request).await
};
Box::pin(fut)
}
}
let accept_compression_encodings = self.accept_compression_encodings;
let send_compression_encodings = self.send_compression_encodings;
let max_decoding_message_size = self.max_decoding_message_size;
let max_encoding_message_size = self.max_encoding_message_size;
let inner = self.inner.clone();
let fut = async move {
let method = GetTitan1ClaimProofSvc(inner);
let codec = tonic::codec::ProstCodec::default();
let mut grpc = tonic::server::Grpc::new(codec)
.apply_compression_config(
accept_compression_encodings,
send_compression_encodings,
)
.apply_max_message_size_config(
max_decoding_message_size,
max_encoding_message_size,
);
let res = grpc.unary(method, req).await;
Ok(res)
};
Box::pin(fut)
}
_ => Box::pin(async move {
let mut response = http::Response::new(empty_body());
let headers = response.headers_mut();
headers.insert(
tonic::Status::GRPC_STATUS,
(tonic::Code::Unimplemented as i32).into(),
);
headers.insert(http::header::CONTENT_TYPE, tonic::metadata::GRPC_CONTENT_TYPE);
Ok(response)
}),
}
}
}
impl<T> Clone for ProverNetworkServer<T> {
fn clone(&self) -> Self {
let inner = self.inner.clone();
Self {
inner,
accept_compression_encodings: self.accept_compression_encodings,
send_compression_encodings: self.send_compression_encodings,
max_decoding_message_size: self.max_decoding_message_size,
max_encoding_message_size: self.max_encoding_message_size,
}
}
}
pub const SERVICE_NAME: &str = "network.ProverNetwork";
impl<T> tonic::server::NamedService for ProverNetworkServer<T> {
const NAME: &'static str = SERVICE_NAME;
}
}