Module nats 

Modules

deserialize

replay_loop

standby_handler

Structs

NatsBalanceUpdatePublisher

NatsConfig

NatsPublisher

Publishes engine commands to NATS JetStream. Used by the primary engine after each apply().

NatsReplaySubscriber

Subscribes to the engine command stream and replays commands. Used by the standby engine to stay caught up with the primary.

ParsedCommandPayload 🔒

ReplayMessage

Enums

CommandType

Constants

COMMAND_PAYLOAD_PREFIX_LEN

COMMAND_WIRE_VERSION_V1

LEGACY_COMMAND_PAYLOAD_PREFIX_LEN

LEGACY_COMMAND_WIRE_VERSION

Functions

balance_update_stream_config 🔒

balance_update_stream_name 🔒

balance_update_subject 🔒

command_stream_config 🔒

decode_balance_update_wire 🔒

get_or_create_balance_update_stream 🔒

get_or_create_command_stream 🔒

parse_command_payload 🔒

stream_name 🔒

subject 🔒