pub async fn assert_capabilities_truthful<S, F, Fut>(
sink: &S,
distinct_count: F,
)Expand description
Check 5. Assert a sink’s advertised capabilities match real behaviour:
Append(always supported) actually adds rows;- a declared idempotent/keyed mechanism actually dedups (reuses check 4);
supports_schema_evolution()impliesevolve_schemais callable (not the default “unsupported” error);- the honest-false branch: a non-idempotent sink’s
write_batch_idempotentdelegates towrite_batchand records no token.
distinct_count reports the destination’s current distinct-row count.