Module streaming_platform::client

Functions

full_message_mode	Future for message based client based on provided config. "addr" value will be used as address for endpoint, "host" value - network addr for the server (in host:port format) "access_key" value will be send for optional authorization, more information about this feature will be provided later. process_stream is used for stream of incoming data processing. startup is executed on the start of this function. restream_rx can be used for restreaming data somewhere else, for example returning data for incoming web request The protocol message format is in sp-dto crate.
start	Starts a message based client based on provided config. Creates new runtime and blocks. Config must have "addr" key, this will be used as address for endpoint, and "host" key - network addr for the server (in host:port format) process_event is used for processing incoming message, which are marked as events via message kind. process_rpc is used for processing incoming message, which are marked as rpc request via message kind. startup is executed on the start of this function. The protocol message format is in sp-dto crate.
start_stream	Starts a stream based client based on provided config. Creates new runtime and blocks. Config must have "addr" key, this will be used as address for endpoint, and "host" key - network addr for the server (in host:port format) Config must have "access_key" key, this will be send for optional authorization, more information about this feature will be provided later. process_stream is used for stream of incoming data processing. startup is executed on the start of this function. restream_rx can be used for restreaming data somewhere else, for example returning data for incoming web request The protocol message format is in sp-dto crate.
stream_mode	Future for stream based client based on provided config. "addr" value will be used as address for endpoint, "host" value - network addr for the server (in host:port format) "access_key" value will be send for optional authorization, more information about this feature will be provided later. process_event is used for processing incoming message, which are marked as events via message kind. process_rpc is used for processing incoming message, which are marked as rpc request via message kind. startup is executed on the start of this function. restream_rx can be used for restreaming data somewhere else, for example returning data for incoming web request The protocol message format is in sp-dto crate.