Crate ame_bus 

Ame Bus

Modern microservices framework based on NATS.

Optional Features

• jetstream - Enable JetStream support.
• service - Enable NATS Service API support.
• full - Enable jetstream and service features.

Re-exports

pub use message::NatsJsonMessage;

pub use message::NatsMessage;

pub use tracing;

pub use futures;

Modules

jetstream

JetStream support.

kv

Key/Value Store support.

message

Define the message struct using inside ame-bus.

pool

Tokio concurrency utilities.

service_rpc

Service RPC support. Using just NATS core features.

Attribute Macros

jet

Specify the JetStream using of the struct.

jet_consumer

Configure the JetStream consumer.

nats_message

Implement StaticSubjectNatsMessage for the struct.

rpc_route

RPC Route Register

rpc_service

RPC Service

Derive Macros

DeriveCoreMessageSend

Implement NatsCoreMessageSendTrait for the struct.

DeriveJetMessageSend

Implement JetStreamMessageSendTrait for the struct.

NatsJsonMessage

Implement NatsJsonMessage trait if it has already implemented Serialize and Deserialize traits.