Module fetch 

Fetch reads assigned Iceberg update tasks and keeps a resumable cursor per task. Tasks are read in state-table order, so the tasks of one route are applied in dispatch order.

Structs

FetchContext 🔒

Inputs that stay fixed for the lifetime of a Fetch executor.

IcebergUpdateFetchExecutor

Enums

FetchResult 🔒

Functions

fetch_work 🔒

Reads a nonempty batch of tasks in order, then reports BatchFinished.

pending_tasks 🔒

Type Aliases

FetchStream 🔒