Bewerken

Delen via


Orleans.ServiceBus.Providers.Testing Namespace

Classes

EventDataGeneratorAdapterFactory

This is a persistent stream provider adapter that generates it's own events rather than reading them from Eventhub. This is primarily for test purposes.

EventDataGeneratorAdapterFactory.StreamRandomPlacementArg

Args for RandomlyPlaceStreamToQueue method

EventDataGeneratorStreamProvider

This is a persistent stream provider that generates it's own events rather than reading them from Eventhub. This is primarily for test purposes.

EventDataGeneratorStreamProvider.AdapterFactory

EHGeneratorStreamProvider.AdpaterFactory

EventDataGeneratorStreamProvider.AdapterFactory.StreamRandomPlacementArg

Args for RandomlyPlaceStreamToQueue method

EventDataProxyMethods

Setter for EventData members

EventHubGeneratorStreamProviderSettings

Setting class for EHGeneratorStreamProvider

EventHubPartitionDataGenerator

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

EventHubPartitionGeneratorReceiver

Eventhub receiver which configured with data generator

MockEventHubSettings

MockEventHubSettings hard code EventHub related settings to avoid configuring those settings. It is used in EventDataGeneratorStreamProvider to mock its connection to EventHub

NoOpCheckpointer

NoOpCheckpointer is used in EventDataGeneratorStreamProvider eco system to replace the default Checkpointer which requires a back end storage. In EventHubDataGeneratorStreamProvider, it is generating EventData on the fly when receiver pull messages from the queue, which means it doesn't support recoverable stream, hence check pointing won't bring much value there. So a checkpointer with no ops should be enough.

NoOpCheckpointerFactory
SimpleStreamEventDataGenerator

Generate data for one stream

Interfaces

IDataGenerator<T>

Data generator for test purpose

IIntCounter

counter for integer

IStreamDataGeneratingController

StreamDataGeneratingController control stream data generating start and stop

IStreamDataGenerator<T>

data generator for a specific stream

Enums

EventDataGeneratorAdapterFactory.Commands

Commands for IControllable

EventDataGeneratorStreamProvider.AdapterFactory.Commands

Commands for IControllable