Struct Caster 

pub struct Caster { /* private fields */ }

Caster connects to a Rune Runtime and registers Rune handlers.

Implementations

impl Caster

pub fn new(config: CasterConfig) -> Self

Create a new Caster with the given configuration.

pub fn caster_id(&self) -> &str

Returns the caster ID.

pub fn config(&self) -> &CasterConfig

Returns a reference to the configuration.

pub fn rune_count(&self) -> usize

Returns the number of registered runes.

pub fn get_rune_config(&self, name: &str) -> Option<RuneConfig>

Returns the config of a registered rune by name.

pub fn is_stream_rune(&self, name: &str) -> bool

Check if a rune is registered as a stream handler.

pub fn stop(&self)

Signal the Caster to stop its run loop.

Safe to call from any thread or task. The run() method will return shortly after this is called. Idempotent — calling multiple times is safe.

pub fn rune_accepts_files(&self, name: &str) -> bool

Check if a rune handler accepts file attachments.

pub fn rune<F, Fut>(&self, config: RuneConfig, handler: F) -> SdkResult<()>

where F: Fn(RuneContext, Bytes) -> Fut + Send + Sync + 'static, Fut: Future<Output = SdkResult<Bytes>> + Send + 'static,

Register a unary rune handler.

The handler receives (RuneContext, Bytes) and returns Result<Bytes>.

Errors

Returns SdkError::DuplicateRune if a rune with the same name already exists.

pub fn rune_with_files<F, Fut>( &self, config: RuneConfig, handler: F, ) -> SdkResult<()>

where F: Fn(RuneContext, Bytes, Vec<FileAttachment>) -> Fut + Send + Sync + 'static, Fut: Future<Output = SdkResult<Bytes>> + Send + 'static,

Register a unary rune handler that accepts file attachments.

pub fn stream_rune<F, Fut>( &self, config: RuneConfig, handler: F, ) -> SdkResult<()>

where F: Fn(RuneContext, Bytes, StreamSender) -> Fut + Send + Sync + 'static, Fut: Future<Output = SdkResult<()>> + Send + 'static,

Register a streaming rune handler.

The handler receives (RuneContext, Bytes, StreamSender) and returns Result<()>.

pub fn stream_rune_with_files<F, Fut>( &self, config: RuneConfig, handler: F, ) -> SdkResult<()>

where F: Fn(RuneContext, Bytes, Vec<FileAttachment>, StreamSender) -> Fut + Send + Sync + 'static, Fut: Future<Output = SdkResult<()>> + Send + 'static,

Register a streaming rune handler that accepts file attachments.

pub async fn run(&self) -> SdkResult<()>

Start the Caster (blocking async). Connects to Runtime with auto-reconnect.

Returns when the session ends normally, or when stop() is called, or on unrecoverable error.