Struct CoinbaseWebSocketHandler

pub struct CoinbaseWebSocketHandler { /* private fields */ }

Coinbase WebSocket handler

Implementations

impl CoinbaseWebSocketHandler

pub fn new() -> Self

Create a new handler

pub fn register_subscription(&self, key: String, info: SubscriptionInfo)

Register a subscription

Trait Implementations

impl Default for CoinbaseWebSocketHandler

fn default() -> Self

Returns the “default value” for a type.

impl ExchangeHandler for CoinbaseWebSocketHandler

fn exchange(&self) -> Exchange

Get the exchange type

fn get_subscriptions<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = WebSocketResult<Vec<Message>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get subscription messages

fn authenticate<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = WebSocketResult<Option<Message>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle authentication if required

fn requires_auth(&self) -> bool

Check if the connection needs authentication

fn get_heartbeat(&self) -> Option<Message>

Get heartbeat message if required

fn heartbeat_interval(&self) -> Option<Duration>

Get heartbeat interval

impl MessageHandler for CoinbaseWebSocketHandler

fn on_message<'life0, 'async_trait>( &'life0 mut self, message: Message, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle a received message

fn on_connected<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle connection established

fn on_disconnected<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = WebSocketResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle connection closed

fn on_error<'life0, 'async_trait>( &'life0 mut self, error: WebSocketError, ) -> Pin<Box<dyn Future<Output = Result<(), WebSocketError>> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

Handle errors

fn set_sender(&mut self, _sender: UnboundedSender<Message>)

Set the sender for outgoing messages (optional, default implementation does nothing)

fn send_message(&self, _message: Message) -> Result<(), WebSocketError>

Send a message through the WebSocket (optional, default implementation returns error)