pub struct OrdersServiceClient<T> { /* private fields */ }Expand description
Client for this service.
Generic over T: ClientTransport. For gRPC (HTTP/2), use
Http2Connection — it has honest poll_ready and composes with
tower::balance for multi-connection load balancing. For Connect
over HTTP/1.1 (or unknown protocol), use HttpClient.
§Working with the response
Unary calls return UnaryResponse<OwnedView<FooView>>.
view() borrows the response
message, so field access is zero-copy:
let resp = client.preview_order(request).await?;
let name: &str = resp.view().name; // borrow into the response bufferIf you need the owned struct (e.g. to store or pass by value), use
into_owned():
let owned = client.preview_order(request).await?.into_owned();into_view() keeps the
zero-copy decoded body (an OwnedView) without copying; field access on it
goes through .reborrow(). Streaming responses yield one
StreamMessage per received message from
.message().await — read fields zero-copy through the generated accessor
methods (msg.name()) or .view(), or convert with .to_owned_message().
Implementations§
Source§impl<T> OrdersServiceClient<T>
impl<T> OrdersServiceClient<T>
Sourcepub fn new(transport: T, config: ClientConfig) -> Self
pub fn new(transport: T, config: ClientConfig) -> Self
Create a new client with the given transport and configuration.
Sourcepub fn config(&self) -> &ClientConfig
pub fn config(&self) -> &ClientConfig
Get the client configuration.
Sourcepub fn config_mut(&mut self) -> &mut ClientConfig
pub fn config_mut(&mut self) -> &mut ClientConfig
Get a mutable reference to the client configuration.
Sourcepub async fn preview_order(
&self,
request: PreviewOrderRequest,
) -> Result<UnaryResponse<OwnedView<PreviewOrderResponseView<'static>>>, ConnectError>
pub async fn preview_order( &self, request: PreviewOrderRequest, ) -> Result<UnaryResponse<OwnedView<PreviewOrderResponseView<'static>>>, ConnectError>
Call the PreviewOrder RPC. Sends a request to /orders.v1.OrdersService/PreviewOrder.
Sourcepub async fn preview_order_with_options(
&self,
request: PreviewOrderRequest,
options: CallOptions,
) -> Result<UnaryResponse<OwnedView<PreviewOrderResponseView<'static>>>, ConnectError>
pub async fn preview_order_with_options( &self, request: PreviewOrderRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<PreviewOrderResponseView<'static>>>, ConnectError>
Call the PreviewOrder RPC with explicit per-call options. Options override ClientConfig defaults.
Sourcepub async fn create_order(
&self,
request: CreateOrderRequest,
) -> Result<UnaryResponse<OwnedView<CreateOrderResponseView<'static>>>, ConnectError>
pub async fn create_order( &self, request: CreateOrderRequest, ) -> Result<UnaryResponse<OwnedView<CreateOrderResponseView<'static>>>, ConnectError>
Call the CreateOrder RPC. Sends a request to /orders.v1.OrdersService/CreateOrder.
Sourcepub async fn create_order_with_options(
&self,
request: CreateOrderRequest,
options: CallOptions,
) -> Result<UnaryResponse<OwnedView<CreateOrderResponseView<'static>>>, ConnectError>
pub async fn create_order_with_options( &self, request: CreateOrderRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<CreateOrderResponseView<'static>>>, ConnectError>
Call the CreateOrder RPC with explicit per-call options. Options override ClientConfig defaults.
Sourcepub async fn cancel_order(
&self,
request: CancelOrderRequest,
) -> Result<UnaryResponse<OwnedView<CancelOrderResponseView<'static>>>, ConnectError>
pub async fn cancel_order( &self, request: CancelOrderRequest, ) -> Result<UnaryResponse<OwnedView<CancelOrderResponseView<'static>>>, ConnectError>
Call the CancelOrder RPC. Sends a request to /orders.v1.OrdersService/CancelOrder.
Sourcepub async fn cancel_order_with_options(
&self,
request: CancelOrderRequest,
options: CallOptions,
) -> Result<UnaryResponse<OwnedView<CancelOrderResponseView<'static>>>, ConnectError>
pub async fn cancel_order_with_options( &self, request: CancelOrderRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<CancelOrderResponseView<'static>>>, ConnectError>
Call the CancelOrder RPC with explicit per-call options. Options override ClientConfig defaults.
Sourcepub async fn cancel_all_orders(
&self,
request: CancelAllOrdersRequest,
) -> Result<UnaryResponse<OwnedView<CancelAllOrdersResponseView<'static>>>, ConnectError>
pub async fn cancel_all_orders( &self, request: CancelAllOrdersRequest, ) -> Result<UnaryResponse<OwnedView<CancelAllOrdersResponseView<'static>>>, ConnectError>
Call the CancelAllOrders RPC. Sends a request to /orders.v1.OrdersService/CancelAllOrders.
Sourcepub async fn cancel_all_orders_with_options(
&self,
request: CancelAllOrdersRequest,
options: CallOptions,
) -> Result<UnaryResponse<OwnedView<CancelAllOrdersResponseView<'static>>>, ConnectError>
pub async fn cancel_all_orders_with_options( &self, request: CancelAllOrdersRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<CancelAllOrdersResponseView<'static>>>, ConnectError>
Call the CancelAllOrders RPC with explicit per-call options. Options override ClientConfig defaults.
Sourcepub async fn cancel_all_after(
&self,
request: CancelAllAfterRequest,
) -> Result<UnaryResponse<OwnedView<CancelAllAfterResponseView<'static>>>, ConnectError>
pub async fn cancel_all_after( &self, request: CancelAllAfterRequest, ) -> Result<UnaryResponse<OwnedView<CancelAllAfterResponseView<'static>>>, ConnectError>
Call the CancelAllAfter RPC. Sends a request to /orders.v1.OrdersService/CancelAllAfter.
Sourcepub async fn cancel_all_after_with_options(
&self,
request: CancelAllAfterRequest,
options: CallOptions,
) -> Result<UnaryResponse<OwnedView<CancelAllAfterResponseView<'static>>>, ConnectError>
pub async fn cancel_all_after_with_options( &self, request: CancelAllAfterRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<CancelAllAfterResponseView<'static>>>, ConnectError>
Call the CancelAllAfter RPC with explicit per-call options. Options override ClientConfig defaults.
Sourcepub async fn batch_create_orders(
&self,
request: BatchCreateOrdersRequest,
) -> Result<UnaryResponse<OwnedView<BatchCreateOrdersResponseView<'static>>>, ConnectError>
pub async fn batch_create_orders( &self, request: BatchCreateOrdersRequest, ) -> Result<UnaryResponse<OwnedView<BatchCreateOrdersResponseView<'static>>>, ConnectError>
Call the BatchCreateOrders RPC. Sends a request to /orders.v1.OrdersService/BatchCreateOrders.
Sourcepub async fn batch_create_orders_with_options(
&self,
request: BatchCreateOrdersRequest,
options: CallOptions,
) -> Result<UnaryResponse<OwnedView<BatchCreateOrdersResponseView<'static>>>, ConnectError>
pub async fn batch_create_orders_with_options( &self, request: BatchCreateOrdersRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<BatchCreateOrdersResponseView<'static>>>, ConnectError>
Call the BatchCreateOrders RPC with explicit per-call options. Options override ClientConfig defaults.
Sourcepub async fn modify_order(
&self,
request: ModifyOrderRequest,
) -> Result<UnaryResponse<OwnedView<ModifyOrderResponseView<'static>>>, ConnectError>
pub async fn modify_order( &self, request: ModifyOrderRequest, ) -> Result<UnaryResponse<OwnedView<ModifyOrderResponseView<'static>>>, ConnectError>
Call the ModifyOrder RPC. Sends a request to /orders.v1.OrdersService/ModifyOrder.
Sourcepub async fn modify_order_with_options(
&self,
request: ModifyOrderRequest,
options: CallOptions,
) -> Result<UnaryResponse<OwnedView<ModifyOrderResponseView<'static>>>, ConnectError>
pub async fn modify_order_with_options( &self, request: ModifyOrderRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<ModifyOrderResponseView<'static>>>, ConnectError>
Call the ModifyOrder RPC with explicit per-call options. Options override ClientConfig defaults.
Sourcepub async fn batch_replace_orders(
&self,
request: BatchReplaceOrdersRequest,
) -> Result<UnaryResponse<OwnedView<BatchReplaceOrdersResponseView<'static>>>, ConnectError>
pub async fn batch_replace_orders( &self, request: BatchReplaceOrdersRequest, ) -> Result<UnaryResponse<OwnedView<BatchReplaceOrdersResponseView<'static>>>, ConnectError>
Call the BatchReplaceOrders RPC. Sends a request to /orders.v1.OrdersService/BatchReplaceOrders.
Sourcepub async fn batch_replace_orders_with_options(
&self,
request: BatchReplaceOrdersRequest,
options: CallOptions,
) -> Result<UnaryResponse<OwnedView<BatchReplaceOrdersResponseView<'static>>>, ConnectError>
pub async fn batch_replace_orders_with_options( &self, request: BatchReplaceOrdersRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<BatchReplaceOrdersResponseView<'static>>>, ConnectError>
Call the BatchReplaceOrders RPC with explicit per-call options. Options override ClientConfig defaults.
Sourcepub async fn batch_cancel_orders(
&self,
request: BatchCancelOrdersRequest,
) -> Result<UnaryResponse<OwnedView<BatchCancelOrdersResponseView<'static>>>, ConnectError>
pub async fn batch_cancel_orders( &self, request: BatchCancelOrdersRequest, ) -> Result<UnaryResponse<OwnedView<BatchCancelOrdersResponseView<'static>>>, ConnectError>
Call the BatchCancelOrders RPC. Sends a request to /orders.v1.OrdersService/BatchCancelOrders.
Sourcepub async fn batch_cancel_orders_with_options(
&self,
request: BatchCancelOrdersRequest,
options: CallOptions,
) -> Result<UnaryResponse<OwnedView<BatchCancelOrdersResponseView<'static>>>, ConnectError>
pub async fn batch_cancel_orders_with_options( &self, request: BatchCancelOrdersRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<BatchCancelOrdersResponseView<'static>>>, ConnectError>
Call the BatchCancelOrders RPC with explicit per-call options. Options override ClientConfig defaults.
Trait Implementations§
Source§impl<T: Clone> Clone for OrdersServiceClient<T>
impl<T: Clone> Clone for OrdersServiceClient<T>
Source§fn clone(&self) -> OrdersServiceClient<T>
fn clone(&self) -> OrdersServiceClient<T>
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more