Struct TheaterClient

pub struct TheaterClient { /* private fields */ }

High-level client for Theater server operations

Implementations

impl TheaterClient

pub fn new(address: SocketAddr) -> Self

Create a new TheaterClient

pub async fn address(&self) -> SocketAddr

Get the server address

pub async fn is_connected(&self) -> bool

Check if connected to the server

pub async fn connect(&self) -> CliResult<()>

Explicitly connect to the server (usually not needed as commands auto-connect)

pub async fn close(&self)

Close the connection

pub async fn list_actors(&self) -> CliResult<Vec<(String, String)>>

List all running actors

pub async fn start_actor( &self, manifest_content: String, initial_state: Option<Vec<u8>>, parent: bool, subscribe: bool, ) -> CliResult<()>

Start an actor from a manifest

pub async fn stop_actor(&self, actor_id: &str) -> CliResult<()>

Stop a running actor

pub async fn get_actor_state(&self, actor_id: &str) -> CliResult<Value>

Get actor state

pub async fn get_actor_events( &self, actor_id: &str, ) -> CliResult<Vec<ChainEvent>>

Get actor events

pub async fn send_message( &self, actor_id: &str, message: Vec<u8>, ) -> CliResult<()>

Send a message to an actor (fire and forget)

pub async fn request_message( &self, actor_id: &str, message: Vec<u8>, ) -> CliResult<Vec<u8>>

Send a request to an actor and wait for response

pub async fn subscribe_to_events( &self, actor_id: &str, ) -> CliResult<EventStream>

Subscribe to events from an actor (returns a stream-like interface)

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

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

pub async fn get_actor_status(&self, actor_id: &str) -> CliResult<String>

Get actor status

pub async fn restart_actor(&self, actor_id: &str) -> CliResult<()>

Restart an actor

pub async fn update_actor_component( &self, actor_id: &str, component: String, ) -> CliResult<()>

Update actor component

pub async fn unsubscribe_from_actor( &self, actor_id: &str, subscription_id: Uuid, ) -> CliResult<()>

Unsubscribe from actor events

pub async fn open_channel( &self, actor_id: &str, initial_message: Vec<u8>, ) -> CliResult<String>

Open a channel with an actor

pub async fn send_on_channel( &self, channel_id: &str, message: Vec<u8>, ) -> CliResult<()>

Send a message on a channel

pub async fn close_channel(&self, channel_id: &str) -> CliResult<()>

Close a channel

pub async fn receive_channel_message( &self, ) -> CliResult<Option<(String, Vec<u8>)>>

Receive channel message (for channel communication)

Trait Implementations

impl Clone for TheaterClient

fn clone(&self) -> TheaterClient

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TheaterClient

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

Formats the value using the given formatter.