Microsoft.Orleans.Streaming.EventHubs

10.0.0 · net10.0

Orleans.Configuration

AzureTableStreamCheckpointerOptions

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

AzureTableStreamCheckpointerOptionsValidator

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

CreateConnectionDelegate

delegate

Creates an Azure Event Hub connection.

EventDataGeneratorStreamOptions

class

Setting class for EHGeneratorStreamProvider

EventHubOptions

class

EventHub settings for a specific hub

EventHubOptionsValidator

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

EventHubReceiverOptions

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

EventHubStreamCachePressureOptions

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

StreamCheckpointerConfigurationValidator

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

Orleans.Hosting

ClientBuilderExtensions

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

ClusterClientEventHubStreamConfigurator

class

Client-side configuration provider for persistent streams.

EventHubStreamConfiguratorExtensions

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

IClusterClientEventHubStreamConfigurator

interface

ISiloEventHubStreamConfigurator

interface

SiloBuilderExtensions

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

SiloEventHubStreamConfigurator

class

Configures reliable streams.

SiloEventHubStreamConfiguratorExtensions

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

Orleans.Hosting.Developer

EventDataGeneratorConfiguratorExtensions

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

EventDataGeneratorStreamConfigurator

class

Configures reliable streams.

IEventDataGeneratorStreamConfigurator

interface

SiloBuilderExtensions

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

Orleans.Streaming.EventHubs

AggregatedCachePressureMonitor

class

Aggregated cache pressure monitor

AveragingCachePressureMonitor

class

Cache pressure monitor whose back pressure algorithm is based on averaging pressure value over all pressure contribution

AzureStorageOperationOptions

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

AzureStorageOperationOptionsValidator<TOptions>

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

AzureStoragePolicyOptions

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

DefaultEventHubReceiverMonitor

class

Default EventHub receiver monitor that tracks metrics using loggers PKI support.

EventDataExtensions

class

Extends EventData to support streaming

EventHubAdapterFactory

class

Queue adapter factory which allows the PersistentStreamProvider to use EventHub as its backend persistent event queue.

EventHubBatchContainer

class

Batch container that is delivers payload and stream position information for a set of events in an EventHub EventData.

EventHubBlockPoolMonitorDimensions

class

Aggregation dimensions for block pool monitor used in Eventhub stream provider ecosystem

EventHubCacheMonitorDimensions

class

Aggregation dimensions for cache monitor used in Eventhub stream provider ecosystem

EventHubCheckpointer

class

This class stores EventHub partition checkpointer information (a partition offset) in azure table storage.

EventHubCheckpointerFactory

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

EventHubDataAdapter

class

Default event hub data adapter. Users may subclass to override event data to stream mapping.

EventHubMessage

class

Replication of EventHub EventData class, reconstructed from cached data CachedEventHubMessage

EventHubMonitorAggregationDimensions

class

Base class for monitor aggregation dimensions, which is an information bag for the monitoring target. Monitors can use this information bag to build its aggregation dimensions.

EventHubQueueCacheFactory

class

Factory class to configure and create IEventHubQueueCache

EventHubReceiverMonitorDimensions

class

Aggregation dimensions for EventHubReceiverMonitor

Event Hub messages consist of a batch of application layer events, so EventHub tokens contain three pieces of information. EventHubOffset - this is a unique value per partition that is used to start reading from this message in the partition. SequenceNumber - EventHub sequence numbers are unique ordered message IDs for messages within a partition. The SequenceNumber is required for uniqueness and ordering of EventHub messages within a partition. event Index - Since each EventHub message may contain more than one application layer event, this value indicates which application layer event this token is for, within an EventHub message. It is required for uniqueness and ordering of application layer events within an EventHub message.

EventHubSequenceTokenV2

class

ICachePressureMonitor

interface

Cache pressure monitor records pressure contribution to the cache, and determine if the cache is under pressure based on its back pressure algorithm

IEventHubDataAdapter

interface

IEventHubPartitionLocation

interface

Location of a message within an EventHub partition

IEventHubQueueCache

interface

Interface for a stream message cache that stores EventHub EventData

IEventHubQueueCacheFactory

interface

Factory responsible for creating a message cache for an EventHub partition.

IEventHubReceiver

interface

Abstraction on EventhubReceiver class, used to configure EventHubReceiver class in EventhubAdapterReceiver, also used to configure EHGeneratorReceiver in EventHubAdapterReceiver for testing purpose

SlowConsumingPressureMonitor

class

Pressure monitor which is in favor of the slow consumer in the cache

Orleans.Streaming.EventHubs.StatisticMonitors

DefaultEventHubBlockPoolMonitor

class

Default monitor for Object pool used by EventHubStreamProvider

DefaultEventHubCacheMonitor

class

Default cache monitor for eventhub streaming provider ecosystem

Orleans.Streaming.EventHubs.Testing

Commands

enum

Commands for IControllable

EventDataGeneratorAdapterFactory

class

This is a persistent stream provider adapter that generates it's own events rather than reading them from Eventhub. This is primarily for test purposes.

EventHubPartitionDataGenerator

class

EHPartitionDataGenerator generate data for a EH partition, which can include data from different streams

EventHubPartitionGeneratorReceiver

class

Eventhub receiver which configured with data generator

IDataGenerator<T>

interface

Data generator for test purpose

IIntCounter

interface

counter for integer

IStreamDataGeneratingController

interface

StreamDataGeneratingController control stream data generating start and stop

IStreamDataGenerator<T>

interface

data generator for a specific stream

NoOpCheckpointer

class

NoOpCheckpointer is used in EventDataGeneratorStreamProvider ecosystem to replace the default Checkpointer which requires a back end storage. In EventHubDataGeneratorStreamProvider, it is generating EventData on the fly when receiver pull messages from the queue, which means it doesn't support recoverable stream, hence check pointing won't bring much value there. So a checkpointer with no ops should be enough.

NoOpCheckpointerFactory

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

SimpleStreamEventDataGenerator

class

Generate data for one stream

StreamRandomPlacementArg

class

Args for RandomlyPlaceStreamToQueue method

OrleansCodeGen.Orleans.Streaming.EventHubs

Codec_EventHubBatchContainer

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

Codec_EventHubMessage

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

Codec_EventHubSequenceToken

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

Codec_EventHubSequenceTokenV2

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

Copier_EventHubBatchContainer

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

Copier_EventHubMessage

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

Copier_EventHubSequenceToken

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

Copier_EventHubSequenceTokenV2

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

OrleansCodeGen.Orleans.Streaming.EventHubs.Testing.EventDataGeneratorAdapterFactory

Codec_StreamRandomPlacementArg

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.

Copier_StreamRandomPlacementArg

class

Supports all classes in the .NET class hierarchy and provides low-level services to derived classes. This is the ultimate base class of all .NET classes; it is the root of the type hierarchy.