Struct AlpacaWebSocketClient 

pub struct AlpacaWebSocketClient { /* private fields */ }

WebSocket client for Alpaca API

Implementations

impl AlpacaWebSocketClient

pub fn new(credentials: Credentials, environment: Environment) -> Self

Create a new WebSocket client for stocks

pub fn from_env(environment: Environment) -> Result<Self>

Create a new client from environment variables

pub fn with_feed( credentials: Credentials, environment: Environment, feed: DataFeed, ) -> Self

Create a WebSocket client for a specific data feed

pub fn crypto(credentials: Credentials, environment: Environment) -> Self

Create a crypto WebSocket client

pub fn crypto_from_env(environment: Environment) -> Result<Self>

Create a crypto client from environment variables

pub fn trading(credentials: Credentials, environment: Environment) -> Self

Create a trading WebSocket client

pub async fn connect(&self) -> Result<AlpacaStream>

Connect to the WebSocket and return a stream of messages

pub async fn connect_with_reconnect( &self, max_retries: u32, ) -> Result<AlpacaStream>

Connect with automatic reconnection

pub async fn subscribe_market_data( &self, subscription: SubscribeMessage, ) -> Result<MarketDataStream>

Subscribe to market data

pub async fn subscribe_trading_updates(&self) -> Result<TradingStream>

Subscribe to trading updates

pub async fn send_subscription( &self, subscription: SubscribeMessage, ) -> Result<()>

Send subscription message

pub async fn send_unsubscription( &self, unsubscription: UnsubscribeMessage, ) -> Result<()>

Send unsubscription message

pub fn url(&self) -> &str

Get the WebSocket URL

pub fn environment(&self) -> &Environment

Get the environment

Trait Implementations

impl Debug for AlpacaWebSocketClient

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

Formats the value using the given formatter.