Struct GaussianBlurActor 

pub struct GaussianBlurActor { /* private fields */ }

Implementations

impl GaussianBlurActor

pub fn new() -> Self

pub fn input_ports(&self) -> Vec<String>

Get a list of available input ports

pub fn output_ports(&self) -> Vec<String>

Get a list of available output ports

Trait Implementations

impl Actor for GaussianBlurActor

fn get_behavior(&self) -> ActorBehavior

The actor’s reaction to incoming data. This is the only thing an actor must define beyond port declarations.

fn get_outports(&self) -> Port

Access the outport channel pair (sender + receiver).

fn get_inports(&self) -> Port

Access the inport channel pair (sender + receiver).

fn inport_names(&self) -> Vec<String>

Declared input port names. Used by the runtime dispatch loop to know when all inports have data (for await_all_inports).

fn outport_names(&self) -> Vec<String>

Declared output port names.

fn await_all_inports(&self) -> bool

When true, the runtime accumulates packets until every declared inport has received data before invoking the behavior.

fn required_inports(&self) -> Vec<String>

Selective await: the runtime accumulates packets until all listed inports have received data. Unlisted inports are optional. Empty vec = no selective await (use await_all_inports or fire-on-any).

fn port_delivery(&self) -> HashMap<String, String>

Per-port delivery metadata.

fn create_instance(&self) -> Arc<dyn Actor>

Create a fresh, isolated actor instance with its own channels.

fn create_state(&self) -> Arc<Mutex<RawMutex, dyn ActorState>>

Factory for the actor’s mutable state. Override to provide a custom ActorState implementation (e.g. Redis-backed state).

fn load_count(&self) -> Arc<ActorLoad>

fn create_process( &self, config: ActorConfig, tracing_integration: Option<TracingIntegration>, ) -> Pin<Box<dyn Future<Output = ()> + Send>>

The runtime dispatch loop. The default implementation builds an ActorProcess from the declarative methods above — most actors should not need to override this.

fn shutdown(&self)

Shutdown the actor, waiting for all processes to finish

fn cleanup(&self)

impl Clone for GaussianBlurActor

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.