EventDataGeneratorStreamProvider.AdapterFactory Class
Definition
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.
EHGeneratorStreamProvider.AdpaterFactory
public class EventDataGeneratorStreamProvider.AdapterFactory : Orleans.ServiceBus.Providers.EventHubAdapterFactory, Orleans.Providers.IControllable
type EventDataGeneratorStreamProvider.AdapterFactory = class
inherit EventHubAdapterFactory
interface IControllable
Public Class EventDataGeneratorStreamProvider.AdapterFactory
Inherits EventHubAdapterFactory
Implements IControllable
- Inheritance
- Implements
Constructors
EventDataGeneratorStreamProvider.AdapterFactory() |
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
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 |
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() | (Inherited from EventHubAdapterFactory) |
Init(IProviderConfiguration, String, Logger, IServiceProvider) |
Init method |
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. |