MemoryAdapterFactory<TSerializer> 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.
Adapter factory for in memory stream provider. This factory acts as the adapter and the adapter factory. The events are stored in an in-memory grain that behaves as an event queue, this provider adapter is primarily used for testing
public class MemoryAdapterFactory<TSerializer> : Orleans.Streams.IQueueAdapter, Orleans.Streams.IQueueAdapterCache, Orleans.Streams.IQueueAdapterFactory where TSerializer : class, IMemoryMessageBodySerializertype MemoryAdapterFactory<'Serializer (requires 'Serializer : null and 'Serializer :> IMemoryMessageBodySerializer)> = class
interface IQueueAdapterFactory
interface IQueueAdapter
interface IQueueAdapterCachePublic Class MemoryAdapterFactory(Of TSerializer)
Implements IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactoryType Parameters
- TSerializer
- Inheritance
-
MemoryAdapterFactory<TSerializer>
- Implements
Constructors
Fields
| BlockPoolMonitorFactory |
Create a block pool monitor to monitor block pool related metrics Return a IBlockPoolMonitor |
| CacheMonitorFactory |
Create a cache monitor to report cache related metrics Return a ICacheMonitor |
| ReceiverMonitorFactory |
Create a monitor to monitor QueueAdapterReceiver related metrics Return a IQueueAdapterReceiverMonitor |
Properties
| Direction |
Direction of this queue adapter: Read, Write or ReadWrite. |
| IsRewindable |
Determines whether this is a rewindable stream adapter - supports subscribing from previous point in time. |
| Name |
Name of the adapter. Primarily for logging purposes |
| StreamFailureHandlerFactory |
Creates a failure handler for a partition. |
Methods
| Create(IServiceProvider, String) |
Creates a new MemoryAdapterFactory<TSerializer> instance. |
| CreateAdapter() |
Create queue adapter. |
| CreateQueueCache(QueueId) |
Create a cache for a given queue id |
| CreateReceiver(QueueId) |
Creates a queue receiver for the specified queueId |
| GetDeliveryFailureHandler(QueueId) |
Acquire delivery failure handler for a queue |
| GetQueueAdapterCache() |
Create queue message cache adapter |
| GetStreamQueueMapper() |
Create queue mapper |
| Init() |
Initializes this instance. |
| Init(IProviderConfiguration, String, Logger, IServiceProvider) |
Factory initialization. |
| 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. |
| QueueMessageBatchAsync<T>(StreamId, IEnumerable<T>, StreamSequenceToken, Dictionary<String,Object>) |
Writes a set of events to the queue as a single batch associated with the provided streamId. |
Extension Methods
| QueueMessageAsync<T>(IQueueAdapter, StreamId, T, StreamSequenceToken, Dictionary<String,Object>) |
Writes a set of events to the queue as a single batch associated with the provided |
| 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. |