Crate shizuku 

Shizuku

Modern microservices framework based on NATS.

docs

API Reference]

Re-exports

pub use core::error;

pub use core::error::Error;

pub use kanau;

pub use tracing;

pub use futures;

pub use core::message::*;

pub use core::processor::*;

Modules

core

Core of Shizuku.

flow

Monadic flow control.

jetstream

JetStream support.

kv

Key/Value Store support.

layer

Something that wraps around a processor.

prelude

reexports of essentials

processor

Async closure Fn(I) -> Future<Output = O> as a trait.

service_rpc

Service RPC support. Using just NATS core features.

Macros

early_return

early_return

jet_route

Define the jetstream route to build FinalJetStreamProcessor

monad_early_return

monad_early_return

protobuf_des

Implement [ByteDeserialize] by prost if it already implements prost::Message.

protobuf_ser

Implement [ByteSerialize] by prost if it already implements prost::Message.

service_route

Routes NATS messages to appropriate service endpoints based on their subjects.

subject_matcher

Creates a SubjectMatcher from a sequence of tokens.

subject_path

Creates a NatsSubjectPath from

Derive Macros

BincodeByteDes

Implement ByteDeserialize by bincode if it already implements bincode::Decode.

BincodeByteSer

Implement ByteSerialize by bincode if it already implements bincode::Encode.

JsonByteDes

Implement ByteDeserialize by serde_json if it already implements serde::Deserialize.

JsonByteSer

Implement ByteSerialize by serde_json if it already implements serde::Serialize.

ProtoDes

Implement ByteDeserialize by prost if it already implements prost::Message.

ProtoSer

Implement ByteSerialize by prost if it already implements prost::Message.