@usine/orchestrator/schedule-triggers

Classes

ScheduleAgentFailure

A schedule loop whose agent is no longer in the loaded roster.

Extends

• Schema.Class

Constructors

Constructor

new ScheduleAgentFailure(…args): ScheduleAgentFailure

Parameters

Parameter	Type
…args	[props: object, options?: MakeOptions]

Returns

ScheduleAgentFailure

Properties

agent

readonly agent: string & Brand<"AgentName">

loop

readonly loop: string & Brand<"LoopName">

message

readonly message: string

---

ScheduleCronFailure

A schedule whose cron boundaries could not be computed at this instant. Cron.prev and Cron.next fail inside a DST spring-forward gap even for a cron that parsed; the schedule retries next cycle and its siblings run.

Extends

• Schema.Class

Constructors

Constructor

new ScheduleCronFailure(…args): ScheduleCronFailure

Parameters

Parameter	Type
…args	[props: object, options?: MakeOptions]

Returns

ScheduleCronFailure

Properties

cron

readonly cron: string

loop

readonly loop: string & Brand<"LoopName">

message

readonly message: string

tz

readonly tz: string

---

ScheduleCycle

The result of evaluating every schedule loop at one instant.

Extends

• Schema.Class

Constructors

Constructor

new ScheduleCycle(…args): ScheduleCycle

Parameters

Parameter	Type
…args	[props: object, options?: MakeOptions]

Returns

ScheduleCycle

Properties

alreadyFired

readonly alreadyFired: number

failures

readonly failures: readonly (ScheduleAgentFailure | ScheduleTickFailure | ScheduleCronFailure)[]

fanout

readonly fanout: number

loops

readonly loops: number

nextTickAt

readonly nextTickAt: Option<Utc>

skipped

readonly skipped: number

submissions

readonly submissions: readonly (Claimed | Queued | Ignored | CycleBlocked)[]

---

ScheduleTickFailure

A selected repository whose Tick could not be evaluated or submitted.

Extends

• Schema.Class

Constructors

Constructor

new ScheduleTickFailure(…args): ScheduleTickFailure

Parameters

Parameter	Type
…args	[props: object, options?: MakeOptions]

Returns

ScheduleTickFailure

Properties

errorTag

readonly errorTag: string

loop

readonly loop: string & Brand<"LoopName">

message

readonly message: string

repository

readonly repository: string & Brand<"RepositoryName">

scheduledAt

readonly scheduledAt: Utc

---

ScheduleTriggers

Turns due schedule ticks into one Event per selected repository.

Extends

• Context.ServiceClass

Properties

Service

readonly Service: object

The service’s operations: what yield* ScheduleTriggers returns.

latest

readonly latest: Effect.Effect<Option.Option<ScheduleCycle>>

run

readonly run: (instance) => Effect.Effect<never>

Parameters

Parameter	Type
instance	LoadedInstance

Returns

Effect.Effect<never>

tick

readonly tick: (instance) => Effect.Effect<ScheduleCycle, EnginePersistenceError>

Evaluates the latest due Tick of every schedule. A repository’s failure is logged and reported without stopping its siblings; a cron failure in a DST gap fails only its own schedule.

Parameters

Parameter	Type
instance	LoadedInstance

Returns

Effect.Effect<ScheduleCycle, EnginePersistenceError>

layer

readonly static layer: Layer<ScheduleTriggers, never, ConfigParser | ExpressionEngine | RunEngine | LoopControl>

Type Aliases

ScheduleFailure

ScheduleFailure = typeof ScheduleFailure.Type

Variables

ScheduleFailure

const ScheduleFailure: Schema.Union<readonly [typeof ScheduleAgentFailure, typeof ScheduleCronFailure, typeof ScheduleTickFailure]>