Module sources 

Source factories (D43/D40/D111).

Sync sources run directly in the source body. Async/time sources stay at the source/driver boundary: they schedule work on the graph-local driver and emit later through DeferredCtx, preserving the sync wave core.

Structs

CronInstant

Fieldized instant used by matches_cron.

CronParseError

Error returned by parse_cron.

CronSchedule

Minimal five-field cron schedule: minute hour day-of-month month day-of-week.

CronTick

Value emitted by from_cron.

FromCronOptions

FromCronOptions data container.

FromFsWatchOptions

Options for from_fs_watch_with_options.

FromGitHookOptions

FromGitHookOptions data container.

FsEvent

Filesystem event emitted by from_fs_watch.

GitEvent

Git event emitted by from_git_hook.

Enums

FsEventKind

Filesystem event kind emitted by from_fs_watch.

GitHookType

GitHookType variants.

SyncValueFromError

Host-boundary result for first_sync_value_from and single_sync_value_from.

Functions

empty

empty: COMPLETE immediately with no DATA.

first_sync_value_from

Read the first DATA value delivered during the synchronous subscribe window.

from_cron

from_cron: emit a CronTick when the schedule matches the current minute.

from_cron_with_options

Configurable form of from_cron.

from_fs_watch

from_fs_watch: filesystem watcher source.

from_fs_watch_with_options

Configurable form of from_fs_watch.

from_git_hook

from_git_hook: poll a local Git repository and emit post-commit events.

from_git_hook_with_options

Configurable form of from_git_hook.

from_http

Creates or computes from_http.

from_http_with_options

Creates or computes from_http_with_options.

from_iter

from_iter: emit every item in order, then COMPLETE, on activation.

from_process

from_process: source-name alias for run_process.

from_sse

Creates or computes from_sse.

from_sse_with_options

Creates or computes from_sse_with_options.

from_timer

from_timer: stable source-name alias for timer.

from_webhook

from_webhook: register an inbound webhook bridge through the graph environment.

from_webhook_with_options

Configurable form of from_webhook.

from_websocket

Creates or computes from_websocket.

from_websocket_with_options

Creates or computes from_websocket_with_options.

future_local

future_local: run a fresh single-thread local fallible future on activation.

interval

interval: ticks 0, 1, 2, ... every ms until deactivation.

matches_cron

Test whether an instant matches a parsed five-field cron schedule.

never

never: activate and remain silent until deactivation.

of

of: emit one value and COMPLETE on activation.

parse_cron

Parse a standard five-field cron expression.

run_process

run_process: execute one process via the graph-local environment process driver.

run_process_with_options

Configurable form of run_process.

single_sync_value_from

Read exactly one DATA value from a synchronously completing source.

stream_local

stream_local: pump a fresh single-thread local fallible stream through the graph-local driver. Every Ok(item) becomes DATA; stream exhaustion emits COMPLETE; the first Err(error) emits ERROR and terminates the source.

throw_error

throw_error: terminate with ERROR on activation.

timer

timer: one tick (0) after ms, then COMPLETE.