Edit

Share via

SimpleQueueCacheCursor Class

  • Reference

Definition

Namespace:
Orleans.Providers.Streams.Common
Assembly:
OrleansProviders.dll
Assembly:
Orleans.Streaming.dll
Package:
Microsoft.Orleans.OrleansProviders v1.5.10
Package:
Microsoft.Orleans.OrleansProviders v2.4.5
Package:
Microsoft.Orleans.OrleansProviders v3.6.5
Package:
Microsoft.Orleans.Streaming v7.2.5
Package:
Microsoft.Orleans.Streaming v8.0.0
Package:
Microsoft.Orleans.Streaming v8.1.0
Source:
SimpleQueueCacheCursor.cs

Cursor into a simple queue cache.

public class SimpleQueueCacheCursor : IDisposable, Orleans.Streams.IQueueCacheCursor
type SimpleQueueCacheCursor = class
    interface IQueueCacheCursor
    interface IDisposable
Public Class SimpleQueueCacheCursor
Implements IDisposable, IQueueCacheCursor
Inheritance
Object
SimpleQueueCacheCursor
Implements
IQueueCacheCursor IDisposable

Constructors

SimpleQueueCacheCursor(SimpleQueueCache, IStreamIdentity, ILogger)

Cursor into a simple queue cache
SimpleQueueCacheCursor(SimpleQueueCache, IStreamIdentity, Logger)

Cursor into a simple queue cache
SimpleQueueCacheCursor(SimpleQueueCache, StreamId, ILogger)

Cursor into a simple queue cache

Methods

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.
Dispose(Boolean)

Clean up cache data when done
GetCurrent(Exception)

Get the current value.
MoveNext()

Move to next message in the stream. If it returns false, there are no more messages. The enumerator is still valid however and can be called again when more data has come in on this stream.
RecordDeliveryFailure()

Record that delivery of the current event has failed
Refresh(StreamSequenceToken)

Refresh that cache cursor. Called when new data is added into a cache.
ToString()

Convert object to string

Applies to