EventHubDataComparer Class

Reference

Definition

Namespace:: Orleans.ServiceBus.Providers

Assembly:: OrleansServiceBus.dll

Assembly:: Orleans.Streaming.EventHubs.dll

Package:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Package:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

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

Applies to

Share via