Struct Connection

pub struct Connection { /* private fields */ }

A connection to the Theater server with automatic reconnection

Implementations

impl Connection

pub fn new(address: SocketAddr, config: Config) -> Self

pub async fn ensure_connected(&mut self) -> CliResult<()>

Ensure we have an active connection, reconnecting if necessary

pub async fn send_command( &mut self, command: ManagementCommand, ) -> CliResult<ManagementResponse>

Send a command and wait for a response

pub async fn send_command_no_response( &mut self, command: ManagementCommand, ) -> CliResult<()>

Send a command without waiting for a response

pub async fn next_response(&mut self) -> CliResult<Option<ManagementResponse>>

Get the next response from the connection (for streaming operations)

pub fn is_connected(&self) -> bool

Check if the connection is currently active

pub fn address(&self) -> SocketAddr

Get the server address

pub fn last_error(&self) -> Option<&str>

Get the last connection error, if any

pub async fn close(&mut self)

Close the connection

Trait Implementations

impl Debug for Connection

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

Formats the value using the given formatter.

impl Drop for Connection

fn drop(&mut self)

Executes the destructor for this type.