Crate cortexkit_bus_trait 

NATS-shaped primitives shared by the production and in-memory bus backends.

The broker transports identifiers and content digests, never record bodies. The traits intentionally model the selected NATS primitives rather than a least-common-denominator queue API.

Structs

AsyncPermissionViolation

CensusWatchGuard

Tracks presence and deletion observations made on this connection as a local safeguard; the server-side credential revocation remains authoritative.

ConformanceReport

ContentDigest

A SHA-256 content digest in its canonical lowercase hexadecimal wire form.

DeadLetterRecord

DeliveryToken

MaxDeliveriesExceeded

Message

PropertyClassification

PropertySpec

PublishAck

RegisterEntry

RegisterValue

Revision

StreamDelivery

Tombstone

WorkItem

Enums

BackendKind

BusError

ClaimOutcome

ConnectionFailure

CredentialSignFailure

DurableOwner

Whose durable a cursor binds: an agent or a module, with its id. The backend derives the durable name from the kind and the id (c_ or m_ followed by the id), so a cursor can bind only an agent’s or a module’s durable and never an arbitrary consumer name.

PropertyApplicability

PropertyOutcome

PropertySet

RegisterUpdate

SuiteBug

WatchEvent

Constants

CONFORMANCE_PROPERTIES

DEAD_LETTER_REASON_MAX_DELIVERIES

Traits

ConformanceBackend

PermissionViolationSource

Register

RegisterWatch

Stream

StreamCursor

A cursor for an already-created durable, selected by its associated registry identity.

WorkQueue

A claimant on a bounded work queue.

Functions

attribute_sentinel_failure

Reports a permission violation observed during the request instead of its less-specific timeout.

classify_properties

effect_dead_subject

map_connection_failure

map_credential_sign_failure

run_conformance

terminally_dispose

Publishes a persistent dead-letter record before terminating the exhausted delivery.

Type Aliases

BusResult

Headers

MessageId