Struct Connection 

pub struct Connection {
    pub write_buffer: Vec<u8>,
    pub connection_id: usize,
    pub subscription_count: usize,
    pub client_name: Option<String>,
    pub client_addr: Option<SocketAddr>,
    pub connected_at: u64,
    pub commands_processed: u64,
    pub flags: Vec<String>,
    /* private fields */
}

Manages a client connection with RESP protocol handling

Handles command parsing, execution, and response buffering.

Fields

write_buffer: Vec<u8>

connection_id: usize

subscription_count: usize

client_name: Option<String>

client_addr: Option<SocketAddr>

connected_at: u64

commands_processed: u64

flags: Vec<String>

Implementations

impl Connection

pub fn new( fd: RawFd, buffer_size: usize, store: Arc<FeoxStore>, config: &Config, ) -> Self

Create a new connection handler

pub fn set_client_registry(&mut self, registry: Arc<ClientRegistry>)

Set the executor with client registry info

pub fn new_with_addr( fd: RawFd, buffer_size: usize, store: Arc<FeoxStore>, config: &Config, addr: Option<SocketAddr>, ) -> Self

Create a new connection handler with address

pub fn fd(&self) -> RawFd

pub fn is_closed(&self) -> bool

pub fn close(&mut self)

pub fn set_authenticated(&mut self, authenticated: bool)

Set authentication status

pub fn is_authenticated(&self) -> bool

Check if connection is authenticated

pub fn process_read(&mut self, data: &[u8]) -> Result<Vec<PubSubOp>>

Process incoming data with inline execution Returns pub/sub operations that need to be executed

pub fn pending_writes(&mut self) -> Option<&[u8]>

Get pending write data as a single buffer slice

pub fn consume_writes(&mut self, n: usize)

Mark bytes as written

pub fn queue_pubsub_message(&mut self, message: PubSubMessage)

Add a pub/sub message to the pending queue

pub fn is_in_pubsub_mode(&self) -> bool

Check if connection is in pub/sub mode

pub fn set_subscription_count(&mut self, count: usize)

Update subscription count

pub fn process_pubsub_messages(&mut self)

Process pending pub/sub messages