Struct PolychartServiceClient 

pub struct PolychartServiceClient<T> { /* private fields */ }

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.get_market_layers(request).await?;
let name: &str = resp.view().name;  // borrow into the response buffer

If you need the owned struct (e.g. to store or pass by value), use into_owned():

let owned = client.get_market_layers(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

impl<T> PolychartServiceClient<T>

where T: ClientTransport, <T::ResponseBody as Body>::Error: Display,

pub fn new(transport: T, config: ClientConfig) -> Self

Create a new client with the given transport and configuration.

pub fn config(&self) -> &ClientConfig

Get the client configuration.

pub fn config_mut(&mut self) -> &mut ClientConfig

Get a mutable reference to the client configuration.

pub async fn get_market_layers( &self, request: GetMarketLayersRequest, ) -> Result<UnaryResponse<OwnedView<GetMarketLayersResponseView<'static>>>, ConnectError>

Call the GetMarketLayers RPC. Sends a request to /polychart.v1.PolychartService/GetMarketLayers.

pub async fn get_market_layers_with_options( &self, request: GetMarketLayersRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<GetMarketLayersResponseView<'static>>>, ConnectError>

Call the GetMarketLayers RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn list_inbox_market_layers( &self, request: ListInboxMarketLayersRequest, ) -> Result<UnaryResponse<OwnedView<ListInboxMarketLayersResponseView<'static>>>, ConnectError>

Call the ListInboxMarketLayers RPC. Sends a request to /polychart.v1.PolychartService/ListInboxMarketLayers.

pub async fn list_inbox_market_layers_with_options( &self, request: ListInboxMarketLayersRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<ListInboxMarketLayersResponseView<'static>>>, ConnectError>

Call the ListInboxMarketLayers RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn get_layer_snapshot( &self, request: GetLayerSnapshotRequest, ) -> Result<UnaryResponse<OwnedView<GetLayerSnapshotResponseView<'static>>>, ConnectError>

Call the GetLayerSnapshot RPC. Sends a request to /polychart.v1.PolychartService/GetLayerSnapshot.

pub async fn get_layer_snapshot_with_options( &self, request: GetLayerSnapshotRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<GetLayerSnapshotResponseView<'static>>>, ConnectError>

Call the GetLayerSnapshot RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn get_layer_subscribe_tokens( &self, request: GetLayerSubscribeTokensRequest, ) -> Result<UnaryResponse<OwnedView<GetLayerSubscribeTokensResponseView<'static>>>, ConnectError>

Call the GetLayerSubscribeTokens RPC. Sends a request to /polychart.v1.PolychartService/GetLayerSubscribeTokens.

pub async fn get_layer_subscribe_tokens_with_options( &self, request: GetLayerSubscribeTokensRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<GetLayerSubscribeTokensResponseView<'static>>>, ConnectError>

Call the GetLayerSubscribeTokens RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn resolve_layer_share_token( &self, request: ResolveLayerShareTokenRequest, ) -> Result<UnaryResponse<OwnedView<ResolveLayerShareTokenResponseView<'static>>>, ConnectError>

Call the ResolveLayerShareToken RPC. Sends a request to /polychart.v1.PolychartService/ResolveLayerShareToken.

pub async fn resolve_layer_share_token_with_options( &self, request: ResolveLayerShareTokenRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<ResolveLayerShareTokenResponseView<'static>>>, ConnectError>

Call the ResolveLayerShareToken RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn create_layer_share_link( &self, request: CreateLayerShareLinkRequest, ) -> Result<UnaryResponse<OwnedView<CreateLayerShareLinkResponseView<'static>>>, ConnectError>

Call the CreateLayerShareLink RPC. Sends a request to /polychart.v1.PolychartService/CreateLayerShareLink.

pub async fn create_layer_share_link_with_options( &self, request: CreateLayerShareLinkRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<CreateLayerShareLinkResponseView<'static>>>, ConnectError>

Call the CreateLayerShareLink RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn revoke_layer_share_link( &self, request: RevokeLayerShareLinkRequest, ) -> Result<UnaryResponse<OwnedView<RevokeLayerShareLinkResponseView<'static>>>, ConnectError>

Call the RevokeLayerShareLink RPC. Sends a request to /polychart.v1.PolychartService/RevokeLayerShareLink.

pub async fn revoke_layer_share_link_with_options( &self, request: RevokeLayerShareLinkRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<RevokeLayerShareLinkResponseView<'static>>>, ConnectError>

Call the RevokeLayerShareLink RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn list_owner_published_layers( &self, request: ListOwnerPublishedLayersRequest, ) -> Result<UnaryResponse<OwnedView<ListOwnerPublishedLayersResponseView<'static>>>, ConnectError>

Call the ListOwnerPublishedLayers RPC. Sends a request to /polychart.v1.PolychartService/ListOwnerPublishedLayers.

pub async fn list_owner_published_layers_with_options( &self, request: ListOwnerPublishedLayersRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<ListOwnerPublishedLayersResponseView<'static>>>, ConnectError>

Call the ListOwnerPublishedLayers RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn publish_layer( &self, request: PublishLayerRequest, ) -> Result<UnaryResponse<OwnedView<PublishLayerResponseView<'static>>>, ConnectError>

Call the PublishLayer RPC. Sends a request to /polychart.v1.PolychartService/PublishLayer.

pub async fn publish_layer_with_options( &self, request: PublishLayerRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<PublishLayerResponseView<'static>>>, ConnectError>

Call the PublishLayer RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn unpublish_layer( &self, request: UnpublishLayerRequest, ) -> Result<UnaryResponse<OwnedView<UnpublishLayerResponseView<'static>>>, ConnectError>

Call the UnpublishLayer RPC. Sends a request to /polychart.v1.PolychartService/UnpublishLayer.

pub async fn unpublish_layer_with_options( &self, request: UnpublishLayerRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<UnpublishLayerResponseView<'static>>>, ConnectError>

Call the UnpublishLayer RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn upsert_layer( &self, request: UpsertLayerRequest, ) -> Result<UnaryResponse<OwnedView<UpsertLayerResponseView<'static>>>, ConnectError>

Call the UpsertLayer RPC. Sends a request to /polychart.v1.PolychartService/UpsertLayer.

pub async fn upsert_layer_with_options( &self, request: UpsertLayerRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<UpsertLayerResponseView<'static>>>, ConnectError>

Call the UpsertLayer RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn delete_layer( &self, request: DeleteLayerRequest, ) -> Result<UnaryResponse<OwnedView<DeleteLayerResponseView<'static>>>, ConnectError>

Call the DeleteLayer RPC. Sends a request to /polychart.v1.PolychartService/DeleteLayer.

pub async fn delete_layer_with_options( &self, request: DeleteLayerRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<DeleteLayerResponseView<'static>>>, ConnectError>

Call the DeleteLayer RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn upsert_drawing( &self, request: UpsertDrawingRequest, ) -> Result<UnaryResponse<OwnedView<UpsertDrawingResponseView<'static>>>, ConnectError>

Call the UpsertDrawing RPC. Sends a request to /polychart.v1.PolychartService/UpsertDrawing.

pub async fn upsert_drawing_with_options( &self, request: UpsertDrawingRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<UpsertDrawingResponseView<'static>>>, ConnectError>

Call the UpsertDrawing RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn delete_drawing( &self, request: DeleteDrawingRequest, ) -> Result<UnaryResponse<OwnedView<DeleteDrawingResponseView<'static>>>, ConnectError>

Call the DeleteDrawing RPC. Sends a request to /polychart.v1.PolychartService/DeleteDrawing.

pub async fn delete_drawing_with_options( &self, request: DeleteDrawingRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<DeleteDrawingResponseView<'static>>>, ConnectError>

Call the DeleteDrawing RPC with explicit per-call options. Options override ClientConfig defaults.

pub async fn set_layer_subscriptions( &self, request: SetLayerSubscriptionsRequest, ) -> Result<UnaryResponse<OwnedView<SetLayerSubscriptionsResponseView<'static>>>, ConnectError>

Call the SetLayerSubscriptions RPC. Sends a request to /polychart.v1.PolychartService/SetLayerSubscriptions.

pub async fn set_layer_subscriptions_with_options( &self, request: SetLayerSubscriptionsRequest, options: CallOptions, ) -> Result<UnaryResponse<OwnedView<SetLayerSubscriptionsResponseView<'static>>>, ConnectError>

Call the SetLayerSubscriptions RPC with explicit per-call options. Options override ClientConfig defaults.

Trait Implementations

impl<T: Clone> Clone for PolychartServiceClient<T>

fn clone(&self) -> PolychartServiceClient<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.