EventHubDataComparer Class

Definition

Namespace:

Orleans.ServiceBus.Providers

Assembly:

Orleans.Streaming.EventHubs.dll

Package:

Microsoft.Orleans.OrleansServiceBus v2.4.5

Default eventhub data comparer. Implements comparisions against CachedEventHubMessage

public class EventHubDataComparer : Orleans.Providers.Streams.Common.ICacheDataComparer<Orleans.ServiceBus.Providers.CachedEventHubMessage>

type EventHubDataComparer = class
    interface ICacheDataComparer<CachedEventHubMessage>

Public Class EventHubDataComparer
Implements ICacheDataComparer(Of CachedEventHubMessage)

Inheritance

Object

EventHubDataComparer

Implements

ICacheDataComparer<CachedEventHubMessage>

Constructors

EventHubDataComparer()

Fields

Instance

Singleton instance, since type is stateless using this will reduce allocations.

Methods

Compare(CachedEventHubMessage, StreamSequenceToken)	Compare a cached message with a sequence token to determine if it message is before or after the token
Equals(CachedEventHubMessage, IStreamIdentity)	Checks to see if the cached message is part of the provided stream

Extension Methods

Compare<TCachedMessage>(ICacheDataComparer<TCachedMessage>, StreamSequenceToken, TCachedMessage)	Compare a cached message with a sequence token to determine if it message is before or after the token
Equals<TCachedMessage>(ICacheDataComparer<TCachedMessage>, IStreamIdentity, TCachedMessage)	Checks to see if the cached message is part of the provided stream