REFERENCE ARCHITECTURE

Event-driven integration

Asynchronous workflows with Conduit (Kafka), Lane (RabbitMQ), and Beacon (NATS) — decouple producers from consumers and scale workers independently.

IntermediatePlan: Business+Resilience: multi-zona

Diagram

Use cases

  • Order fulfillment
  • Webhook fan-out
  • Legacy system integration

Components

LayerRoleProduct
IngressPublic API entryGateway + Compute
Event logDurable ordered streamsConduit
Job queuesTask dispatch + dead-letterLane
Pub/subLightweight notificationsBeacon
WorkersIdempotent consumersCompute + Autoscale
StateCheckpoints and audit trailDatastore
OperationsQueue lag and DLQ alertsInsight

Products

When to use

  • Order pipelines, webhook fan-out, audit event streams.
  • Peak traffic buffering (Black Friday, batch imports).
  • Integrating legacy systems without synchronous coupling.

When to avoid

  • Simple CRUD with immediate read-your-writes — synchronous API is simpler.
  • Teams without idempotent consumer design discipline.

Design notes

Pick the right bus

Conduit for durable event logs and replay. Lane for job queues with ACK. Beacon for lightweight pub/sub notifications.

Idempotent workers

Design Compute workers to handle duplicate messages. Store processing checkpoints in Datastore.

Dead-letter strategy

Route failed Lane messages to a dedicated queue and alert via Insight.

Blueprint

Use this JSON as a starting point when creating a project via the Tesserra API or console. Replace image URLs, domains, and resource references with your values.

json
{
  "nome": "Order Pipeline",
  "modo": "avancado",
  "recursos": [
    {
      "tipo": "compute",
      "nome": "orders-api",
      "config": {
        "subtipo": "api",
        "porta": 3000,
        "replicas_min": 2
      }
    },
    {
      "tipo": "conduit",
      "nome": "order-events",
      "config": {
        "particoes": 6,
        "retencao_horas": 168
      }
    },
    {
      "tipo": "lane",
      "nome": "fulfillment-jobs",
      "config": {
        "prefetch": 10,
        "duravel": true
      }
    },
    {
      "tipo": "beacon",
      "nome": "notifications",
      "config": {
        "jetstream": true
      }
    },
    {
      "tipo": "compute",
      "nome": "fulfillment-worker",
      "config": {
        "subtipo": "worker",
        "replicas_min": 1,
        "replicas_max": 8
      }
    },
    {
      "tipo": "datastore",
      "nome": "pipeline-db",
      "config": {
        "engine": "postgres",
        "tamanho_gb": 30
      }
    },
    {
      "tipo": "insight",
      "nome": "pipeline-insight",
      "config": {
        "retencao_dias": 30,
        "alertas": true
      }
    }
  ]
}
Documentation · Tesserra