EventDataGeneratorAdapterFactory Class

Reference

Definition

Namespace:: Orleans.ServiceBus.Providers.Testing

Assembly:: Orleans.Streaming.EventHubs.dll

Package:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Package:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Source:: EventDataGeneratorAdapterFactory.cs

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

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.

public class EventDataGeneratorAdapterFactory : Orleans.ServiceBus.Providers.EventHubAdapterFactory, Orleans.Providers.IControllable

type EventDataGeneratorAdapterFactory = class
    inherit EventHubAdapterFactory
    interface IControllable

Public Class EventDataGeneratorAdapterFactory
Inherits EventHubAdapterFactory
Implements IControllable

Inheritance: Object

EventHubAdapterFactory
EventDataGeneratorAdapterFactory

Implements: IControllable

Constructors

EventDataGeneratorAdapterFactory(String, EventDataGeneratorStreamOptions, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IEventHubDataAdapter, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)
EventDataGeneratorAdapterFactory(String, EventDataGeneratorStreamOptions, EventHubOptions, EventHubReceiverOptions, EventHubStreamCachePressureOptions, StreamCacheEvictionOptions, StreamStatisticOptions, IServiceProvider, SerializationManager, ITelemetryProducer, ILoggerFactory)

Fields

adapterSettings	Stream provider settings (Inherited from EventHubAdapterFactory)
checkpointerSettings	Checkpointer settings (Inherited from EventHubAdapterFactory)
dataAdapter	Data adapter (Inherited from EventHubAdapterFactory)
EventHubReceiverFactory	Factory to create a IEventHubReceiver (Inherited from EventHubAdapterFactory)
hubSettings	Event Hub settings (Inherited from EventHubAdapterFactory)
logger	Orleans logging (Inherited from EventHubAdapterFactory)
providerConfig	Provider configuration (Inherited from EventHubAdapterFactory)
serviceProvider	Framework service provider (Inherited from EventHubAdapterFactory)

Properties

CacheFactory	Creates a message cache for an eventhub partition. (Inherited from EventHubAdapterFactory)
CheckpointerFactory	Creates a parition checkpointer. (Inherited from EventHubAdapterFactory)
Direction	Direction of this queue adapter: Read, Write or ReadWrite. (Inherited from EventHubAdapterFactory)
IsRewindable	Determines whether this is a rewindable stream adapter - supports subscribing from previous point in time. (Inherited from EventHubAdapterFactory)
Name	Name of the adapter. Primarily for logging purposes (Inherited from EventHubAdapterFactory)
QueueMapperFactory	Create a queue mapper to map EventHub partitions to queues (Inherited from EventHubAdapterFactory)
ReceiverMonitorFactory	Create a receiver monitor to report performance metrics. Factory funciton should return an IEventHubReceiverMonitor. (Inherited from EventHubAdapterFactory)
SerializationManager	Gets the serialization manager. (Inherited from EventHubAdapterFactory)
StreamFailureHandlerFactory	Creates a failure handler for a partition. (Inherited from EventHubAdapterFactory)

Methods

Create(IServiceProvider, String)
CreateAdapter()	Create queue adapter. (Inherited from EventHubAdapterFactory)
CreateCacheFactory(EventHubStreamCachePressureOptions)	Create a IEventHubQueueCacheFactory. It will create a EventHubQueueCacheFactory by default. User can override this function to return their own implementation of IEventHubQueueCacheFactory, and other customization of IEventHubQueueCacheFactory if they may. (Inherited from EventHubAdapterFactory)
CreateCacheFactory(EventHubStreamProviderSettings)	Create a IEventHubQueueCacheFactory. It will create a EventHubQueueCacheFactory by default. User can override this function to return their own implementation of IEventHubQueueCacheFactory, and other customization of IEventHubQueueCacheFactory if they may. (Inherited from EventHubAdapterFactory)
CreateQueueCache(QueueId)	Create a cache for a given queue id (Inherited from EventHubAdapterFactory)
CreateReceiver(QueueId)	Creates a quere receiver for the specificed queueId (Inherited from EventHubAdapterFactory)
ExecuteCommand(Int32, Object)	Execute Command
GenerateEventHubPartitions(Int32)
GetDeliveryFailureHandler(QueueId)	Aquire delivery failure handler for a queue (Inherited from EventHubAdapterFactory)
GetPartitionIdsAsync()	Generate mocked eventhub partition Ids from EventHubGeneratorStreamProviderSettings
GetQueueAdapterCache()	Create queue message cache adapter (Inherited from EventHubAdapterFactory)
GetStreamQueueMapper()	Create queue mapper (Inherited from EventHubAdapterFactory)
Init()
Init(IProviderConfiguration, String, Logger, IServiceProvider)	Factory initialization. Provider config must contain the event hub settings type or the settings themselves. EventHubSettingsType is recommended for consumers that do not want to include secure information in the cluster configuration. (Inherited from EventHubAdapterFactory)
InitEventHubClient()	System.Object.InitEventHubClient
QueueMessageBatchAsync<T>(Guid, String, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>)	Writes a set of events to the queue as a single batch associated with the provided streamId. (Inherited from EventHubAdapterFactory)

Extension Methods

QueueMessageAsync<T>(IQueueAdapter, Guid, String, T, StreamSequenceToken, Dictionary<String,Object>)

Writes a set of events to the queue as a single batch associated with the provided streamId.

Applies to

Share via