Enum CallRecord 

pub enum CallRecord {
    RunMigrations,
    HealthCheck,
    Enqueue(NewJob),
    Subscribe(String),
    PublishStream {
        stream: String,
        event: NewEvent,
    },
    SubscribeStream {
        stream: String,
        consumer_group: String,
        last_seq: Option<i64>,
    },
    AckStream {
        stream: String,
        consumer_group: String,
        seq: i64,
    },
    ReadEventsStream {
        stream: String,
        after_seq: i64,
        limit: i64,
    },
    ConsumerGroupInfoStream(String),
    LeaseJobsBatch {
        queue: String,
        worker_id: String,
        lease_seconds: i64,
        batch_size: i64,
    },
    LeaseJobsBatchWithOrdering {
        queue: String,
        worker_id: String,
        lease_seconds: i64,
        batch_size: i64,
        ordering: QueueOrdering,
    },
    ReapExpiredLocks,
    StartAttemptsBatch {
        job_ids: Vec<Uuid>,
        worker_id: String,
    },
    MarkSucceeded {
        job_id: Uuid,
        attempt_id: Uuid,
        worker_id: String,
        latency_ms: i32,
    },
    MarkSucceededBatch {
        dataset_id: String,
        updates: Vec<(Uuid, Uuid, i32)>,
        worker_id: String,
    },
    RescheduleForRetry {
        job_id: Uuid,
        attempt_id: Uuid,
        worker_id: String,
        latency_ms: i32,
        next_run_at: DateTime<Utc>,
        error_code: String,
        error_message: String,
        attempt_no: i32,
    },
    MarkDlq {
        job_id: Uuid,
        attempt_id: Uuid,
        worker_id: String,
        latency_ms: i32,
        reason_code: String,
        error_code: String,
        error_message: String,
        attempt_no: i32,
    },
    ArchiveSucceededOlderThan {
        cutoff: DateTime<Utc>,
        limit: i64,
    },
    DeleteHistoryForSucceededOlderThan {
        cutoff: DateTime<Utc>,
        limit: i64,
    },
    PerformMaintenance,
    ExtendLease {
        job_id: Uuid,
        worker_id: String,
        lease_seconds: i64,
    },
    GetJob(Uuid),
    ListJobs {
        queue: Option<String>,
        status: Option<String>,
        limit: i64,
    },
    ReplayJob {
        job_id: Uuid,
        override_queue: Option<String>,
        override_run_at: Option<DateTime<Utc>>,
    },
}

Log record representing a single call executed against a MockBackend.

Variants

RunMigrations

HealthCheck

Enqueue(NewJob)

Subscribe(String)

PublishStream

Fields

stream: String

event: NewEvent

SubscribeStream

Fields

stream: String

consumer_group: String

last_seq: Option<i64>

AckStream

Fields

stream: String

consumer_group: String

seq: i64

ReadEventsStream

Fields

stream: String

after_seq: i64

limit: i64

ConsumerGroupInfoStream(String)

LeaseJobsBatch

Fields

queue: String

worker_id: String

lease_seconds: i64

batch_size: i64

LeaseJobsBatchWithOrdering

Fields

queue: String

worker_id: String

lease_seconds: i64

batch_size: i64

ordering: QueueOrdering

ReapExpiredLocks

StartAttemptsBatch

Fields

job_ids: Vec<Uuid>

worker_id: String

MarkSucceeded

Fields

job_id: Uuid

attempt_id: Uuid

worker_id: String

latency_ms: i32

MarkSucceededBatch

Fields

dataset_id: String

updates: Vec<(Uuid, Uuid, i32)>

worker_id: String

RescheduleForRetry

Fields

job_id: Uuid

attempt_id: Uuid

worker_id: String

latency_ms: i32

next_run_at: DateTime<Utc>

error_code: String

error_message: String

attempt_no: i32

MarkDlq

Fields

job_id: Uuid

attempt_id: Uuid

worker_id: String

latency_ms: i32

reason_code: String

error_code: String

error_message: String

attempt_no: i32

ArchiveSucceededOlderThan

Fields

cutoff: DateTime<Utc>

limit: i64

DeleteHistoryForSucceededOlderThan

Fields

cutoff: DateTime<Utc>

limit: i64

PerformMaintenance

ExtendLease

Fields

job_id: Uuid

worker_id: String

lease_seconds: i64

GetJob(Uuid)

ListJobs

Fields

queue: Option<String>

status: Option<String>

limit: i64

ReplayJob

Fields

job_id: Uuid

override_queue: Option<String>

override_run_at: Option<DateTime<Utc>>

Trait Implementations

impl Clone for CallRecord

fn clone(&self) -> CallRecord

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CallRecord

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.