Crate wadm

Source

Modules§

commands
Type implementations for commands issued to compensate for state changes
config
consumers
Contains implementions of durable consumers of events that automatically take a message from a consumer and parse it to concrete types for consumption in a scheduler
events
nats_utils
Helper utilities for interacting with NATS
publisher
A module that defines a generic publisher trait and several common publishers that can be passed into various structs in wadm. Often times this is used for testing, but it also allows for flexibility for others who may want to publish to other sources
scaler
server
storage
workers
Various Worker implementations for reconciling and handling events and commands. These are essentially the default things that drive work forward in wadm

Enums§

StreamPersistence

Constants§

APP_SPEC_ANNOTATION
An annotation that denotes which model a resource belongs to
DEFAULT_COMMANDS_TOPIC
Default topic to listen to for all commands
DEFAULT_COMMAND_STREAM_NAME
Default stream name for wadm commands
DEFAULT_EVENTS_TOPIC
Default topic to listen to for all lattice events
DEFAULT_EXPIRY_TIME
Default amount of time events should stay in the stream. This is the 2x heartbeat interval, plus some wiggle room. Exported to make setting defaults easy
DEFAULT_LINK_NAME
The default link name. In the future, this will likely be pulled in from another crate
DEFAULT_MULTITENANT_EVENTS_TOPIC
Default topic to listen to for all lattice events in a multitenant deployment
DEFAULT_NOTIFY_STREAM_NAME
Default stream name for wadm notifications
DEFAULT_STATUS_STREAM_NAME
Default stream name for wadm status
DEFAULT_STATUS_TOPIC
Default topic to listen to for all status updates. wadm.status.<lattice_id>.<manifest_name>
DEFAULT_WADM_EVENTS_TOPIC
Default topic to listen to for all wadm event updates
DEFAULT_WADM_EVENT_CONSUMER_STREAM_NAME
Default stream name for wadm event consumer
DEFAULT_WADM_EVENT_CONSUMER_TOPIC
Default internal wadm event consumer listen topic for the merged wadm and wasmbus events stream.
DEFAULT_WADM_EVENT_STREAM_NAME
Default stream name for wadm events
DEFAULT_WASMBUS_EVENT_STREAM_NAME
Default stream name for wasmbus events
MANAGED_BY_ANNOTATION
Managed by annotation used for labeling things properly in wadm
MANAGED_BY_IDENTIFIER
Identifier for managed by annotation. This is the value MANAGED_BY_ANNOTATION is set to
SCALER_KEY
An annotation that denotes which scaler is managing a resource

Functions§

start_wadm
Start wadm with the provided WadmConfig, returning JoinSet with two tasks: