{
  "code": null,
  "collection": "architecture",
  "href": "https://banes-lab.com/ontology#architecture-event-stream",
  "id": "event-stream",
  "kind": "mechanism",
  "layer": {
    "href": "https://banes-lab.com/ontology/schema#layer-execution-core",
    "json": "https://banes-lab.com/json/records/layer/execution-core",
    "label": "Execution Core",
    "markdown": "https://banes-lab.com/records/layer/execution-core.md",
    "ref": "layer:execution-core"
  },
  "name": "Event Stream",
  "ref": "architecture:event-stream",
  "relations": [
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-ordered-log",
          "json": "https://banes-lab.com/json/records/lexicon/ordered-log",
          "label": "Ordered Log",
          "markdown": "https://banes-lab.com/records/lexicon/ordered-log.md",
          "ref": "lexicon:ordered-log"
        },
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-event-schema",
          "json": "https://banes-lab.com/json/records/lexicon/event-schema",
          "label": "Event Schema",
          "markdown": "https://banes-lab.com/records/lexicon/event-schema.md",
          "ref": "lexicon:event-schema"
        }
      ],
      "relation": "requires"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology#architecture-streaming-architecture",
          "json": "https://banes-lab.com/json/records/architecture/streaming-architecture",
          "label": "Streaming Architecture",
          "markdown": "https://banes-lab.com/records/architecture/streaming-architecture.md",
          "ref": "architecture:streaming-architecture"
        }
      ],
      "relation": "reinforces"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-replay",
          "json": "https://banes-lab.com/json/records/lexicon/replay",
          "label": "Replay",
          "markdown": "https://banes-lab.com/records/lexicon/replay.md",
          "ref": "lexicon:replay"
        },
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-continuous-processing",
          "json": "https://banes-lab.com/json/records/lexicon/continuous-processing",
          "label": "Continuous Processing",
          "markdown": "https://banes-lab.com/records/lexicon/continuous-processing.md",
          "ref": "lexicon:continuous-processing"
        }
      ],
      "relation": "enables"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-mutable-state-only",
          "json": "https://banes-lab.com/json/records/lexicon/mutable-state-only",
          "label": "Mutable State Only",
          "markdown": "https://banes-lab.com/records/lexicon/mutable-state-only.md",
          "ref": "lexicon:mutable-state-only"
        }
      ],
      "relation": "conflicts-with"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-storage-volume",
          "json": "https://banes-lab.com/json/records/lexicon/storage-volume",
          "label": "Storage Volume",
          "markdown": "https://banes-lab.com/records/lexicon/storage-volume.md",
          "ref": "lexicon:storage-volume"
        }
      ],
      "relation": "tensions-with"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/schema#tension-event-stream-storage-volume",
          "json": "https://banes-lab.com/json/records/tension/event-stream-storage-volume",
          "label": "Event Stream / Storage Volume",
          "markdown": "https://banes-lab.com/records/tension/event-stream-storage-volume.md",
          "ref": "tension:event-stream-storage-volume"
        }
      ],
      "relation": "tensions"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-non-replayable-processing",
          "json": "https://banes-lab.com/json/records/lexicon/non-replayable-processing",
          "label": "Non-Replayable Processing",
          "markdown": "https://banes-lab.com/records/lexicon/non-replayable-processing.md",
          "ref": "lexicon:non-replayable-processing"
        }
      ],
      "relation": "violated-by"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-offset-tracking",
          "json": "https://banes-lab.com/json/records/lexicon/offset-tracking",
          "label": "Offset Tracking",
          "markdown": "https://banes-lab.com/records/lexicon/offset-tracking.md",
          "ref": "lexicon:offset-tracking"
        }
      ],
      "relation": "refactored-by"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/schema#vocabulary-severity-contextual",
          "json": "https://banes-lab.com/json/records/vocabulary/severity-contextual",
          "label": "contextual",
          "markdown": "https://banes-lab.com/records/vocabulary/severity-contextual.md",
          "ref": "vocabulary:severity-contextual"
        }
      ],
      "relation": "severity"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology#architecture-category-event-messaging-asynchronous-architecture",
          "json": "https://banes-lab.com/json/records/architecture-category/event-messaging-asynchronous-architecture",
          "label": "Event / Messaging / Asynchronous Architecture",
          "markdown": "https://banes-lab.com/records/architecture-category/event-messaging-asynchronous-architecture.md",
          "ref": "architecture-category:event-messaging-asynchronous-architecture"
        }
      ],
      "relation": "category"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology#architecture-memory-efficiency",
          "json": "https://banes-lab.com/json/records/architecture/memory-efficiency",
          "label": "Memory Efficiency",
          "markdown": "https://banes-lab.com/records/architecture/memory-efficiency.md",
          "ref": "architecture:memory-efficiency"
        }
      ],
      "relation": "refactors"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology#architecture-category-error-handling-resilience",
          "json": "https://banes-lab.com/json/ontology/principles/architecture-category-error-handling-resilience",
          "label": "Error Handling / Resilience",
          "markdown": "https://banes-lab.com/ontology/principles/architecture-category-error-handling-resilience.md",
          "ref": "chapter:/ontology#architecture-category-error-handling-resilience"
        },
        {
          "href": "https://banes-lab.com/ontology#architecture-category-scalability-performance-optimization",
          "json": "https://banes-lab.com/json/ontology/principles/architecture-category-scalability-performance-optimization",
          "label": "Scalability / Performance / Optimization",
          "markdown": "https://banes-lab.com/ontology/principles/architecture-category-scalability-performance-optimization.md",
          "ref": "chapter:/ontology#architecture-category-scalability-performance-optimization"
        },
        {
          "href": "https://banes-lab.com/ontology#architecture-category-streaming-pipeline-dataflow-processing",
          "json": "https://banes-lab.com/json/ontology/principles/architecture-category-streaming-pipeline-dataflow-processing",
          "label": "Streaming / Pipeline / Dataflow Processing",
          "markdown": "https://banes-lab.com/ontology/principles/architecture-category-streaming-pipeline-dataflow-processing.md",
          "ref": "chapter:/ontology#architecture-category-streaming-pipeline-dataflow-processing"
        },
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-category-core-vocabulary",
          "json": "https://banes-lab.com/json/ontology/lexicon/lexicon-category-core-vocabulary",
          "label": "Core Vocabulary",
          "markdown": "https://banes-lab.com/ontology/lexicon/lexicon-category-core-vocabulary.md",
          "ref": "chapter:/ontology/lexicon#lexicon-category-core-vocabulary"
        },
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-category-event-messaging-async",
          "json": "https://banes-lab.com/json/ontology/lexicon/lexicon-category-event-messaging-async",
          "label": "Event Messaging Async",
          "markdown": "https://banes-lab.com/ontology/lexicon/lexicon-category-event-messaging-async.md",
          "ref": "chapter:/ontology/lexicon#lexicon-category-event-messaging-async"
        },
        {
          "href": "https://banes-lab.com/ontology/schema#the-vocabulary-severity",
          "json": "https://banes-lab.com/json/ontology/schema/the-vocabulary-severity",
          "label": "Severity levels",
          "markdown": "https://banes-lab.com/ontology/schema/the-vocabulary-severity.md",
          "ref": "chapter:/ontology/schema#the-vocabulary-severity"
        },
        {
          "href": "https://banes-lab.com/ontology/schema#the-resolutions",
          "json": "https://banes-lab.com/json/ontology/schema/the-resolutions",
          "label": "The resolutions",
          "markdown": "https://banes-lab.com/ontology/schema/the-resolutions.md",
          "ref": "chapter:/ontology/schema#the-resolutions"
        }
      ],
      "relation": "linked-from"
    }
  ],
  "summary": "A mechanism that keeps events in an ordered, replayable log that consumers read from their own offset.",
  "siblings": {
    "next": {
      "href": "https://banes-lab.com/ontology#architecture-event-sourcing",
      "json": "https://banes-lab.com/json/records/architecture/event-sourcing",
      "label": "Event Sourcing",
      "markdown": "https://banes-lab.com/records/architecture/event-sourcing.md",
      "ref": "architecture:event-sourcing"
    },
    "previous": {
      "href": "https://banes-lab.com/ontology#architecture-event-bus",
      "json": "https://banes-lab.com/json/records/architecture/event-bus",
      "label": "Event Bus",
      "markdown": "https://banes-lab.com/records/architecture/event-bus.md",
      "ref": "architecture:event-bus"
    }
  },
  "up": {
    "href": null,
    "json": "https://banes-lab.com/json/api/records/architecture",
    "label": "Architecture principles",
    "markdown": "https://banes-lab.com/api/records/architecture.md",
    "ref": "api:records/architecture"
  },
  "aliases": [],
  "exemplar": {
    "after": "const stream = fooEvents.stream(fooId);\nfor await (const event of stream) fooProjection.apply(event);",
    "before": "const latest = await fooApi.getCurrentState(fooId);",
    "lang": "ts",
    "medium": "code"
  },
  "formedBy": null,
  "scope": [
    "stream processing",
    "integration"
  ],
  "severity": "contextual"
}