Namespace DotCompute.Core.Messaging
Classes
- CorrelationManager
Manages correlation between request and response messages.
- DeadLetterQueue
Thread-safe implementation of the dead letter queue.
- DeadLetterQueueFactory
Factory for creating dead letter queues.
- MessageAggregatorFactory
Factory for creating message aggregators.
- MessageAggregator<TResponse, TResult>
Aggregates responses from multiple requests into a single result.
- MessageBatcher
Batches multiple messages together for efficient transmission.
- MessageQueueBridge<T>
Bridges host-side named message queues to GPU-resident Span buffers with bidirectional support.
- MessageQueueFactory
Factory for creating message queue instances based on configuration options.
- MessageQueueRegistry
Centralized registry for managing named message queues across all backends. Provides thread-safe registration, discovery, and lifecycle management.
- MessageQueue<T>
Lock-free concurrent message queue using a ring buffer for high-performance message passing.
- MessageTtlExtensions
Extension methods for message TTL and dead letter operations.
- MessageTtlManager
Manages message TTL enforcement and expiration handling.
- P2PConnectionInfo
P2P connection information between two devices.
- P2PMessageQueueFactory
Factory for creating P2P message queues between GPU devices.
- P2PMessageQueue<T>
High-performance P2P message queue for multi-GPU communication.
- P2PTopologyResult
Result of P2P topology initialization.
- PinnedStagingBuffer
Lock-free pinned memory buffer for staging messages before GPU transfer.
- PriorityMessageQueue<T>
Priority-based message queue using a binary heap for message ordering by priority.
- QueueMetadata
Metadata about a registered message queue.
Enums
- BridgeDirection
Specifies the direction of message flow in a MessageQueueBridge<T>.