Struct ManagedConnection 

pub struct ManagedConnection {
    pub id: ChannelId,
    pub ticker: Option<KiteTickerAsync>,
    pub subscriber: Option<KiteTickerSubscriber>,
    pub subscribed_symbols: HashMap<u32, Mode>,
    pub stats: Arc<RwLock<ConnectionStats>>,
    pub is_healthy: Arc<AtomicBool>,
    pub last_ping: Arc<AtomicU64>,
    pub task_handle: Option<JoinHandle<()>>,
    pub heartbeat_handle: Option<JoinHandle<()>>,
    pub message_sender: UnboundedSender<TickerMessage>,
    /* private fields */
}

Represents a single WebSocket connection with its metadata

Fields

id: ChannelId

ticker: Option<KiteTickerAsync>

subscriber: Option<KiteTickerSubscriber>

subscribed_symbols: HashMap<u32, Mode>

stats: Arc<RwLock<ConnectionStats>>

is_healthy: Arc<AtomicBool>

last_ping: Arc<AtomicU64>

task_handle: Option<JoinHandle<()>>

heartbeat_handle: Option<JoinHandle<()>>

message_sender: UnboundedSender<TickerMessage>

Implementations

impl ManagedConnection

pub fn new( id: ChannelId, message_sender: UnboundedSender<TickerMessage>, ) -> Self

pub async fn connect( &mut self, api_key: &str, access_token: &str, config: &KiteManagerConfig, ) -> Result<(), String>

Connect to WebSocket and start message processing

pub async fn connect_with_raw( &mut self, api_key: &str, access_token: &str, config: &KiteManagerConfig, raw_only: bool, ) -> Result<(), String>

Connect with explicit raw_only flag

pub async fn subscribe_symbols( &mut self, symbols: &[u32], mode: Mode, ) -> Result<(), String>

Subscribe to symbols on this connection

pub async fn add_symbols( &mut self, symbols: &[u32], mode: Mode, ) -> Result<(), String>

Dynamically add new symbols to existing subscription

pub async fn remove_symbols(&mut self, symbols: &[u32]) -> Result<(), String>

Dynamically remove symbols from existing subscription

pub async fn start_message_processing(&mut self) -> Result<(), String>

Start message processing for the subscriber

pub fn can_accept_symbols( &self, count: usize, max_per_connection: usize, ) -> bool

Check if connection can accept more symbols

pub fn symbol_count(&self) -> usize

Get current symbol count

pub fn is_healthy(&self) -> bool

Check if connection is healthy

Trait Implementations

impl Debug for ManagedConnection

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

Formats the value using the given formatter.