Struct MakerDataClient 

pub struct MakerDataClient { /* private fields */ }

Maker data-plane client.

Implementations

impl MakerDataClient

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

pub async fn request_all<R: MakerDataRequest>( &self, request: R, timeout: Duration, ) -> Result<MakerResponse<R::Response>, MakerDataRequestError>

Fetch the complete response. A list request follows every page, so use request_page to stop early.

pub async fn request_page<R: MakerDataRequest>( &self, request: R, timeout: Duration, ) -> Result<MakerResponse<R::Response>, MakerDataRequestError>

Fetch exactly one page. Use request_all for a complete collection.

pub async fn all_pages<R: PagedRequest>( &self, request: R, timeout: Duration, ) -> Result<R::Response, MakerDataRequestError>

Every page of request at the server’s largest page size; its own limit and cursor are ignored. Pages after the first are appended.

pub fn subscribe_messages(&self) -> ManagedMessageReceiver

Receive owner-direct PositionUpdated, TradeExecuted and MakerCapsUpdated pushes alongside query responses. No subscription is required. Owner pushes begin after MmSummary recovery; quote lifecycle messages stay on the quote session. On reconnect or a stream gap, rebuild authoritative state (for example with maker_open_positions).

pub fn subscribe_reference_changes(&self) -> ReferenceChangeReceiver

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 MakerDataClient

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.