Module sources 

Dynamic source resolution for Sigma pipelines.

This module provides the SourceResolver trait and a DefaultSourceResolver implementation that fetches data from file, command, HTTP, and NATS sources declared in a pipeline’s sources section.

Re-exports

pub use cache::SourceCache;

pub use template::TemplateExpander;

Modules

cache

Source resolution cache with in-memory and optional SQLite persistence.

command

Command source resolver: runs a local command and captures stdout.

extract

Expression-based data extraction for dynamic sources.

file

File source resolver: reads data from local files.

http

HTTP source resolver: fetches data from HTTP endpoints.

include

Include expansion for dynamic pipelines.

refresh

Background refresh scheduler for dynamic pipeline sources.

registry

Daemon-wide source registry that merges external (--source) and pipeline-declared dynamic sources with collision-error semantics.

template

Template expansion for dynamic pipeline sources.

Structs

DefaultSourceResolver

Default source resolver that dispatches to file, command, and HTTP resolvers.

ResolvedValue

The result of successfully resolving a dynamic source.

SourceError

An error that occurred while resolving a dynamic source.

Enums

SourceErrorKind

The kind of error that occurred during source resolution.

Constants

MAX_SOURCE_RESPONSE_BYTES

Maximum size of a source response body (HTTP, command stdout, NATS payload).

MIN_REFRESH_INTERVAL

Minimum allowed refresh interval to prevent hot CPU loops.

Traits

SourceResolver

Trait for resolving dynamic pipeline sources.

Functions

resolve_all

Resolve all sources in a pipeline, returning a map of source_id -> resolved data.

resolve_all_with_state

Like resolve_all but also updates a PipelineState with source resolution status.

yaml_value_to_json

Convert a yaml_serde::Value to a serde_json::Value.