Step Functions · EventBridge · SQS

Serverless, Workflow & Integration

Durable workflows, an event bus, connectors, realtime channels, rules and schedules.

64operations
6services
24endpoints shown
4architecture seams

What it is

Durable workflows, an event bus, connectors, realtime channels, rules and schedules.

The integration plane: Temporal durable workflows with signals and resets, an event bus with schemas and consumer groups, an integration hub with connectors, DLQ replay and canonical events, realtime presence channels, a versioned rules engine with replayable receipts, and exactly-once scheduling.

Auth is one model across every service here — an SS-01 bearer token plus X-Tenant-Id on every /api/v1 route. Public base https://api.nexocloud.io/api/v1.

Services & endpoints

6 real backends, 64 operations.

Every path below is a real route from services/<svc>/openapi.json. Each service lists a representative slice of its full contract.

Temporal Workflows SS-12

8 operations

Durable workflows — namespaces, workflow start/advance, signals, resets and stuck-workflow detection.

  • POST/api/v1/workflowsStart a durable workflow.
  • POST/api/v1/workflows/{id}/signalsSend a signal to a running workflow.
  • POST/api/v1/workflows/{id}/resetReset a workflow to an earlier event.
  • GET/api/v1/workflows/stuckList workflows that are stuck.

Event Bus SS-03

8 operations

Event bus — topics, schema registry, publish/consume and compacted topics with consumer-group commits.

  • POST/api/v1/topicsCreate a topic.
  • POST/api/v1/topics/{name}/messagesPublish a message to a topic.
  • POST/api/v1/topics/{name}/schemasRegister a schema for a topic.
  • POST/api/v1/topics/{name}/groups/{group}/commitCommit a consumer-group offset.

Integration Hub SS-23

16 operations

Integration hub — providers, endpoints with circuit breakers, delivery attempts, DLQ replay and canonical events.

  • POST/api/v1/endpointsRegister a delivery endpoint.
  • POST/api/v1/emitEmit a canonical event into the hub.
  • POST/api/v1/dlq/{id}/replayReplay a dead-lettered delivery.
  • POST/api/v1/endpoints/{id}/breaker/resetReset a tripped circuit breaker.

Realtime SS-16

10 operations

Realtime channels — publish, subscribe, presence, history and resumable connections.

  • POST/api/v1/channels/{name}/publishPublish a message to a channel.
  • POST/api/v1/channels/{name}/subscribeSubscribe to a channel.
  • GET/api/v1/channels/{name}/presenceRead channel presence.
  • POST/api/v1/channels/{name}/resumeResume a dropped connection from a cursor.

Rules Engine SS-17

11 operations

Rules engine — versioned rulesets, evaluate (and as-of), certify, simulate and rollback with replayable receipts.

  • POST/api/v1/rulesets/{name}/evaluateEvaluate a ruleset against input.
  • POST/api/v1/rulesets/{name}/evaluate-as-ofEvaluate as of a historical ruleset version.
  • POST/api/v1/rulesets/{name}/versions/{n}/simulateSimulate a ruleset version before activation.
  • POST/api/v1/receipts/{id}/re-deriveRe-derive a decision from its receipt.

Scheduling SS-21

11 operations

Scheduling — schedules with calendars, previews, pause/resume, run-now and exactly-once fire acks.

  • POST/api/v1/schedulesCreate a schedule.
  • GET/api/v1/schedules/{id}/previewPreview upcoming fire times.
  • POST/api/v1/schedules/{id}/run-nowFire a schedule immediately.
  • POST/api/v1/fires/{key}/ackAcknowledge a fire for exactly-once semantics.

Worked example

An event triggers a durable workflow

A published event fans out through the bus, a durable workflow coordinates the long-running steps, and a rules receipt records exactly why each branch was taken.

  1. 1
    Publish the eventPOST/api/v1/topics/{name}/messages

    Schema-validated against the topic's registered schema.

  2. 2
    Start the workflowPOST/api/v1/workflows

    Temporal drives the multi-step process with durable state.

  3. 3
    Decide with rulesPOST/api/v1/rulesets/{name}/evaluate

    Versioned rules produce a replayable receipt for each decision.

  4. 4
    Signal progressPOST/api/v1/workflows/{id}/signals

    External events signal the workflow to advance.

Architecture placement

Where it sits in the platform.

Serverless, Workflow & Integration does not reimplement the platform — it composes it. These are the services it leans on and the seams between them.

Temporal (SS-12)

Durable, resumable workflows for long-running orchestration.

Event Bus (SS-03) + Integration (SS-23)

Schema-checked events, connectors and DLQ replay.

Realtime (SS-16)

Presence channels for live client fan-out.

Rules (SS-17) + Scheduling (SS-21)

Versioned decisions with receipts, and exactly-once schedules.