EventHubBatchContainer
class
Namespace: Orleans.Streaming.EventHubs
Batch container that is delivers payload and stream position information for a set of events in an EventHub EventData.
[Orleans.GenerateSerializer]public class EventHubBatchContainer : IBatchContainerConstructors
EventHubBatchContainer(EventHubMessage, Serializer)Batch container that delivers events from cached EventHub data associated with an orleans stream
Properties
SequenceTokenStream Sequence Token for the start of this batch.StreamIdStream identifier for the stream this batch is part of.
Methods
GetEventsGets events of a specific type from the batch.ImportRequestContextGives an opportunity to IBatchContainer to set any data in the RequestContext before this IBatchContainer is sent to consumers. It can be the data that was set at the time event was generated and enqueued into the persistent provider or any other data.ToEventData(Serializer, StreamId, IEnumerable<T>, Dictionary<string, object>)Put events list and its context into a EventData objectUpdateEventData(EventData, Serializer, StreamId, IEnumerable<T>, Dictionary<string, object>)Updates the event data with the events list and its context.
