AddToCache(IList<IBatchContainer>)
virtual
public virtual void AddToCache(IList<IBatchContainer> msgs) Adds messages to the cache.
Parameters
msgsIList<IBatchContainer>- The message batches.
SimpleQueueCache Methods
A queue cache that keeps items in memory.
GetCacheCursor(StreamId, StreamSequenceToken?)
virtual
[System.Obsolete(Use IQueueCache.TryGetCacheCursor instead.)]public virtual IQueueCacheCursor GetCacheCursor(StreamId streamId, StreamSequenceToken? token) Acquire a stream message cursor. This can be used to retrieve messages from the cache starting at the location indicated by the provided token.
Parameters
streamIdStreamId- The stream identifier.
tokenStreamSequenceToken?- The token.
Returns
The queue cache cursor.
Exceptions
Orleans.Streams.QueueCacheMissException- The requested token is older than the messages retained by the cache.
GetMaxAddCount
public int GetMaxAddCount() Gets the maximum number of items that can be added.
Returns
The maximum number of items that can be added.
IsUnderPressure
virtual
public virtual bool IsUnderPressure() Returns
true if this cache is under pressure, false otherwise. Returns
true if this cache is under pressure; otherwise, false.TryPurgeFromCache(IList<IBatchContainer>)
virtual
public virtual bool TryPurgeFromCache(out IList<IBatchContainer> purgedItems) Requests that the cache purge any items that can be purged.
Parameters
purgedItemsIList<IBatchContainer>- The purged items.
Returns
true if items were successfully purged from the cache., false otherwise.