Edit

Share via


SimpleQueueCache Class

Definition

A queue cache that keeps items in memory.

public class SimpleQueueCache : Orleans.Streams.IQueueCache
type SimpleQueueCache = class
    interface IQueueCache
    interface IQueueFlowController
Public Class SimpleQueueCache
Implements IQueueCache
Inheritance
SimpleQueueCache
Implements

Constructors

SimpleQueueCache(Int32, ILogger)

Initializes a new instance of the SimpleQueueCache class.

SimpleQueueCache(Int32, Logger)

SimpleQueueCache Constructor

Properties

Size

Gets the number of items in the cache.

Methods

AddToCache(IList<IBatchContainer>)

Add a list of message to the cache

GetCacheCursor(IStreamIdentity, StreamSequenceToken)

Acquire a stream message cursor. This can be used to retrieve messages from the cache starting at the ___location indicated by the provided token.

GetCacheCursor(StreamId, StreamSequenceToken)

Acquire a stream message cursor. This can be used to retrieve messages from the cache starting at the ___location indicated by the provided token.

GetMaxAddCount()

The limit of the maximum number of items that can be added

IsUnderPressure()

Returns true if this cache is under pressure.

TryPurgeFromCache(IList<IBatchContainer>)

Ask the cache if it has items that can be purged from the cache (so that they can be subsequently released them the underlying queue).

Applies to