PullingAgentStreamRegistered

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

class

Namespace: Orleans.Streaming.Diagnostics

NuGetSourceMarkdown

Event payload for when a persistent stream pulling agent registers a local stream entry.

public sealed class PullingAgentStreamRegistered : StreamingEvent

Constructors

• PullingAgentStreamRegistered(string, SiloAddress?, QueueId, StreamId, GrainId, int) Event payload for when a persistent stream pulling agent registers a local stream entry.

Fields

• ProducerGrainId The pulling agent grain ID registered as producer in pubsub.
• QueueId The queue handled by the pulling agent.
• StreamId The stream ID.
• SubscriberCount The number of non-faulted subscribers returned by pubsub.