Struct MakerQuoteClient 

pub struct MakerQuoteClient { /* private fields */ }

Maker quote-plane client.

try_* methods return immediately when the outbound queue is full. A successful SendTicket reports a socket write, not a server acknowledgement.

Implementations

impl MakerQuoteClient

pub fn spawn(config: ManagedWsConfig) -> Result<Self, MakerClientError>

pub async fn quote(&self, payload: QuoteMessage) -> Result<(), ManagedWsError>

pub fn try_quote( &self, payload: QuoteMessage, ) -> Result<SendTicket, ManagedWsError>

pub async fn replace_quote( &self, payload: ReplaceQuoteMessage, ) -> Result<(), ManagedWsError>

pub fn try_replace_quote( &self, payload: ReplaceQuoteMessage, ) -> Result<SendTicket, ManagedWsError>

pub async fn batch_quotes( &self, payload: BatchQuotesMessage, ) -> Result<(), ManagedWsError>

pub fn try_batch_quotes( &self, payload: BatchQuotesMessage, ) -> Result<SendTicket, ManagedWsError>

pub async fn cancel_quote( &self, payload: CancelQuoteData, ) -> Result<(), ManagedWsError>

pub fn try_cancel_quote( &self, payload: CancelQuoteData, ) -> Result<SendTicket, ManagedWsError>

pub async fn cancel_all_quotes( &self, payload: CancelAllQuotesMessage, ) -> Result<(), ManagedWsError>

pub fn try_cancel_all_quotes( &self, payload: CancelAllQuotesMessage, ) -> Result<SendTicket, ManagedWsError>

pub async fn indicative_prices_response( &self, payload: IndicativePricesResponseMessage, ) -> Result<(), ManagedWsError>

pub fn try_indicative_prices_response( &self, payload: IndicativePricesResponseMessage, ) -> Result<SendTicket, ManagedWsError>

pub async fn subscribe( &self, payload: SubscribeData, ) -> Result<(), ManagedWsError>

pub async fn unsubscribe( &self, payload: UnsubscribeData, ) -> Result<(), ManagedWsError>

pub async fn add_mints( &self, payload: AddMintsData, ) -> Result<(), ManagedWsError>

pub async fn remove_mints( &self, payload: RemoveMintsData, ) -> Result<(), ManagedWsError>

pub async fn add_channels( &self, payload: AddChannelsData, ) -> Result<(), ManagedWsError>

pub async fn remove_channels( &self, payload: RemoveChannelsData, ) -> Result<(), ManagedWsError>

pub fn subscribe_messages(&self) -> ManagedMessageReceiver

pub fn subscribe_events(&self) -> Receiver<ManagedWsEvent>

pub fn state(&self) -> ManagedWsState

pub async fn wait_until_ready(&self) -> Result<u64, WaitUntilReadyError>

pub const fn raw(&self) -> &ManagedWsHandle

pub fn into_raw(self) -> ManagedWsHandle

pub async fn close(&self) -> Result<(), ManagedWsError>

Trait Implementations

impl Clone for MakerQuoteClient

fn clone(&self) -> MakerQuoteClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.