List of all items

Structs

• NatsClient
• NatsJwtCredentials
• NatsReceivedCommand
• NatsReceivedEvent
• NatsRequestBody
• SigningKey
• Subscriber
• client::NatsClient
• client::request::NatsRequestBody
• config::CommandRetentionConfig
• config::ConsumerConfig
• config::MessageBusConfig
• config::NatsClientTls
• config::NatsConfiguration
• consumergroup::ConsumerClient
• consumergroup::ConsumerClientConfig
• credentials::NatsJwtCredentials
• mock::MockBus
• mock::MockPublisher
• mock::MockReceivedCommand
• mock::MockReceivedEvent
• mock::MockSubscriber
• mock::ReplyChecker
• opentelemetry::NatsHeaderExtractor
• opentelemetry::NatsHeaderInjector
• requester::NatsReceivedCommand
• requester::ReplyHandle
• resubscribe::ConnectionSignals
• subscriber::NatsReceivedEvent
• test_utils::NatsSystemCredentials

Enums

• CommandError
• MessageBusError
• NatsCredentials
• NatsError
• config::NatsConfigurationError
• config::StreamRetentionConfig
• credentials::NatsCredentials
• resubscribe::ForwardOutcome

Traits

• Command
• Event
• Publisher
• ReceivedCommand
• ReceivedEvent
• Requester
• Responder
• credentials::Env

Derive Macros

• Command
• Event

Functions

• auth_management::create_account
• auth_management::create_jwt
• auth_management::create_operator_account
• auth_management::create_user
• client::event_subjects
• client::stream_name
• consumergroup::update_or_recreate_consumer
• encode_subject_segment
• headers::reply_subject
• headers::set_reply_subject
• opentelemetry::extract_otel_context
• opentelemetry::span_from_nats_message
• opentelemetry::span_to_nats_headers
• responder::received_command
• resubscribe::await_connection
• resubscribe::forward_and_resubscribe
• resubscribe::forward_stream
• resubscribe::resubscribe
• resubscribe::resubscribing_stream
• test_utils::authenticate_as_sys
• test_utils::authenticate_via_jwt
• test_utils::create_nats_account_for_test

Type Aliases

• SharedNatsClient
• client::SharedNatsClient
• credentials::EnvVarValue
• resubscribe::MessageStream

Constants

• client::request::NATS_REQUEST_TIMEOUT
• client::room::ROOMSERVER_STREAM_NAME
• client::room::ROOMSERVER_STREAM_PARTITION_PARTS
• client::sync::SYNC_UPDATE_SUBJECT
• config::DEFAULT_COMMAND_PREFETCH
• config::DEFAULT_MAX_ACK_PENDING
• config::DEFAULT_MAX_DELIVER
• config::DEFAULT_STREAM_BUFFER_SIZE
• headers::REPLY_SUBJECT_HEADER
• requester::REQUEST_TIMEOUT
• resubscribe::RECONNECT_MAX_DELAY