Module k2k 

K2K (Kernel-to-Kernel) coordination utilities.

This module provides higher-level abstractions for K2K communication patterns commonly used in financial analytics pipelines.

Coordination Patterns

• Fan-out: One kernel broadcasting to multiple downstream kernels
• Fan-in: Multiple kernels sending to one aggregator kernel
• Pipeline: Sequential multi-stage processing
• Scatter-Gather: Parallel processing with result aggregation
• Iterative: Convergence-based algorithms (PageRank, K-Means)

Structs

FanOutTracker

Tracks fan-out broadcast destinations and delivery status.

IterativeConvergenceSummary

Summary of iterative algorithm convergence.

IterativeState

State for tracking iterative algorithm convergence.

K2KWorkerResult

Result from a worker in a scatter-gather operation.

PipelineTracker

Tracks progress through a multi-stage pipeline.

ScatterGatherState

Tracks scatter-gather operation state.

Enums

K2KControlMessage

Control messages for K2K coordination between kernels.

K2KPriority

Priority levels for K2K messages.

Functions

kernel_id_to_u64

Convert a KernelId to a u64 hash for message envelope addressing.