Struct TcpHandler 

pub struct TcpHandler { /* private fields */ }

Handler for providing raw TCP networking access to WebAssembly actors.

Implementations

impl TcpHandler

pub fn new(config: TcpHandlerConfig) -> Self

pub fn interfaces(&self) -> Vec<InterfaceImpl>

Get the interface declarations for this handler.

Trait Implementations

impl Clone for TcpHandler

fn clone(&self) -> TcpHandler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Handler for TcpHandler

fn create_instance(&self, config: Option<&HandlerConfig>) -> Box<dyn Handler>

Create a new instance of this handler, optionally with a config from the manifest.

fn name(&self) -> &str

fn imports(&self) -> Option<Vec<String>>

Returns the list of imports this handler can satisfy. Used for matching handlers to components that need these imports.

fn exports(&self) -> Option<Vec<String>>

Returns the list of exports this handler expects from the component. Used for matching handlers to components that export these interfaces.

fn interface_hashes(&self) -> Vec<(String, TypeHash)>

Returns the interface hashes for each interface this handler provides.

fn interfaces(&self) -> Vec<InterfaceImpl>

Returns the InterfaceImpl declarations for each interface this handler provides.

fn setup( &mut self, actor_handle: ActorHandle, _actor_instance: SharedActorInstance, shutdown_receiver: ShutdownReceiver, _event_rx: HandlerEventReceiver, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send>>

Initialize and run the handler.

fn setup_host_functions_composite( &mut self, builder: &mut HostLinkerBuilder<'_, ActorStore>, ctx: &mut HandlerContext, ) -> Result<(), LinkerError>

Set up host functions for this handler (Composite Graph ABI runtime).

fn supports_composite(&self) -> bool

Returns true if this handler supports Composite’s Graph ABI runtime.

fn init( &mut self, _actor_handle: ActorHandle, _actor_instance: Arc<RwLock<Option<PackInstance>>>, )

Synchronous initialization called BEFORE the actor can receive any calls.

fn run( &mut self, shutdown_receiver: ShutdownReceiver, _event_rx: Receiver<(TheaterId, ChainEvent)>, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send>>

Async runtime loop that runs for the handler’s lifetime.