Struct barter_data::exchange::ftx::Ftx

pub struct Ftx {
    pub ids: SubscriptionIds,
}

Fields

ids: SubscriptionIds

Trait Implementations

impl Clone for Ftx

fn clone(&self) -> Ftx

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Ftx

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Ftx

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl ExchangeTransformer for Ftx

const EXCHANGE: ExchangeTransformerId = ExchangeTransformerId::Ftx

Unique identifier for an ExchangeTransformer.

fn new(ids: SubscriptionIds) -> Self

Construct a new ExchangeTransformer using a HashMap containing the relationship between all active Barter Subscriptions and their associated exchange specific identifiers.

impl PartialEq<Ftx> for Ftx

fn eq(&self, other: &Ftx) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Ftx) -> bool

This method tests for !=.

impl Serialize for Ftx

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.

impl Subscriber for Ftx

type SubResponse = FtxSubResponse

Deserialisable type that this Subscriber expects to receive from the exchange in response to Subscription requests. Implements Validator in order to determine if the SubResponse communicates a successful outcome.

fn base_url() -> &'static str

Returns the Base URL of the exchange to establish a connection with.

fn build_subscription_meta(
    subscriptions: &[Subscription]
) -> Result<SubscriptionMeta, SocketError>

Uses the provided Barter Subscriptions to build exchange specific subscription payloads. Generates a SubscriptionIds Hashmap that is used by an ExchangeTransformer to identify the Barter Subscriptions associated with received messages.

fn subscribe<'life0, 'async_trait>(
    subscriptions: &'life0 [Subscription]
) -> Pin<Box<dyn Future<Output = Result<(WebSocket, SubscriptionIds), SocketError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: Send + 'async_trait, 

Initialises a WebSocket connection, actions the provided collection of Barter Subscriptions, and validates that the Subscription were accepted by the exchange.

fn validate<'life0, 'async_trait>(
    websocket: &'life0 mut WebSocket,
    expected_responses: usize
) -> Pin<Box<dyn Future<Output = Result<(), SocketError>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: Send + 'async_trait, 

Uses the provided WebSocket connection to consume Subscription responses and validate their outcomes.

fn subscription_timeout() -> Duration

Return the expected Duration in which the exchange will respond to all actioned WebSocket Subscription requests.

impl Transformer<MarketData> for Ftx

type Input = FtxMessage

type OutputIter = Vec<Result<MarketData, SocketError>, Global>

fn transform(&mut self, input: Self::Input) -> Self::OutputIter

impl Eq for Ftx

impl StructuralEq for Ftx

impl StructuralPartialEq for Ftx