Skip to main content

probe_invocation

Function probe_invocation 

Source
pub async fn probe_invocation(
    id: String,
    source: ConnectorSpec,
    sink: ConnectorSpec,
    state: Option<StateStoreSpec>,
    auth: &AuthCatalog,
    ctx: &CheckContext,
    sla: Option<(SlaSpec, String)>,
) -> InvocationOut
Expand description

Build the three connectors for one invocation and run their probes. When an sla: block is configured, sla carries the spec plus the invocation’s base state key so the persisted SLA history can be probed read-only (staleness vs max_staleness_secs, volume-baseline warm-up).