GeneratorPooledCache.GetCacheCursor Method

Definition

Overloads

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.

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.

public Orleans.Streams.IQueueCacheCursor GetCacheCursor (Orleans.Runtime.StreamId streamId, Orleans.Streams.StreamSequenceToken token);
abstract member GetCacheCursor : Orleans.Runtime.StreamId * Orleans.Streams.StreamSequenceToken -> Orleans.Streams.IQueueCacheCursor
override this.GetCacheCursor : Orleans.Runtime.StreamId * Orleans.Streams.StreamSequenceToken -> Orleans.Streams.IQueueCacheCursor
Public Function GetCacheCursor (streamId As StreamId, token As StreamSequenceToken) As IQueueCacheCursor

Parameters

streamId
StreamId

The stream identifier.

token
StreamSequenceToken

The token.

Returns

The queue cache cursor.

Implements

Applies to

GetCacheCursor(IStreamIdentity, StreamSequenceToken)

Source:
GeneratorPooledCache.cs

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

public Orleans.Streams.IQueueCacheCursor GetCacheCursor (Orleans.Streams.IStreamIdentity streamIdentity, Orleans.Streams.StreamSequenceToken token);
abstract member GetCacheCursor : Orleans.Streams.IStreamIdentity * Orleans.Streams.StreamSequenceToken -> Orleans.Streams.IQueueCacheCursor
override this.GetCacheCursor : Orleans.Streams.IStreamIdentity * Orleans.Streams.StreamSequenceToken -> Orleans.Streams.IQueueCacheCursor
Public Function GetCacheCursor (streamIdentity As IStreamIdentity, token As StreamSequenceToken) As IQueueCacheCursor

Parameters

streamIdentity
IStreamIdentity

Returns

Implements

Applies to