Skip to content

The Pipeline Framework

Main Navigation

Coffee Machine

Search

Portable Serverless Functions

State, Replay, and Queryable Data

Start Monolith, Split Later

Operational Confidence

Plugins, Not Glue

Architectural Decisions

Data Architecture

Immutable Dataflow

Data coupling

Query and Command

Effects and comparisons

Functional Core, Imperative Shell

State Model

Application Structure

Common Module Structure

JPA Query Connector

Predicates and Selection

Capture and Persistence

Caching

Field Materialization

Expansion and Reduction

Operator Reuse Strategy

Runtime Topology Strategy

Design Best Practices

Spring Support Status

Pipeline Compilation

Generated Artifacts

Module Ownership

Build Integration

Verification and Troubleshooting

Configuration

Build-Time Settings

Runtime Settings

Await and Checkpoint

Transport and Platform

Providers and Plugins

All Settings

Application Configuration

Replay Viewer Parameters

Lambda-Focused Configuration

Pipeline Template DSL

@PipelineStep Annotation

Code a Step

Item Reject Sink

Operators

Operator Build Troubleshooting

Delegation and Extension

External Library Delegation

Use Existing Java Methods

Operator Service Contracts

Legacy Delegation Migration

Operator Delegation Reference

Operator Libraries

Client Steps

Orchestrator Runtime Extensions

Handling File Operations

Testing with Testcontainers

Runtime Layouts

Using Runtime Mapping

Maven Migration Playbook

POM vs Layout Matrix

CSV Payments Pipeline-Runtime

CSV Payments Monolith

Orchestrator Runtime

Function Platforms

Azure Functions Platform

Google Cloud Run Functions Platform

Multi-Cloud Function Providers

Search Lambda Verification Lane

Search Azure Verification Lane

Azure Deployment Walkthrough

Azure Troubleshooting

Search Azure Reference

Dependency Management

Pipeline Parent POM Lifecycle

CSV Payments POM Lifecycle

Checkpoint Handoff

Concurrency and Backpressure Sizing

Operators

Operator Troubleshooting

Observability

Metrics

Tracing

Replay & Live Topology

Queue-Async Immutable Boundaries

Architecture Reference

Operators

Runtime Mapping

Annotation Processing

Synthetics

Implementation Plan

TDD Plan

Validation & Migration Examples

TPFGo

Design Spectrum

DDD Alignment

Observer and Tap Contract

Roadmap

Roadmap Archive

Durable Coordinator

Coordinator And Worker Topology

Worker Protocols

Step-Aware Invocation Runtime

Bundle Contract

Pipeline Contract And Release Model

Runtime Boundaries And Performance

All-Serverless Coordinator

Local APIs

Self-Hosted Deployment

Self-Hosted HA Roadmap

Self-Hosted Milestone

Brokered Boundaries

Boundary Taxonomy

Dispatch Substrates

Envelope And Data Policy

Adoption And Slices

Framework Portability Assessment

Guide Overview

Full Assessment Snapshot

Persistence Portability

Annotation Removal

Code Generation Portability

Maven And Scaffolding

Roadmap And Guardrails

Annotation Processor Guide

Phases and Flow

Models and Bindings

Generation and Rendering

Current Architecture

Annotation Processor Architecture (Compat)

Compiler Pipeline Architecture

Runtime Core Decoupling

I/O Shell Absorption

Data Types

Canonical Domain Readiness

Typed Union Output Contracts

Plugins Architecture

Reference Implementation

Reference Implementation Archive

Template Generator

Release And Publishing

Framework Release Process

Docs Snapshot Process

Proto Descriptor Integration

Protobuf-over-HTTP Dispatch Design

Aspects

Await Unit Runtime

Appearance

Sidebar Navigation

Value

Overview

Coffee Machine

Search

Quotes

Personas

Business Value

Developer Joy

Performance

Portable Serverless Functions

State, Replay, and Queryable Data

Start Monolith, Split Later

Operational Confidence

Plugins, Not Glue

Design

Overview

Architectural Decisions

Data Architecture

Immutable Dataflow

Data coupling

Query and Command

Effects and comparisons

Functional Core, Imperative Shell

State Model

Application Structure

Common Module Structure

Operators

Execution Safety

Await Boundaries

Object Ingest

JPA Query Connector

Overview

Setup and YAML

Predicates and Selection

Capture and Persistence

Caching

Overview

Configuration

Policies

Invalidation

Replay Walkthrough

Key Strategy

Cache vs Persistence

Persistence

Field Materialization

Expansion and Reduction

Operator Reuse Strategy

Runtime Topology Strategy

Design Best Practices

Develop

