Module list 

List enumerates bounded pages of Iceberg update tasks and dispatches them to Fetch.

Structs

IcebergUpdateListExecutor

ListContext 🔒

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

ListResult 🔒

Enums

NextPoll 🔒

When List starts its next poll.

Functions

assignments_chunk 🔒

fetch_state_reader 🔒

Reads the task keys of the Fetch state table across all vnodes, so that completion observes the tasks of every Fetch actor.

list_work 🔒

Metadata I/O runs on the data arm so it cannot prevent List from forwarding barriers. idle_delay throttles only catalog polls; completion checks never wait for it.

write_list_state 🔒

Writes the single List state row, inserting it on the first write.

Type Aliases

ListStream 🔒