Module ring_messages

Module ring_messages 

Source
Expand description

Ring message types for Statistical ML kernels.

This module defines zero-copy Ring messages for GPU-native persistent actors. Type IDs 700-799 are reserved for Statistical ML domain.

§Type ID Allocation

  • 700-719: KMeans messages
  • 720-739: DBSCAN messages
  • 740-759: Anomaly detection messages
  • 760-779: K2K parallel coordination messages

Structs§

ArchivedK2KCentroidAggregation
An archived K2KCentroidAggregation
ArchivedK2KCentroidBroadcast
An archived K2KCentroidBroadcast
ArchivedK2KCentroidBroadcastAck
An archived K2KCentroidBroadcastAck
ArchivedK2KKMeansSync
An archived K2KKMeansSync
ArchivedK2KKMeansSyncResponse
An archived K2KKMeansSyncResponse
ArchivedK2KPartialCentroid
An archived K2KPartialCentroid
ArchivedKMeansAssignResponse
An archived KMeansAssignResponse
ArchivedKMeansAssignRing
An archived KMeansAssignRing
ArchivedKMeansInitResponse
An archived KMeansInitResponse
ArchivedKMeansInitRing
An archived KMeansInitRing
ArchivedKMeansQueryResponse
An archived KMeansQueryResponse
ArchivedKMeansQueryRing
An archived KMeansQueryRing
ArchivedKMeansUpdateResponse
An archived KMeansUpdateResponse
ArchivedKMeansUpdateRing
An archived KMeansUpdateRing
K2KCentroidAggregation
K2K centroid aggregation response.
K2KCentroidAggregationResolver
The resolver for an archived K2KCentroidAggregation
K2KCentroidBroadcast
K2K broadcast new centroids to workers.
K2KCentroidBroadcastAck
K2K broadcast acknowledgment.
K2KCentroidBroadcastAckResolver
The resolver for an archived K2KCentroidBroadcastAck
K2KCentroidBroadcastResolver
The resolver for an archived K2KCentroidBroadcast
K2KKMeansSync
K2K iteration sync for distributed KMeans.
K2KKMeansSyncResolver
The resolver for an archived K2KKMeansSync
K2KKMeansSyncResponse
K2K sync response.
K2KKMeansSyncResponseResolver
The resolver for an archived K2KKMeansSyncResponse
K2KPartialCentroid
K2K partial centroid update from a worker.
K2KPartialCentroidResolver
The resolver for an archived K2KPartialCentroid
KMeansAssignResponse
Assignment response.
KMeansAssignResponseResolver
The resolver for an archived KMeansAssignResponse
KMeansAssignRing
Assign points to clusters (E-step).
KMeansAssignRingResolver
The resolver for an archived KMeansAssignRing
KMeansInitResponse
KMeans initialization response.
KMeansInitResponseResolver
The resolver for an archived KMeansInitResponse
KMeansInitRing
Initialize KMeans with centroids.
KMeansInitRingResolver
The resolver for an archived KMeansInitRing
KMeansQueryResponse
Query response.
KMeansQueryResponseResolver
The resolver for an archived KMeansQueryResponse
KMeansQueryRing
Query cluster assignment for a point.
KMeansQueryRingResolver
The resolver for an archived KMeansQueryRing
KMeansUpdateResponse
Update response with new centroids.
KMeansUpdateResponseResolver
The resolver for an archived KMeansUpdateResponse
KMeansUpdateRing
Update centroids (M-step).
KMeansUpdateRingResolver
The resolver for an archived KMeansUpdateRing

Functions§

from_fixed_point
Convert fixed-point i64 to f64.
pack_coordinates
Pack coordinates into fixed-point array.
to_fixed_point
Convert f64 to fixed-point i64 (8 decimal places).
unpack_coordinates
Unpack coordinates from fixed-point array.