Struct RefreshScheduler 

pub struct RefreshScheduler { /* private fields */ }

Manages background refresh tasks for dynamic sources.

The scheduler spawns per-source tasks based on their refresh policy and sends RefreshResult notifications whenever source data changes.

Implementations

impl RefreshScheduler

pub fn new() -> Self

Create a new scheduler.

pub fn trigger_sender(&self) -> Sender<RefreshTrigger>

Get a sender for triggering on-demand resolution.

pub fn result_receiver(&self) -> Receiver<Option<RefreshResult>>

Get a receiver that is notified when sources are refreshed.

pub fn subscribe( self, sources: Vec<DynamicSource>, resolver: Arc<dyn SourceResolver>, ) -> SourceSubscription

Start the scheduler for a detached, non-pipeline consumer.

Returns a SourceSubscription bundling the spawned coordination task, a watch receiver of decoded source payloads, and a trigger sender for on-demand re-resolution. This is the seam used by consumers that want a source’s decoded payload directly (rather than bound into a pipeline ${source.*} namespace): it reuses the same per-source file, HTTP, and NATS fetch and refresh machinery as the pipeline binder via Self::run, so that logic is never duplicated.

pub fn run( self, sources: Vec<DynamicSource>, resolver: Arc<dyn SourceResolver>, ) -> JoinHandle<()>

Start the scheduler background loop.

Takes ownership of the trigger receiver and spawns per-source interval tasks. Returns a JoinHandle for the main coordination task.

When a refresh occurs (via interval timer or on-demand trigger), all sources are re-resolved and the result is published on the watch channel.

Trait Implementations

impl Default for RefreshScheduler

fn default() -> Self

Returns the “default value” for a type.