pub struct Bitfinex;Expand description
Bitfinex exchange.
Trait Implementations§
Source§impl Connector for Bitfinex
impl Connector for Bitfinex
Source§const ID: ExchangeId = ExchangeId::Bitfinex
const ID: ExchangeId = ExchangeId::Bitfinex
Unique identifier for the exchange server being connected with.
Source§type Channel = BitfinexChannel
type Channel = BitfinexChannel
Type that defines how to translate a Barter
Subscription into an exchange specific
channel to be subscribed to. Read moreSource§type Market = BitfinexMarket
type Market = BitfinexMarket
Type that defines how to translate a Barter
Subscription into an exchange specific market that
can be subscribed to. Read moreSource§type Subscriber = WebSocketSubscriber
type Subscriber = WebSocketSubscriber
Subscriber type that establishes a connection with the exchange server, and actions
Subscriptions over the socket.Source§type SubValidator = BitfinexWebSocketSubValidator
type SubValidator = BitfinexWebSocketSubValidator
SubscriptionValidator type that listens to responses from the exchange server and
validates if the actioned Subscriptions were
successful.Source§type SubResponse = BitfinexPlatformEvent
type SubResponse = BitfinexPlatformEvent
Deserialisable type that the
Self::SubValidator expects to receive from the exchange server in
response to the Subscription Self::requests
sent over the WebSocket. Implements
Validator in order to determine if Self
communicates a successful Subscription outcome.Source§fn requests(
exchange_subs: Vec<ExchangeSub<Self::Channel, Self::Market>>,
) -> Vec<WsMessage> ⓘ
fn requests( exchange_subs: Vec<ExchangeSub<Self::Channel, Self::Market>>, ) -> Vec<WsMessage> ⓘ
Defines how to translate a collection of
ExchangeSubs into the WsMessage
subscription payloads sent to the exchange server.Source§fn ping_interval() -> Option<PingInterval>
fn ping_interval() -> Option<PingInterval>
Defines
PingInterval of custom application-level
WebSocket pings for the exchange
server being connected with. Read moreSource§fn expected_responses<InstrumentKey>(map: &Map<InstrumentKey>) -> usize
fn expected_responses<InstrumentKey>(map: &Map<InstrumentKey>) -> usize
Number of
Subscription responses expected from the
exchange server in responses to the requests send. Used to validate all
Subscriptions were accepted.Source§fn subscription_timeout() -> Duration
fn subscription_timeout() -> Duration
Expected
Duration the SubscriptionValidator will wait to receive all success
responses to actioned Subscription requests.Source§impl<'de> Deserialize<'de> for Bitfinex
impl<'de> Deserialize<'de> for Bitfinex
Source§fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>where
D: Deserializer<'de>,
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>where
D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Source§impl Ord for Bitfinex
impl Ord for Bitfinex
Source§impl PartialOrd for Bitfinex
impl PartialOrd for Bitfinex
Source§impl<Instrument> StreamSelector<Instrument, PublicTrades> for Bitfinexwhere
Instrument: InstrumentData,
impl<Instrument> StreamSelector<Instrument, PublicTrades> for Bitfinexwhere
Instrument: InstrumentData,
type SnapFetcher = NoInitialSnapshots
type Stream = ExchangeStream<WebSocketParser, SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>, StatelessTransformer<Bitfinex, <Instrument as InstrumentData>::Key, PublicTrades, BitfinexMessage>>
impl Copy for Bitfinex
impl Eq for Bitfinex
impl StructuralPartialEq for Bitfinex
Auto Trait Implementations§
impl Freeze for Bitfinex
impl RefUnwindSafe for Bitfinex
impl Send for Bitfinex
impl Sync for Bitfinex
impl Unpin for Bitfinex
impl UnwindSafe for Bitfinex
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Comparable<K> for Q
impl<Q, K> Comparable<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more