MemoryAdapterFactory<TSerializer> Class

Definition

Namespace:

Orleans.Providers

Assembly:

Orleans.Streaming.dll

Package:

Microsoft.Orleans.Streaming v8.2.0

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, IMemoryMessageBodySerializer

type MemoryAdapterFactory<'Serializer (requires 'Serializer : null and 'Serializer :> IMemoryMessageBodySerializer)> = class
    interface IQueueAdapterFactory
    interface IQueueAdapter
    interface IQueueAdapterCache

Public Class MemoryAdapterFactory(Of TSerializer)
Implements IQueueAdapter, IQueueAdapterCache, IQueueAdapterFactory

Type Parameters

TSerializer

Inheritance

Object

MemoryAdapterFactory<TSerializer>

Implements

IQueueAdapter IQueueAdapterCache IQueueAdapterFactory

Constructors

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

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.
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 streamId.