Docs.rs
  • apalis-core-0.3.2
    • apalis-core 0.3.2
    • Docs.rs crate page
    • MIT
    • Links
    • crates.io
    • Source
    • Owners
    • geofmureithi
    • Dependencies
      • async-trait ^0.1 normal
      • chrono ^0.4 normal
      • dashmap ^4 normal
      • futures ^0.3 normal
      • http ^0.2.7 normal
      • log ^0.4 normal
      • metrics ^0.18 normal
      • metrics-exporter-prometheus ^0.8 normal
      • once_cell ^1 normal
      • petgraph ^0.6.2 normal
      • pin-project-lite ^0.2.9 normal
      • sentry-core ^0.25.0 normal
      • serde ^1.0 normal
      • serde_json ^1 normal
      • strum ^0.24 normal
      • thiserror ^1 normal
      • tokio ^1 normal
      • tower ^0.4 normal
      • tracing ^0.1 normal
      • tracing-futures ^0.2.5 normal
      • uuid ^0.8 normal
      • tokio ^1.6.0 dev
    • Versions
    • 100% of the crate is documented
  • Go to latest version
  • Platform
    • i686-pc-windows-msvc
    • i686-unknown-linux-gnu
    • x86_64-apple-darwin
    • x86_64-pc-windows-msvc
    • x86_64-unknown-linux-gnu
  • Feature flags
  • docs.rs
    • About docs.rs
    • Badges
    • Builds
    • Metadata
    • Shorthand URLs
    • Download
    • Rustdoc JSON
    • Build queue
    • Privacy policy
  • Rust
    • Rust website
    • The Book
    • Standard Library API Reference
    • Rust by Example
    • The Cargo Guide
    • Clippy Documentation
logo

logo

Crate apalis_core

logo
Change settings

List of all items

Structs

  • builder::WorkerBuilder
  • context::JobContext
  • job::Counts
  • job::JobRequestWrapper
  • job::JobStreamWorker
  • job_fn::JobFn
  • job_fn::JobFnHttpFuture
  • layers::TimeoutLayer
  • layers::extensions::AddExtension
  • layers::extensions::Extension
  • layers::limit::RateLimitLayer
  • layers::prometheus::PrometheusLayer
  • layers::prometheus::PrometheusService
  • layers::prometheus::ResponseFuture
  • layers::retry::DefaultRetryPolicy
  • layers::retry::RetryLayer
  • layers::sentry::SentryHttpFuture
  • layers::sentry::SentryJobLayer
  • layers::sentry::SentryJobService
  • layers::tracing::ResponseFuture
  • layers::tracing::Trace
  • layers::tracing::TraceLayer
  • request::JobRequest
  • storage::StorageWorker
  • worker::Addr
  • worker::AlwaysAddr
  • worker::Context
  • worker::InitializedActor
  • worker::Recipient
  • worker::broker::Broker
  • worker::prelude::Monitor
  • worker::prelude::WorkerMessage

Enums

  • error::JobError
  • error::JobStreamError
  • error::WorkerError
  • layers::tracing::LatencyUnit
  • request::JobState
  • response::JobResult
  • storage::StorageError
  • storage::StorageWorkerPulse
  • worker::WorkerStatus
  • worker::prelude::WorkerEvent

Traits

  • builder::WorkerFactory
  • builder::WorkerFactoryFn
  • job::Job
  • job::JobStream
  • job::JobStreamExt
  • response::IntoJobResponse
  • storage::Storage
  • worker::Actor
  • worker::ContextHandler
  • worker::Handler
  • worker::Message
  • worker::MessageResponse
  • worker::Worker
  • worker::broker::BrokerMessage
  • worker::prelude::WorkerListener

Functions

  • job_fn::job_fn

Typedefs

  • job::JobFuture
  • job::JobStreamResult
  • storage::StorageResult