Module report 

Structs

IcebergPlanCompletion 🔒

IcebergTaskTracker 🔒

PkIndexCompactionResult 🔒

Per-plan result of a pk-index coordinated compaction run (rewrite without commit).

Enums

ReportSendResult 🔒

Functions

build_iceberg_task_report 🔒

build_pk_index_compaction_result 🔒

Builds the pk-index coordinated report payload from a no-commit rewrite.

fail_pk_index_report 🔒

Marks report as failed after a pk-index payload field failed validation or serialization, so meta retries the task instead of silently dropping the compaction output.

flush_pending_iceberg_task_reports 🔒

populate_pk_index_report_fields 🔒

Flattens the per-plan pk-index coordinated results into the ReportTask payload fields.

send_iceberg_task_report 🔒

send_or_buffer_iceberg_task_report 🔒

Type Aliases

IcebergTaskReport 🔒