DefaultQueueAdapterReceiverMonitor

1. Documentation
2. API reference
3. Microsoft.Orleans.Streaming
4. DefaultQueueAdapterReceiverMonitor

class

Namespace: Orleans.Providers.Streams.Common

NuGetSourceMarkdown

Queue adapter receiver monitor used as a default option in GeneratorStreamprovider and MemoryStreamProvider

public class DefaultQueueAdapterReceiverMonitor : IQueueAdapterReceiverMonitor

Constructors

• DefaultQueueAdapterReceiverMonitor(ReceiverMonitorDimensions, OrleansInstruments)

Methods

• TrackInitialization(bool, TimeSpan, Exception) Track attempts to initialize the receiver.
• TrackMessagesReceived(long, DateTime?, DateTime?) Tracks messages read and time taken per successful read. Tracked per successful partition read operation.
• TrackRead(bool, TimeSpan, Exception) Track attempts to read from the partition. Tracked per partition read operation.
• TrackShutdown(bool, TimeSpan, Exception) Track attempts to shutdown the receiver.