Crate dora_message 

Enable serialisation and deserialisation of capnproto messages

Re-exports

pub use uhlc;

pub use aligned_vec;

pub use arrow_data;

pub use arrow_schema;

Modules

auth

Shared-token authentication for coordinator connections.

cli_to_coordinator

common

config

coordinator_to_cli

coordinator_to_daemon

daemon_to_coordinator

daemon_to_daemon

daemon_to_node

descriptor

Dataflow descriptor types for YAML-based dataflow specifications.

id

integration_testing_format

Use these types for integration testing nodes.

metadata

node_to_daemon

ws_protocol

WebSocket message protocol for the control plane.

Structs

BuildId

SessionId

Constants

MAX_MESSAGE_BYTES

Maximum allowed message size over TCP (64 MiB).

TCP_READ_TIMEOUT

Read timeout for TCP/socket connections (30 seconds).

VERSION

The version of the dora-message crate

Functions

current_crate_version

Type Aliases

DataflowId

Unique identifier for a dataflow instance.