Crate dspk_stream 

Network sessions for continuous multi-channel signals: a server streams a recording, a client receives its exact description, its stored samples, and envelopes of any view.

• protocol: the messages (generated from proto/dspk_stream.proto), their framing, and conversions to and from dspk-core / dspk-view types.
• transport: QUIC + TLS 1.3 endpoints, the server session and the client session.

Local recording I/O lives in dspk-io; envelopes and pyramids in dspk-view (a server answers views with them).

Re-exports

pub use error::StreamError;

pub use error::StreamResult;

pub use transport::files;

pub use transport::jobs;

pub use transport::checked_view;

pub use transport::client_config;

pub use transport::client_config_with;

pub use transport::serve_recording;

pub use transport::serve_session;

pub use transport::server_config;

pub use transport::Device;

pub use transport::OpenRecording;

pub use transport::RecordingOpener;

pub use transport::server_config_with_clients;

pub use transport::Authority;

pub use transport::ClientIdentity;

pub use transport::ClientRecord;

pub use transport::Enrollment;

pub use transport::Pacing;

pub use transport::Peer;

pub use transport::Permission;

pub use transport::ServeOptions;

pub use transport::Server;

pub use transport::ServerIdentity;

pub use transport::ServerTls;

pub use transport::ServerTrust;

pub use transport::Session;

pub use transport::SignalReceiver;

pub use transport::DEFAULT_MAX_CONNECTIONS;

pub use transport::DEFAULT_MAX_REQUEST_BYTES;

pub use transport::MAX_VIEW_COLUMNS;

pub use transport::MAX_VIEW_VALUES;

pub use transport::REFUSED_CLIENT;

Modules

error

Errors of a stream session.

protocol

The wire protocol (no networking): message types generated from proto/dspk_stream.proto, length-prefixed framing, and conversions to and from dspk-core / dspk-view types.

transport

QUIC endpoints with TLS 1.3. Each client gets one connection holding a control stream, a signal stream and one stream per view request (see proto/dspk_stream.proto), so a view never waits behind signal data.