Düzenle

Aracılığıyla paylaş

EventHubPartitionDataGenerator Class

  • Reference

Definition

Namespace:
Orleans.ServiceBus.Providers.Testing
Assembly:
OrleansServiceBus.dll
Assembly:
Orleans.Streaming.EventHubs.dll
Package:
Microsoft.Orleans.OrleansServiceBus v1.5.10
Package:
Microsoft.Orleans.OrleansServiceBus v2.4.5
Package:
Microsoft.Orleans.OrleansServiceBus v3.6.5
Source:
EventHubPartitionDataGenerator.cs

EHPartitionDataGenerator generate data for a EH partition, which can include data from different streams

public class EventHubPartitionDataGenerator : Orleans.ServiceBus.Providers.Testing.IDataGenerator<Microsoft.ServiceBus.Messaging.EventData>, Orleans.ServiceBus.Providers.Testing.IStreamDataGeneratingController
public class EventHubPartitionDataGenerator : Orleans.ServiceBus.Providers.Testing.IDataGenerator<Microsoft.Azure.EventHubs.EventData>, Orleans.ServiceBus.Providers.Testing.IStreamDataGeneratingController
public class EventHubPartitionDataGenerator : Orleans.ServiceBus.Providers.Testing.IDataGenerator<Azure.Messaging.EventHubs.EventData>, Orleans.ServiceBus.Providers.Testing.IStreamDataGeneratingController
type EventHubPartitionDataGenerator = class
    interface IDataGenerator<EventData>
    interface IStreamDataGeneratingController
Public Class EventHubPartitionDataGenerator
Implements IDataGenerator(Of EventData), IStreamDataGeneratingController
Inheritance
Object
EventHubPartitionDataGenerator
Implements
IDataGenerator<EventData> IStreamDataGeneratingController IDataGenerator<EventData> IDataGenerator<EventData>

Constructors

EventHubPartitionDataGenerator(EventDataGeneratorStreamOptions, Func<IStreamIdentity,IStreamDataGenerator<EventData>>, ILogger)

Constructor
EventHubPartitionDataGenerator(EventDataGeneratorStreamOptions, Func<IStreamIdentity,IStreamDataGenerator<EventData>>, ILogger)

Constructor
EventHubPartitionDataGenerator(Logger, SerializationManager, EventHubGeneratorStreamProviderSettings)

Constructor

Methods

AddDataGeneratorForStream(IStreamIdentity)

StreamDataGeneratingController control stream data generating start and stop
StopProducingOnStream(IStreamIdentity)

StreamDataGeneratingController control stream data generating start and stop
TryReadEvents(Int32, IEnumerable<EventData>) System.Object.TryReadEvents(System.Int32,System.Collections.Generic.IEnumerable{Azure.Messaging.EventHubs.EventData}@)
TryReadEvents(Int32, IEnumerable<EventData>) System.Object.TryReadEvents(System.Int32,System.Collections.Generic.IEnumerable{Microsoft.Azure.EventHubs.EventData}@)
TryReadEvents(Int32, IEnumerable<EventData>)

Data generator for test purpose

Applies to