Module deploy_runtime_containerized 

Available on crate feature deploy and (crate features docker_runtime or ecs_runtime) only.

Structs

ChannelHandshake

Handshake message sent by the connecting side to identify the channel.

ChannelMagic

Magic header sent as the very first frame of every channel handshake.

ChannelMux

A shared accept loop that listens on a single port and dispatches incoming connections to the right consumer based on the channel name sent in the handshake.

ChannelProtocolVersion

Protocol version sent as the second frame, after ChannelMagic.

SocketIdent

Constants

CHANNEL_MAGIC

Magic constant embedded in every ChannelMagic header.

CHANNEL_MUX_PORT

The single well-known port that every node listens on.

CHANNEL_PROTOCOL_VERSION

Current protocol version for the channel handshake.

Functions

cluster_ids

cluster_membership_streamdocker_runtime

cluster_self_iddocker_runtime

deploy_containerized_external_sink_source_ident

deploy_containerized_m2m

deploy_containerized_m2o

deploy_containerized_o2m

deploy_containerized_o2o

get_or_init_channel_mux

Get or initialize the global ChannelMux for this process.

send_handshake

Sends a ChannelMagic, then a ChannelProtocolVersion, then a ChannelHandshake as three separate frames over the given sink.