Struct Rpc 

pub struct Rpc {
    pub api: FinamApi,
    pub limiter: Arc<BrokerLimiter>,
    pub timeout: Duration,
}

Everything a connector needs to make calls: clients, quota, deadline.

Cheap to clone. FinamRaw wraps it for application code.

Fields

api: FinamApi

Service clients with the shared token manager.

limiter: Arc<BrokerLimiter>

Rate limiter shared by all connectors of one Finam user.

timeout: Duration

Deadline of one unary call.

Implementations

impl Rpc

pub fn acquire(&self, method: &str) -> Result<(), Error>

Takes the quota for the proto method method.

Errors

[brokapi_core::Error::RateLimited] when a bucket on the route of method is empty. Nothing is consumed in that case and the request must not be sent.

pub async fn read<T, F, Fut>(&self, method: &str, f: F) -> Result<T, Error>

where F: Fn(FinamApi) -> Fut, Fut: Future<Output = Result<Response<T>, Status>>,

A read-only call: quota, deadline, one re-auth retry, public error mapping.

Errors

[brokapi_core::Error::RateLimited] (local quota or RESOURCE_EXHAUSTED), [brokapi_core::Error::Rejected] (the broker said no), [brokapi_core::Error::Transport] (connection failure or timeout). See crate::error::map_protocol_err.

pub async fn send_command<T, F, Fut>(&self, f: F) -> Result<T, FinamError>

where F: Fn(FinamApi) -> Fut, Fut: Future<Output = Result<Response<T>, Status>>,

A trading command: quota, deadline, NO retry. The raw protocol error is returned so the caller can tell “definitely rejected” from “unknown outcome”.

Quota is taken by the caller beforehand (acquire) so that a refusal happens before the command is registered as in flight.

Errors

The raw [FinamError]. Map it with crate::error::map_command_err.

Trait Implementations

impl Clone for Rpc

fn clone(&self) -> Rpc

Returns a duplicate of the value.

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

Performs copy-assignment from source.