inspection

Classes

DeliveryInspectionError

Stable inspection errors never include stored cargo or raw SQL failures.

Extends

• Error

Constructors

Constructor

new DeliveryInspectionError(code): DeliveryInspectionError

Parameters

code

"unavailable" | "invalid_query"

Returns

DeliveryInspectionError

Overrides

Error.constructor

Properties

code

readonly code: "unavailable" | "invalid_query"

Type Aliases

DeliveryInspectionPageQuery

DeliveryInspectionPageQuery = Schema.Codec.Encoded<typeof DeliveryInspectionPageQuerySchema>>

An email receipt page uses the same producer-key pagination.

---

DeliveryInspectionQuery

DeliveryInspectionQuery = Schema.Codec.Encoded<typeof DeliveryInspectionQuerySchema>>

Input to one producer-local inspection. Cursors are producer keys, without storage prefixes.

---

PostReceiptSummary

PostReceiptSummary = Schema.Schema.Type<typeof PostReceiptSummarySchema>>

Metadata for one retained Post row.

---

PostInspectionPage

PostInspectionPage = Schema.Schema.Type<typeof PostInspectionPageSchema>>

One read of producer-local Post dispatch evidence.

---

CarrierInspectionPage

CarrierInspectionPage = Schema.Schema.Type<typeof CarrierInspectionPageSchema>>

One read of aggregate email dispatch evidence.

Variables

DeliveryInspectionPageQuerySchema

const DeliveryInspectionPageQuerySchema: Struct<{ limit: withDecodingDefaultType<Int, never>>; after: optional<String>>; }>

One bounded scan; an empty filtered page can still have a continuation.

---

DeliveryInspectionQuerySchema

const DeliveryInspectionQuerySchema: Struct<{ limit: withDecodingDefaultType<Int, never>>; after: optional<String>>; view: Literals<readonly ["receipts", "deadLetters"]>; }>

Post can filter dead letters while scanning at most one bounded page.

---

PostReceiptSummarySchema

const PostReceiptSummarySchema: Union<readonly [Struct<{ key: String; state: Literal<"delivered">>; }>, Struct<{ key: String; state: Literal<"pending">>; kind: String; attempts: Int; nextAttemptAt: Number; }>, Struct<{ key: String; state: Literal<"dead">>; kind: String; attempts: Int; reason: Literals<readonly ["refused", "exhausted"]>; }>]>

Dispatch evidence deliberately omits the address and event.

---

PostInspectionPageSchema

const PostInspectionPageSchema: Union<readonly [Struct<{ status: Literal<"uninitialized">>; }>, Struct<{ status: Literal<"available">>; records: $Array<Union<readonly [Struct<{ key: String; state: Literal<"delivered">>; }>, Struct<{ key: String; state: Literal<"pending">>; kind: String; attempts: Int; nextAttemptAt: Number; }>, Struct<{ key: String; state: Literal<"dead">>; kind: String; attempts: Int; reason: Literals<readonly […, …]>; }>]>>; nextCursor: NullOr<String>>; }>]>

Bounded evidence with an explicit distinction between empty and uninitialized storage.

---

CarrierReceiptSummarySchema

const CarrierReceiptSummarySchema: Struct<{ id: String; status: Literals<readonly ["queued", "dispatching", "provider_accepted", "outcome_unknown", "rejected", "refused", "expired", "superseded"]>; attempts: Int; retryAt: NullOr<Number>>; providerMessageId: optional<NonEmptyString>>; providerRejection: optional<Struct<{ code: NonEmptyString; class: Literals<readonly ["permanent", "temporary"]>; }>>; }>

Aggregate email evidence without bodies, headers or recipient addresses.

---

CarrierInspectionPageSchema

const CarrierInspectionPageSchema: Union<readonly [Struct<{ status: Literal<"uninitialized">>; }>, Struct<{ status: Literal<"available">>; records: $Array<Struct<{ id: String; status: Literals<readonly ["queued", "dispatching", "provider_accepted", "outcome_unknown", "rejected", "refused", "expired", "superseded"]>; attempts: Int; retryAt: NullOr<Number>>; providerMessageId: optional<NonEmptyString>>; providerRejection: optional<Struct<{ code: NonEmptyString; class: Literals<…>; }>>; }>>; nextCursor: NullOr<String>>; }>]>

Carrier’s bounded metadata page; unavailable storage is never reported as empty.

Functions

createDeliveryInspection()

createDeliveryInspection(sql): object

Read existing storage without opening a sender, initializing tables, repairing jobs or arming a wake. The trusted host must admit an operator before calling.

Parameters

sql

Readonly<{ exec: (statement, …bindings) => WatchdogSqliteCursor; }>

Returns

email()

email(input): { status: "uninitialized"; } | { status: "available"; records: readonly object[]; nextCursor: string | null; }

Read aggregate dispatch evidence without email cargo or recipient addresses.

Parameters

input

limit?

number = ...

after?

string = ...

Returns

{ status: "uninitialized"; } | { status: "available"; records: readonly object[]; nextCursor: string | null; }

post()

post(input): { status: "uninitialized"; } | { status: "available"; records: readonly ({ key: string; state: "delivered"; } | { key: string; state: "pending"; kind: string; attempts: number; nextAttemptAt: number; } | { key: string; state: "dead"; kind: string; attempts: number; reason: "refused" | "exhausted"; })[]; nextCursor: string | null; }

Read Post metadata; filtered pages retain their continuation through other states.

Parameters

input

limit?

number = ...

after?

string = ...

view

"deadLetters" | "receipts" = ...

Returns

{ status: "uninitialized"; } | { status: "available"; records: readonly ({ key: string; state: "delivered"; } | { key: string; state: "pending"; kind: string; attempts: number; nextAttemptAt: number; } | { key: string; state: "dead"; kind: string; attempts: number; reason: "refused" | "exhausted"; })[]; nextCursor: string | null; }