Skip to content

PullingAgentStreamRegistered Constructors

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

PullingAgentStreamRegistered(string, SiloAddress?, QueueId, StreamId, GrainId, int)

View source
public PullingAgentStreamRegistered(string streamProvider, SiloAddress? siloAddress, QueueId queueId, StreamId streamId, GrainId producerGrainId, int subscriberCount)
Event payload for when a persistent stream pulling agent registers a local stream entry.

Parameters

streamProviderstring
The name of the stream provider.
siloAddressSiloAddress?
The address of the silo.
queueIdQueueId
The queue handled by the pulling agent.
streamIdStreamId
The stream ID.
producerGrainIdGrainId
The pulling agent grain ID registered as producer in pubsub.
subscriberCountint
The number of non-faulted subscribers returned by pubsub.