Struct WatcherController 

pub struct WatcherController { /* private fields */ }

Wrapper around the SDK’s WatchController. Today this is just a newtype so callers don’t have to import relayburn_sdk directly to construct or stop a watcher; tomorrow it gives us a stable boundary to attach harness-side observability (e.g. a name, a per-adapter metric counter) without leaking through to the SDK.

Implementations

impl WatcherController

pub fn new(inner: WatchController) -> Self

Wrap a raw SDK controller. pending_stamp::adapter is the canonical caller; bespoke adapters that build their own watch loop also funnel through here.

pub async fn tick(&self)

Run a single tick on demand. Forwards to WatchController::tick.

pub async fn stop(&self)

Stop the periodic loop and await any in-flight tick. Idempotent. Call this once the spawned child exits.

pub fn raw(&self) -> &WatchController

Borrow the wrapped controller for callers that need the raw SDK type (e.g. integration tests parking on tick_done).