Overview

Spring Support Status

Pipeline Compilation

Overview

Generated Artifacts

Module Ownership

Build Integration

Verification and Troubleshooting

Configuration

Overview

Build-Time Settings

Runtime Settings

Await and Checkpoint

Transport and Platform

Providers and Plugins

All Settings

Application Configuration

Replay Viewer Parameters

Lambda-Focused Configuration

Pipeline Template DSL

@PipelineStep Annotation

Code a Step

Item Reject Sink

Operators

Operator Build Troubleshooting

Delegation and Extension

External Library Delegation

Use Existing Java Methods

Operator Service Contracts

Legacy Delegation Migration

Operator Delegation Reference

Operator Libraries

Client Steps

Orchestrator Runtime Extensions

Command Connectors

One-turn LLM Query

Reactive Services

REST Resources

Mappers and DTOs

Handling File Operations

Testing with Testcontainers

Modularity

Using Plugins

Writing a Plugin

TPFGo Example

Performance

Customization Points

Deploy

Overview

Runtime Layouts

Overview

Using Runtime Mapping

Maven Migration Playbook

POM vs Layout Matrix

CSV Payments Pipeline-Runtime

CSV Payments Monolith

Orchestrator Runtime

Overview

Queue-Async Runtime

Checkpoint Handoff

Command Steps

Await Runtime Setup

Function Platforms

AWS Lambda Platform

Azure Functions Platform

Google Cloud Run Functions Platform

Multi-Cloud Function Providers

Search Lambda Verification Lane

Search Azure Verification Lane

Azure Deployment Walkthrough

Azure Troubleshooting

Search Azure Reference

Dependency Management

Pipeline Parent POM Lifecycle

CSV Payments POM Lifecycle

Checkpoint Handoff

Concurrency and Backpressure Sizing

Operate

Overview

Await Boundaries

Circuit Protection

Error Handling & DLQ

In-flight Probe

AWS Lambda SnapStart

Operators

Runtime Operations

Operator Playbook

Operator Troubleshooting

Observability

Overview

Metrics

Tracing

Replay & Live Topology

Replay Viewer

Logging

Health Checks

Alerting

Scalability

Best Practices

NewRelic OTel

Using Quarkus LGTM

Security Notes

Best Practices Index

Evolve

Overview

Architecture

Queue-Async Immutable Boundaries

Architecture Reference

I/O Shell Absorption

Operators

Overview

Architecture

Invocation Internals

Runtime Mapping

Overview

Schema

Cheat Sheet

Build Topologies

Annotation Processing

Synthetics

Implementation Plan

TDD Plan

Validation & Migration Examples

TPFGo

Overview

Design Spectrum

DDD Alignment

Observer and Tap Contract

Roadmap

Roadmap Archive

Durable Coordinator

Overview

Coordinator And Worker Topology

Worker Protocols

Step-Aware Invocation Runtime

Bundle Contract

Pipeline Contract And Release Model

Runtime Boundaries And Performance

All-Serverless Coordinator

Local APIs

Self-Hosted Deployment

Self-Hosted HA Roadmap

Self-Hosted Milestone

Brokered Boundaries

Overview

Boundary Taxonomy

Dispatch Substrates

Envelope And Data Policy

Adoption And Slices

Framework Portability Assessment

Guide Overview

Full Assessment Snapshot

Coupling Inventory

Quarkus Coupling

Vert.x Coupling

Runtime Split

Reactive Portability

Persistence Portability

Annotation Removal

Code Generation Portability

Maven And Scaffolding

Roadmap And Guardrails

Annotation Processor Guide

Overview

Phases and Flow

Models and Bindings

Generation and Rendering

Current Architecture

Annotation Processor Architecture (Compat)

Compiler Pipeline Architecture

Runtime Core Decoupling

I/O Shell Absorption

Data Types

Canonical Domain Readiness

Typed Union Output Contracts

Plugins Architecture

Reference Implementation

Reference Implementation Archive

Template Generator

Release And Publishing

Overview

Framework Release Process

Docs Snapshot Process

Publishing Reference

CI Guidelines

Testing Guidelines

Gotchas & Pitfalls

Proto Descriptor Integration

Protobuf-over-HTTP Dispatch Design

Aspects

Aspect Semantics

Aspect Ordering

Aspect Warnings

Await Unit Runtime

Model

Immutable Boundaries

Sequences

Patterns

Limitations And Debt

Additional Resources

Versions

On this page

Operate

Observe, troubleshoot, and recover running TPF applications.

Edit this page

Pager

Previous pageConcurrency and Backpressure Sizing

Next pageAwait Boundaries

Operate ​

Operate