{
  "code": null,
  "collection": "architecture",
  "href": "https://banes-lab.com/ontology#architecture-dataflow-architecture",
  "id": "dataflow-architecture",
  "kind": "style",
  "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": "Dataflow Architecture",
  "ref": "architecture:dataflow-architecture",
  "relations": [
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-data-dependencies",
          "json": "https://banes-lab.com/json/records/lexicon/data-dependencies",
          "label": "Data Dependencies",
          "markdown": "https://banes-lab.com/records/lexicon/data-dependencies.md",
          "ref": "lexicon:data-dependencies"
        },
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-stages",
          "json": "https://banes-lab.com/json/records/lexicon/stages",
          "label": "Stages",
          "markdown": "https://banes-lab.com/records/lexicon/stages.md",
          "ref": "lexicon:stages"
        }
      ],
      "relation": "requires"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology#architecture-pipeline-architecture",
          "json": "https://banes-lab.com/json/records/architecture/pipeline-architecture",
          "label": "Pipeline Architecture",
          "markdown": "https://banes-lab.com/records/architecture/pipeline-architecture.md",
          "ref": "architecture:pipeline-architecture"
        }
      ],
      "relation": "reinforces"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-parallel-stream-processing",
          "json": "https://banes-lab.com/json/records/lexicon/parallel-stream-processing",
          "label": "Parallel/Stream Processing",
          "markdown": "https://banes-lab.com/records/lexicon/parallel-stream-processing.md",
          "ref": "lexicon:parallel-stream-processing"
        }
      ],
      "relation": "enables"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-control-flow-centric-monolith",
          "json": "https://banes-lab.com/json/records/lexicon/control-flow-centric-monolith",
          "label": "Control-Flow-Centric Monolith",
          "markdown": "https://banes-lab.com/records/lexicon/control-flow-centric-monolith.md",
          "ref": "lexicon:control-flow-centric-monolith"
        }
      ],
      "relation": "conflicts-with"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-state-coordination",
          "json": "https://banes-lab.com/json/records/lexicon/state-coordination",
          "label": "State Coordination",
          "markdown": "https://banes-lab.com/records/lexicon/state-coordination.md",
          "ref": "lexicon:state-coordination"
        }
      ],
      "relation": "tensions-with"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/schema#tension-dataflow-architecture-state-coordination",
          "json": "https://banes-lab.com/json/records/tension/dataflow-architecture-state-coordination",
          "label": "Dataflow Architecture / State Coordination",
          "markdown": "https://banes-lab.com/records/tension/dataflow-architecture-state-coordination.md",
          "ref": "tension:dataflow-architecture-state-coordination"
        }
      ],
      "relation": "tensions"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-hidden-dependency",
          "json": "https://banes-lab.com/json/records/lexicon/hidden-dependency",
          "label": "Hidden Dependency",
          "markdown": "https://banes-lab.com/records/lexicon/hidden-dependency.md",
          "ref": "lexicon:hidden-dependency"
        }
      ],
      "relation": "violated-by"
    },
    {
      "links": [
        {
          "href": "https://banes-lab.com/ontology#architecture-pipeline-architecture",
          "json": "https://banes-lab.com/json/records/architecture/pipeline-architecture",
          "label": "Pipeline Architecture",
          "markdown": "https://banes-lab.com/records/architecture/pipeline-architecture.md",
          "ref": "architecture:pipeline-architecture"
        }
      ],
      "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-streaming-pipeline-dataflow-processing",
          "json": "https://banes-lab.com/json/records/architecture-category/streaming-pipeline-dataflow-processing",
          "label": "Streaming / Pipeline / Dataflow Processing",
          "markdown": "https://banes-lab.com/records/architecture-category/streaming-pipeline-dataflow-processing.md",
          "ref": "architecture-category:streaming-pipeline-dataflow-processing"
        }
      ],
      "relation": "category"
    },
    {
      "links": [
        {
          "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-causality-ordering-distributed-time",
          "json": "https://banes-lab.com/json/ontology/lexicon/lexicon-category-causality-ordering-distributed-time",
          "label": "Causality / Ordering / Distributed Time",
          "markdown": "https://banes-lab.com/ontology/lexicon/lexicon-category-causality-ordering-distributed-time.md",
          "ref": "chapter:/ontology/lexicon#lexicon-category-causality-ordering-distributed-time"
        },
        {
          "href": "https://banes-lab.com/ontology/lexicon#lexicon-category-streaming-pipeline-dataflow-processing",
          "json": "https://banes-lab.com/json/ontology/lexicon/lexicon-category-streaming-pipeline-dataflow-processing",
          "label": "Streaming / Pipeline / Dataflow Processing",
          "markdown": "https://banes-lab.com/ontology/lexicon/lexicon-category-streaming-pipeline-dataflow-processing.md",
          "ref": "chapter:/ontology/lexicon#lexicon-category-streaming-pipeline-dataflow-processing"
        },
        {
          "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 convention of arranging processing as a graph of stages connected by explicit data edges, where a stage runs when its inputs arrive.",
  "siblings": {
    "next": {
      "href": "https://banes-lab.com/ontology#architecture-stateless-processing",
      "json": "https://banes-lab.com/json/records/architecture/stateless-processing",
      "label": "Stateless Processing",
      "markdown": "https://banes-lab.com/records/architecture/stateless-processing.md",
      "ref": "architecture:stateless-processing"
    },
    "previous": {
      "href": "https://banes-lab.com/ontology#architecture-forward-only-processing",
      "json": "https://banes-lab.com/json/records/architecture/forward-only-processing",
      "label": "Forward-Only Processing",
      "markdown": "https://banes-lab.com/records/architecture/forward-only-processing.md",
      "ref": "architecture:forward-only-processing"
    }
  },
  "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 graph = dataflow()\n  .source(\"foo\", fooSource)\n  .map(\"bar\", \"foo\", toBar)\n  .map(\"baz\", \"bar\", toBaz)\n  .sink(\"output\", \"baz\", bazSink);\nawait graph.run();",
    "before": "controller.runFoo();\ncontroller.runBar();\ncontroller.runBaz();",
    "lang": "ts",
    "medium": "code"
  },
  "formedBy": null,
  "scope": [
    "processing",
    "workflow",
    "stream"
  ],
  "severity": "contextual"
}