Integration Platform — workers, grains and sagas¶
Generated from the architecture model
This page is rendered from model/**/*.yaml by tools/docs_model during mkdocs build. Edit the YAML, not this page; hand-written design lives on the linked service, platform and plane pages.
Workers¶
| Worker | Service | Trigger | Output events | Retry | Idempotency key | Concurrency |
|---|---|---|---|---|---|---|
| OutboundDeliveryRetrier | ConnectorRegistryService | schedule */1 * * * * |
DeliveryDispatched, DeliveryFailed | exponential ×5 | deliveryId + attempts |
4 by ConnectorId |
| InboundDispatcher | ConnectorRegistryService | event WebhookGatewayService.InboundDeliveryVerified | DeliveryReceived, DeliveryDispatched, DeliveryFailed | exponential ×5 | dedupKey |
8 by SubscriptionId |
| ConformanceRunner | ConnectorRegistryService | manual on CertifyConnector |
ConnectorActivated | fixed ×1 | connectorId + version + suiteVersion |
2 by ConnectorId |
| ConnectionHealthProbe | IntegrationService | schedule */10 * * * * |
ConnectionStateChanged | fixed ×2 | connectionId + probeWindow |
4 by Provider |
| RotationReminder | IntegrationService | schedule 0 6 * * * |
— | fixed ×2 | connectionId + day |
2 by TenantId |
- OutboundDeliveryRetrier (ConnectorRegistryService): Retries failed outbound deliveries per the connector's retry profile within the calling tool's budget; final failure emits DeliveryFailed.
- InboundDispatcher (ConnectorRegistryService): Dispatches verified inbound deliveries to workflow triggers, knowledge sync or fleet signals and acknowledges.
- ConformanceRunner (ConnectorRegistryService): Runs the connector conformance suite (capability calls against a sandbox connection) and records certification evidence.
- ConnectionHealthProbe (IntegrationService): Probes Active connections with a read-only provider call through brokered credentials and marks Degraded or Active.
- RotationReminder (IntegrationService): Raises Studio tasks and audit events for connections whose rotation is due or whose grants expire.
Grains (actors)¶
None modelled
No grains are modelled for this item yet.
Sagas¶
None modelled
No sagas are modelled for this item yet.