[][src]Function cerk_port_unix_socket::port_input_unix_socket_json_start

pub fn port_input_unix_socket_json_start(
    id: InternalServerId,
    inbox: BoxedReceiver,
    sender_to_kernel: BoxedSender
)

This is the main function to start the port.

This port reads CloudEvents form a UNIX Socket and sens them to the Kernel.

Configurations

The Socket expects a Config::String as configuration. The string should be a file path where the UNIX Socket should be created.

e.g. Config::String(String::from("path/to/the/socket"))

Examples

Limitations

  • reliability this port does not support any DeliveryGuarantee other then Unspecified and so does never send a IncomingCloudEventProcessed message

open issues

  • https://github.com/ce-rust/cerk/issues/25