Crate apalis_core

Source
Expand description

§apalis-core

Utilities for building job and message processing tools.

Modules§

backend
Represents a task source eg Postgres or Redis
builder
Represent utilities for creating worker instances.
codec
Codec for handling data
data
Represents the utils needed to extend a task’s context.
error
Includes all possible error types.
interval
Interval utilities
layers
Represents middleware offered through tower
memory
In-memory utilities for testing and mocking
monitor
Represents monitoring of running workers
mq
Message queuing utilities
notify
Allows async listening in a mpsc style.
poller
Controlled polling and streaming
request
Represents the request to be processed.
response
Represents different possible responses.
service_fn
Represents a service that is created from a function.
step
Allows stepped tasks
storage
Represents ability to persist and consume jobs from storages.
task
Task management utilities
test_utils
Test utilities that allows you to test backends
worker
Represents the utils for building workers.

Macros§

generic_storage_test
Tests a generic storage
test_message_queue
Tests a generic mq

Functions§

sleep
Sleep utilities