Edit

Share via


MemoryAdapterFactory<TSerializer> Class

Definition

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
MemoryAdapterFactory<TSerializer>
Implements

Constructors

MemoryAdapterFactory<TSerializer>()
MemoryAdapterFactory<TSerializer>(String, StreamCacheEvictionOptions, StreamStatisticOptions, HashRingStreamQueueMapperOptions, IServiceProvider, IGrainFactory, ILoggerFactory)
MemoryAdapterFactory<TSerializer>(String, StreamCacheEvictionOptions, StreamStatisticOptions, HashRingStreamQueueMapperOptions, IServiceProvider, IGrainFactory, ITelemetryProducer, 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.

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

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