Module ring_messages

Module ring_messages 

Source
Expand description

Ring message types for Graph Analytics kernels.

This module defines zero-copy Ring messages for GPU-native persistent actors. Type IDs 200-299 are reserved for Graph Analytics domain.

§Type ID Allocation

  • 200-209: PageRank messages
  • 210-219: Community detection messages
  • 220-229: Centrality messages
  • 230-239: K2K coordination messages

Structs§

ArchivedComputeModularityRing
An archived ComputeModularityRing
ArchivedK2KBarrier
An archived K2KBarrier
ArchivedK2KBarrierRelease
An archived K2KBarrierRelease
ArchivedK2KBoundaryUpdate
An archived K2KBoundaryUpdate
ArchivedK2KBoundaryUpdateAck
An archived K2KBoundaryUpdateAck
ArchivedK2KCommunityMerge
An archived K2KCommunityMerge
ArchivedK2KHeartbeat
An archived K2KHeartbeat
ArchivedK2KIterationSync
An archived K2KIterationSync
ArchivedK2KIterationSyncResponse
An archived K2KIterationSyncResponse
ArchivedModularityResponse
An archived ModularityResponse
ArchivedPageRankConvergeResponse
An archived PageRankConvergeResponse
ArchivedPageRankConvergeRing
An archived PageRankConvergeRing
ArchivedPageRankIterateResponse
An archived PageRankIterateResponse
ArchivedPageRankIterateRing
An archived PageRankIterateRing
ArchivedPageRankQueryResponse
An archived PageRankQueryResponse
ArchivedPageRankQueryRing
An archived PageRankQueryRing
ComputeModularityRing
Request to compute modularity for current community assignment.
ComputeModularityRingResolver
The resolver for an archived ComputeModularityRing
K2KBarrier
K2K barrier synchronization.
K2KBarrierRelease
K2K barrier release.
K2KBarrierReleaseResolver
The resolver for an archived K2KBarrierRelease
K2KBarrierResolver
The resolver for an archived K2KBarrier
K2KBoundaryUpdate
K2K boundary node update.
K2KBoundaryUpdateAck
K2K boundary update acknowledgment.
K2KBoundaryUpdateAckResolver
The resolver for an archived K2KBoundaryUpdateAck
K2KBoundaryUpdateResolver
The resolver for an archived K2KBoundaryUpdate
K2KCommunityMerge
K2K community merge proposal.
K2KCommunityMergeResolver
The resolver for an archived K2KCommunityMerge
K2KHeartbeat
K2K worker heartbeat.
K2KHeartbeatResolver
The resolver for an archived K2KHeartbeat
K2KIterationSync
K2K iteration synchronization request.
K2KIterationSyncResolver
The resolver for an archived K2KIterationSync
K2KIterationSyncResponse
K2K iteration sync response.
K2KIterationSyncResponseResolver
The resolver for an archived K2KIterationSyncResponse
ModularityResponse
Modularity computation response.
ModularityResponseResolver
The resolver for an archived ModularityResponse
PageRankConvergeResponse
PageRank convergence response.
PageRankConvergeResponseResolver
The resolver for an archived PageRankConvergeResponse
PageRankConvergeRing
PageRank converge request - iterate until threshold or max iterations.
PageRankConvergeRingResolver
The resolver for an archived PageRankConvergeRing
PageRankIterateResponse
PageRank iterate response.
PageRankIterateResponseResolver
The resolver for an archived PageRankIterateResponse
PageRankIterateRing
PageRank iterate request - perform one power iteration step.
PageRankIterateRingResolver
The resolver for an archived PageRankIterateRing
PageRankQueryResponse
PageRank query response.
PageRankQueryResponseResolver
The resolver for an archived PageRankQueryResponse
PageRankQueryRing
PageRank query request - get score for a specific node.
PageRankQueryRingResolver
The resolver for an archived PageRankQueryRing

Functions§

from_fixed_point
Convert fixed-point i64 to f64.
to_fixed_point
Convert f64 to fixed-point i64 (8 decimal places).