Struct rhoast_client_v03::proto::casper::v1::deploy_service_client::DeployServiceClient
source · pub struct DeployServiceClient<T> { /* private fields */ }
Expand description
Use doDeploy
to queue deployments of Rholang code and then
ProposeServiceV2.propose
to make a new block with the results of running them
all.
To get results back, use listenForDataAtName
.
Implementations§
source§impl<T> DeployServiceClient<T>where
T: GrpcService<BoxBody>,
T::Error: Into<StdError>,
T::ResponseBody: Body<Data = Bytes> + Send + 'static,
<T::ResponseBody as Body>::Error: Into<StdError> + Send,
impl<T> DeployServiceClient<T>where T: GrpcService<BoxBody>, T::Error: Into<StdError>, T::ResponseBody: Body<Data = Bytes> + Send + 'static, <T::ResponseBody as Body>::Error: Into<StdError> + Send,
pub fn new(inner: T) -> Self
pub fn with_interceptor<F>( inner: T, interceptor: F ) -> DeployServiceClient<InterceptedService<T, F>>where F: Interceptor, T::ResponseBody: Default, T: Service<Request<BoxBody>, Response = Response<<T as GrpcService<BoxBody>>::ResponseBody>>, <T as Service<Request<BoxBody>>>::Error: Into<StdError> + Send + Sync,
sourcepub fn send_gzip(self) -> Self
pub fn send_gzip(self) -> Self
Compress requests with gzip
.
This requires the server to support it otherwise it might respond with an error.
sourcepub fn accept_gzip(self) -> Self
pub fn accept_gzip(self) -> Self
Enable decompressing responses with gzip
.
sourcepub async fn do_deploy(
&mut self,
request: impl IntoRequest<DeployDataProto>
) -> Result<Response<DeployResponse>, Status>
pub async fn do_deploy( &mut self, request: impl IntoRequest<DeployDataProto> ) -> Result<Response<DeployResponse>, Status>
Queue deployment of Rholang code (or fail to parse).
sourcepub async fn get_block(
&mut self,
request: impl IntoRequest<BlockQuery>
) -> Result<Response<BlockResponse>, Status>
pub async fn get_block( &mut self, request: impl IntoRequest<BlockQuery> ) -> Result<Response<BlockResponse>, Status>
Get details about a particular block.
sourcepub async fn visualize_dag(
&mut self,
request: impl IntoRequest<VisualizeDagQuery>
) -> Result<Response<Streaming<VisualizeBlocksResponse>>, Status>
pub async fn visualize_dag( &mut self, request: impl IntoRequest<VisualizeDagQuery> ) -> Result<Response<Streaming<VisualizeBlocksResponse>>, Status>
Get dag
pub async fn machine_verifiable_dag( &mut self, request: impl IntoRequest<MachineVerifyQuery> ) -> Result<Response<MachineVerifyResponse>, Status>
sourcepub async fn show_main_chain(
&mut self,
request: impl IntoRequest<BlocksQuery>
) -> Result<Response<Streaming<BlockInfoResponse>>, Status>
pub async fn show_main_chain( &mut self, request: impl IntoRequest<BlocksQuery> ) -> Result<Response<Streaming<BlockInfoResponse>>, Status>
Returns on success LightBlockInfo
sourcepub async fn get_blocks(
&mut self,
request: impl IntoRequest<BlocksQuery>
) -> Result<Response<Streaming<BlockInfoResponse>>, Status>
pub async fn get_blocks( &mut self, request: impl IntoRequest<BlocksQuery> ) -> Result<Response<Streaming<BlockInfoResponse>>, Status>
Get a summary of blocks on the blockchain.
sourcepub async fn listen_for_data_at_name(
&mut self,
request: impl IntoRequest<DataAtNameQuery>
) -> Result<Response<ListeningNameDataResponse>, Status>
pub async fn listen_for_data_at_name( &mut self, request: impl IntoRequest<DataAtNameQuery> ) -> Result<Response<ListeningNameDataResponse>, Status>
Find data sent to a name. OBSOLETE: Use getDataAtName instead. This method will be removed in the future version of RNode.
sourcepub async fn get_data_at_name(
&mut self,
request: impl IntoRequest<DataAtNameByBlockQuery>
) -> Result<Response<RhoDataResponse>, Status>
pub async fn get_data_at_name( &mut self, request: impl IntoRequest<DataAtNameByBlockQuery> ) -> Result<Response<RhoDataResponse>, Status>
Find data sent to a name.
sourcepub async fn listen_for_continuation_at_name(
&mut self,
request: impl IntoRequest<ContinuationAtNameQuery>
) -> Result<Response<ContinuationAtNameResponse>, Status>
pub async fn listen_for_continuation_at_name( &mut self, request: impl IntoRequest<ContinuationAtNameQuery> ) -> Result<Response<ContinuationAtNameResponse>, Status>
Find processes receiving on a name.
sourcepub async fn find_deploy(
&mut self,
request: impl IntoRequest<FindDeployQuery>
) -> Result<Response<FindDeployResponse>, Status>
pub async fn find_deploy( &mut self, request: impl IntoRequest<FindDeployQuery> ) -> Result<Response<FindDeployResponse>, Status>
Find block containing a deploy.
sourcepub async fn preview_private_names(
&mut self,
request: impl IntoRequest<PrivateNamePreviewQuery>
) -> Result<Response<PrivateNamePreviewResponse>, Status>
pub async fn preview_private_names( &mut self, request: impl IntoRequest<PrivateNamePreviewQuery> ) -> Result<Response<PrivateNamePreviewResponse>, Status>
Preview new top-level unforgeable names (for example, to compute signatures over them).
sourcepub async fn last_finalized_block(
&mut self,
request: impl IntoRequest<LastFinalizedBlockQuery>
) -> Result<Response<LastFinalizedBlockResponse>, Status>
pub async fn last_finalized_block( &mut self, request: impl IntoRequest<LastFinalizedBlockQuery> ) -> Result<Response<LastFinalizedBlockResponse>, Status>
Get details about a particular block.
sourcepub async fn is_finalized(
&mut self,
request: impl IntoRequest<IsFinalizedQuery>
) -> Result<Response<IsFinalizedResponse>, Status>
pub async fn is_finalized( &mut self, request: impl IntoRequest<IsFinalizedQuery> ) -> Result<Response<IsFinalizedResponse>, Status>
Check if a given block is finalized.
sourcepub async fn bond_status(
&mut self,
request: impl IntoRequest<BondStatusQuery>
) -> Result<Response<BondStatusResponse>, Status>
pub async fn bond_status( &mut self, request: impl IntoRequest<BondStatusQuery> ) -> Result<Response<BondStatusResponse>, Status>
Check if a given validator is bonded. Returns on success BondStatusResponse
sourcepub async fn exploratory_deploy(
&mut self,
request: impl IntoRequest<ExploratoryDeployQuery>
) -> Result<Response<ExploratoryDeployResponse>, Status>
pub async fn exploratory_deploy( &mut self, request: impl IntoRequest<ExploratoryDeployQuery> ) -> Result<Response<ExploratoryDeployResponse>, Status>
Executes deploy as user deploy with immediate rollback and return result
sourcepub async fn get_blocks_by_heights(
&mut self,
request: impl IntoRequest<BlocksQueryByHeight>
) -> Result<Response<Streaming<BlockInfoResponse>>, Status>
pub async fn get_blocks_by_heights( &mut self, request: impl IntoRequest<BlocksQueryByHeight> ) -> Result<Response<Streaming<BlockInfoResponse>>, Status>
get blocks by block height
sourcepub async fn get_event_by_hash(
&mut self,
request: impl IntoRequest<ReportQuery>
) -> Result<Response<EventInfoResponse>, Status>
pub async fn get_event_by_hash( &mut self, request: impl IntoRequest<ReportQuery> ) -> Result<Response<EventInfoResponse>, Status>
temporary api for testing
sourcepub async fn status(
&mut self,
request: impl IntoRequest<()>
) -> Result<Response<StatusResponse>, Status>
pub async fn status( &mut self, request: impl IntoRequest<()> ) -> Result<Response<StatusResponse>, Status>
Get node status
Trait Implementations§
source§impl<T: Clone> Clone for DeployServiceClient<T>
impl<T: Clone> Clone for DeployServiceClient<T>
source§fn clone(&self) -> DeployServiceClient<T>
fn clone(&self) -> DeployServiceClient<T>
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreAuto Trait Implementations§
impl<T> RefUnwindSafe for DeployServiceClient<T>where T: RefUnwindSafe,
impl<T> Send for DeployServiceClient<T>where T: Send,
impl<T> Sync for DeployServiceClient<T>where T: Sync,
impl<T> Unpin for DeployServiceClient<T>where T: Unpin,
impl<T> UnwindSafe for DeployServiceClient<T>where T: UnwindSafe,
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T
in a tonic::Request