Index

A

ack_wait (walnats.Actor attribute) acquire() (walnats.Priority method) Actor (class in walnats) actor (walnats.types.Context attribute) (walnats.types.ErrorContext attribute) (walnats.types.OkContext attribute)

Actors (class in walnats) add() (walnats.Services method) age (walnats.Limits attribute) attempts (walnats.types.Context property)

B

bytes (walnats.Limits attribute)

BytesSerializer (class in walnats.serializers)

C

Clock (class in walnats) CloudEvent (class in walnats) connect() (walnats.Actors method) (walnats.Events method) ConnectedActors (class in walnats.types)

ConnectedEvents (class in walnats.types) consumer_name (walnats.Actor property) consumers (walnats.Limits attribute) Context (class in walnats.types) CurrentContextMiddleware (class in walnats.middlewares)

D

DataclassSerializer (class in walnats.serializers) DatetimeSerializer (class in walnats.serializers) decode() (walnats.serializers.Serializer method)

description (walnats.Actor attribute) (walnats.Event attribute) duration (walnats.types.OkContext attribute)

E

emit() (walnats.types.ConnectedEvents method) encode() (walnats.serializers.Serializer method) ErrorContext (class in walnats.types) ErrorThresholdMiddleware (class in walnats.middlewares) Event (class in walnats) event (walnats.Actor attribute) (walnats.Clock attribute)

Events (class in walnats) EventWithResponse (class in walnats.types) evolve() (walnats.Limits method) exception (walnats.types.ErrorContext attribute) execute_in (walnats.Actor attribute) ExecuteIn (class in walnats) ExtraLogMiddleware (class in walnats.middlewares)

F

FernetSerializer (class in walnats.serializers)

filter_time() (in module walnats.decorators) FrequencyMiddleware (class in walnats.middlewares)

G

get() (walnats.Actors method) (walnats.Events method) get_async_api() (walnats.Services method)

get_async_apis() (walnats.Services method) get_d2() (walnats.Services method) GZipSerializer (class in walnats.serializers)

H

handler (walnats.Actor attribute)

HIGH (walnats.Priority attribute) HMACSerializer (class in walnats.serializers)

J

job_timeout (walnats.Actor attribute)

L

Limits (class in walnats) limits (walnats.Event attribute)

listen() (walnats.types.ConnectedActors method) LOW (walnats.Priority attribute)

M

MAIN (walnats.ExecuteIn attribute) MarshmallowSerializer (class in walnats.serializers) max_ack_pending (walnats.Actor attribute) max_attempts (walnats.Actor attribute) max_jobs (walnats.Actor attribute) message (walnats.types.Context attribute) (walnats.types.ErrorContext attribute) (walnats.types.OkContext attribute)

message_size (walnats.Limits attribute) MessagePackSerializer (class in walnats.serializers) messages (walnats.Limits attribute) meta (walnats.Clock attribute) metadata (walnats.types.Context property) Middleware (class in walnats.middlewares) middlewares (walnats.Actor attribute)

N

name (walnats.Actor attribute) (walnats.Event attribute)

new() (walnats.serializers.Serializer class method) NORMAL (walnats.Priority attribute)

O

OkContext (class in walnats.types) on_failure() (walnats.middlewares.Middleware method)

on_start() (walnats.middlewares.Middleware method) on_success() (walnats.middlewares.Middleware method) OpenTelemetryTraceMiddleware (class in walnats.middlewares)

P

period (walnats.Clock attribute) PrimitiveSerializer (class in walnats.serializers) Priority (class in walnats) priority (walnats.Actor attribute)

PROCESS (walnats.ExecuteIn attribute) PrometheusMiddleware (class in walnats.middlewares) ProtobufSerializer (class in walnats.serializers) pulse (walnats.Actor attribute) PydanticSerializer (class in walnats.serializers)

R

rate_limit() (in module walnats.decorators) register() (walnats.types.ConnectedActors method) (walnats.types.ConnectedEvents method)

request() (walnats.types.ConnectedEvents method) require() (in module walnats.decorators) retry_delay (walnats.Actor attribute) run() (walnats.Clock method)

S

schema (walnats.Event attribute) SentryMiddleware (class in walnats.middlewares) seq_number (walnats.types.Context property) Serializer (class in walnats.serializers) serializer (walnats.Event attribute) Services (class in walnats)

StatsdMiddleware (class in walnats.middlewares) stream_name (walnats.Event property) StreamConfigError StreamExistsError subject_name (walnats.Event property) suppress() (in module walnats.decorators)

T

TextLogMiddleware (class in walnats.middlewares)

THREAD (walnats.ExecuteIn attribute) trace_id (walnats.types.Context property)

W

with_response() (walnats.Event method)

Z

ZipkinMiddleware (class in walnats.middlewares)