Crate queuerious 

Queuerious Rust SDK — Job queue observability.

Report job lifecycle events (started, completed, failed, retrying, dead-lettered) to the Queuerious platform.

Quick Start

use queuerious::{QueuriousClient, JobEvent, Backend};

let client = QueuriousClient::builder()
    .api_key("qk_your_api_key")
    .endpoint("https://api.queuerious.io")
    .build()?;

// Report a job started event (non-blocking, batched).
client.report(
    JobEvent::started("email-queue", Backend::RabbitMQ, "job-123", "SendEmail")
        .payload(serde_json::json!({"to": "user@example.com"}))
        .build()
)?;

// Gracefully shut down (flushes pending events).
client.shutdown().await?;

Structs

IngestEventError

Error details for a failed ingest event.

IngestEventResult

Result for a successfully processed job_started event.

IngestResponse

Response from the ingest endpoint.

JobEvent

A job lifecycle event to report to Queuerious.

JobEventFailedBuilder

Builder for “job failed” events with optional fields.

JobEventStartedBuilder

Builder for “job started” events with optional fields.

NoopReporter

A no-op reporter for testing or disabled environments.

QueuriousClient

Client for reporting job lifecycle events to Queuerious.

QueuriousClientBuilder

Builder for QueuriousClient.

Enums

Backend

Supported queue backend types.

QueuriousError

Errors that can occur when using the Queuerious SDK.

Traits

QueuriousReporter

Trait for reporting job events to Queuerious.