polaris_events
Poll and acknowledge delivery events from a transactional outbox by consumer, using cursors to resume and prevent redelivery.
Instructions
Consume delivery events published through the transactional outbox.
Actions and required parameters:
poll: consumer_id (stable identity, 1-100 chars) — returns events newer than
cursor(optional limit). Persist the returned nextCursor between polls; without a cursor you start from the oldest event. After successfully processing events, acknowledge them.acknowledge: consumer_id + event_ids (1-500 ids) — acknowledged events are never redelivered to that consumer; acknowledgement is idempotent per (consumer, event) pair.
Event JSON: {id, type (e.g. EvaluationRecorded, FitnessFunctionVersionActivated), version, aggregateType, aggregateId, occurredAt, actor, correlationId, payload}.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| limit | No | ||
| action | Yes | ||
| cursor | No | ||
| all_pages | No | ||
| event_ids | No | ||
| consumer_id | No |