Skip to content
Fungi

index

@fungi.computer/watchdog

@fungi.computer/watchdog / index

index

Section titled “index”

Classes

Section titled “Classes”

WatchdogError

Section titled “WatchdogError”

Typed failures owned by the generic Watchdog engine.

Extends

Section titled “Extends”
  • Error

Constructors

Section titled “Constructors”
Constructor
Section titled “Constructor”

new WatchdogError(cause): WatchdogError

Parameters
Section titled “Parameters”
cause
Section titled “cause”

"store_unavailable" | "store_invalid" | "claim_unavailable" | "execution_failed" | "settlement_rejected" | "wake_unavailable"

Returns
Section titled “Returns”

WatchdogError

Overrides
Section titled “Overrides”

Error.constructor

Properties

Section titled “Properties”
_tag
Section titled “_tag”

readonly _tag: "WatchdogError"

cause
Section titled “cause”

readonly cause: "store_unavailable" | "store_invalid" | "claim_unavailable" | "execution_failed" | "settlement_rejected" | "wake_unavailable"

Inherited from
Section titled “Inherited from”

Error.cause

Type Aliases

Section titled “Type Aliases”

WatchdogExecutor

Section titled “WatchdogExecutor”

WatchdogExecutor = (job, signal) => Promise<WatchdogExecutionDecision>>

Promise host executor for one generic running job.

Parameters

Section titled “Parameters”
job
Section titled “job”

WatchdogRunningJob

signal
Section titled “signal”

AbortSignal

Returns

Section titled “Returns”

Promise<WatchdogExecutionDecision>

WatchdogOptions

Section titled “WatchdogOptions”

WatchdogOptions = Readonly<{ owner: WatchdogSqliteOwner; isAlive: (job) => Promise<boolean>>; execute: WatchdogExecutor; wake: Readonly<{ recompute: () => Promise<void>>; }>; }>

Options for constructing the Promise facade.

WatchdogRuntime

Section titled “WatchdogRuntime”

WatchdogRuntime = Readonly<{ hasPendingWork: () => Promise<boolean>>; ingest: (job) => Promise<WatchdogIngestResult>>; read: (jobId) => Promise<WatchdogReadResult>>; readQueueHead: (queue) => Promise<WatchdogQueueHead>>; tick: () => Promise<WatchdogTickResult>>; cancel: (input) => Promise<WatchdogCancellationResult>>; purge: (queue) => Promise<void>>; transactional: WatchdogTransactionalProjection; }>

Promise facade over the canonical Effect runtime.

WatchdogApi

Section titled “WatchdogApi”

WatchdogApi = Readonly<{ make: (options) => Promise<WatchdogRuntime>>; }>

Factory for the Promise facade.

Variables

Section titled “Variables”

Watchdog

Section titled “Watchdog”

const Watchdog: WatchdogApi

Promise facade over the canonical Effect-owned runtime.

References

Section titled “References”

WatchdogCancellationIntentSchema

Section titled “WatchdogCancellationIntentSchema”

Re-exports WatchdogCancellationIntentSchema

WatchdogCancellationResultSchema

Section titled “WatchdogCancellationResultSchema”

Re-exports WatchdogCancellationResultSchema

WatchdogExecutionDecisionSchema

Section titled “WatchdogExecutionDecisionSchema”

Re-exports WatchdogExecutionDecisionSchema

WatchdogIngestResultSchema

Section titled “WatchdogIngestResultSchema”

Re-exports WatchdogIngestResultSchema

WatchdogQueuedJobSchema

Section titled “WatchdogQueuedJobSchema”

Re-exports WatchdogQueuedJobSchema

WatchdogQueueHeadSchema

Section titled “WatchdogQueueHeadSchema”

Re-exports WatchdogQueueHeadSchema

WatchdogReadResultSchema

Section titled “WatchdogReadResultSchema”

Re-exports WatchdogReadResultSchema

WatchdogRunningJobSchema

Section titled “WatchdogRunningJobSchema”

Re-exports WatchdogRunningJobSchema

WatchdogSettledJobSchema

Section titled “WatchdogSettledJobSchema”

Re-exports WatchdogSettledJobSchema

WatchdogStoredJobSchema

Section titled “WatchdogStoredJobSchema”

Re-exports WatchdogStoredJobSchema

EffectWatchdogOptions

Section titled “EffectWatchdogOptions”

Re-exports EffectWatchdogOptions

EffectWatchdogExecutor

Section titled “EffectWatchdogExecutor”

Re-exports EffectWatchdogExecutor

WatchdogCancellationDecision

Section titled “WatchdogCancellationDecision”

Re-exports WatchdogCancellationDecision

WatchdogCancellationIntent

Section titled “WatchdogCancellationIntent”

Re-exports WatchdogCancellationIntent

WatchdogCancellationResult

Section titled “WatchdogCancellationResult”

Re-exports WatchdogCancellationResult

WatchdogExecutionDecision

Section titled “WatchdogExecutionDecision”

Re-exports WatchdogExecutionDecision

WatchdogIngestResult

Section titled “WatchdogIngestResult”

Re-exports WatchdogIngestResult

WatchdogQueuedJob

Section titled “WatchdogQueuedJob”

Re-exports WatchdogQueuedJob

WatchdogQueueHead

Section titled “WatchdogQueueHead”

Re-exports WatchdogQueueHead

WatchdogReadResult

Section titled “WatchdogReadResult”

Re-exports WatchdogReadResult

WatchdogRunningJob

Section titled “WatchdogRunningJob”

Re-exports WatchdogRunningJob

WatchdogRuntimeEffect

Section titled “WatchdogRuntimeEffect”

Re-exports WatchdogRuntimeEffect

WatchdogSettledJob

Section titled “WatchdogSettledJob”

Re-exports WatchdogSettledJob

WatchdogSqliteCursor

Section titled “WatchdogSqliteCursor”

Re-exports WatchdogSqliteCursor

WatchdogSqliteOwner

Section titled “WatchdogSqliteOwner”

Re-exports WatchdogSqliteOwner

WatchdogSqliteValue

Section titled “WatchdogSqliteValue”

Re-exports WatchdogSqliteValue

WatchdogStoredJob

Section titled “WatchdogStoredJob”

Re-exports WatchdogStoredJob

WatchdogTickResult

Section titled “WatchdogTickResult”

Re-exports WatchdogTickResult

WatchdogTransactionalProjection

Section titled “WatchdogTransactionalProjection”

Re-exports WatchdogTransactionalProjection