Skip to main content

Crate awa_model

Crate awa_model 

Source

Re-exports§

pub use adapter::postgres::prepare_job_insert;
pub use adapter::postgres::prepare_raw_job_insert;
pub use adapter::postgres::PreparedJobInsert;
pub use admin::CallbackConfig;
pub use admin::DefaultAction;
pub use admin::JobKindDescriptor;
pub use admin::JobKindOverview;
pub use admin::ListJobsFilter;
pub use admin::QueueDescriptor;
pub use admin::QueueOverview;
pub use admin::QueueRuntimeConfigSnapshot;
pub use admin::QueueRuntimeMode;
pub use admin::QueueRuntimeSnapshot;
pub use admin::QueueRuntimeSummary;
pub use admin::RateLimitSnapshot;
pub use admin::ResolveOutcome;
pub use admin::RetryFailedOutcome;
pub use admin::RuntimeInstance;
pub use admin::RuntimeOverview;
pub use admin::RuntimeSnapshotInput;
pub use admin::StateTimeseriesBucket;
pub use admin::StorageCapability;
pub use batch_operations::BatchOperation;
pub use batch_operations::BatchOperationFilter;
pub use batch_operations::BatchOperationKind;
pub use batch_operations::BatchOperationPreview;
pub use batch_operations::BatchOperationSpec;
pub use batch_operations::BatchOperationState;
pub use batch_operations::ListBatchOperationsFilter;
pub use batch_operations::SubmitBatchOperation;
pub use cron::CronJobRow;
pub use cron::CronMissedFirePolicy;
pub use cron::PeriodicJob;
pub use cron::PeriodicJobBuilder;
pub use dlq::DlqMetadata;
pub use dlq::DlqRow;
pub use dlq::ListDlqFilter;
pub use dlq::RetryFromDlqOpts;
pub use error::map_sqlx_error;
pub use error::AwaError;
pub use insert::insert;
pub use insert::insert_many;
pub use insert::insert_many_copy;
pub use insert::insert_many_copy_from_pool;
pub use insert::insert_with;
pub use job::InsertOpts;
pub use job::InsertParams;
pub use job::JobRow;
pub use job::JobState;
pub use job::UniqueOpts;
pub use partitioned_queue::partition_for_ordering_key;
pub use partitioned_queue::partition_hash64;
pub use partitioned_queue::PartitionedQueue;
pub use partitioned_queue::PartitionedQueueError;
pub use queue_storage::ClaimedEntry;
pub use queue_storage::ClaimedRuntimeJob;
pub use queue_storage::PruneOutcome;
pub use queue_storage::QueueCounts;
pub use queue_storage::QueueStorage;
pub use queue_storage::QueueStorageConfig;
pub use queue_storage::RotateOutcome;
pub use queue_storage::SkipReason;
pub use queue_storage::TerminalDeltaRollupOutcome;
pub use storage::StorageStatus;

Modules§

adapter
Stable building blocks for external database adapters.
admin
batch_operations
bridge
Transactional enqueue for non-sqlx Postgres stacks.
callback_contract
HTTP callback ingress contract — wire types, signing, header names.
cron
Periodic/cron job types and database operations.
dlq
Dead-letter queue helpers for the queue_storage backend.
error
insert
job
kind
migrations
partitioned_queue
queue_storage
storage
unique

Traits§

JobArgs
Trait for typed job arguments.

Type Aliases§

QueueStatsDeprecated
Deprecated alias preserved for one release so existing downstream code compiling against awa_model::QueueStats keeps building. New callers should use QueueOverview directly — the renamed type carries additional descriptor fields this alias predates.

Derive Macros§

JobArgs
Derive macro for job argument types.