MemoryAdapterFactory<TSerializer>

class

Namespace: Orleans.Providers

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> : IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory
    where TSerializer : class, Orleans.Providers.IMemoryMessageBodySerializer

Constructors

MemoryAdapterFactory<TSerializer>(string, StreamCacheEvictionOptions, StreamStatisticOptions, HashRingStreamQueueMapperOptions, IServiceProvider, IGrainFactory, ILoggerFactory)

Properties

Direction Gets the direction of this queue adapter: StreamProviderDirection, StreamProviderDirection, or StreamProviderDirection.
IsRewindable Gets a value indicating whether this is a rewindable stream adapter - supports subscribing from previous point in time.
Name Gets the name of the adapter. Primarily for logging purposes
StreamFailureHandlerFactory Creates a failure handler for a partition.

Methods

Create(IServiceProvider, string) Creates a new Orleans.Providers.MemoryAdapterFactory instance.
CreateAdapter Creates a 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 Creates queue message cache adapter.
GetStreamQueueMapper Creates a queue mapper.
Init Initializes this instance.
QueueMessageBatchAsync(StreamId, IEnumerable<T>, StreamSequenceToken?, Dictionary<string, object>) Writes a set of events to the queue as a single batch associated with the provided streamId.

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