EventHubQueueCache Clase

Definición

Espacio de nombres:

Orleans.Streaming.EventHubs

Ensamblado:

Orleans.Streaming.EventHubs.dll

Paquete:

Microsoft.Orleans.Streaming.EventHubs v8.1.0

Caché de colas de EventHub

public class EventHubQueueCache : IDisposable, Orleans.Streaming.EventHubs.IEventHubQueueCache, Orleans.Streams.IQueueFlowController

type EventHubQueueCache = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public Class EventHubQueueCache
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

Herencia

Object

EventHubQueueCache

Implementaciones

IEventHubQueueCache IQueueFlowController IDisposable

Constructores

EventHubQueueCache(String, Int32, IObjectPool<FixedSizeBuffer>, IEventHubDataAdapter, IEvictionStrategy, IStreamQueueCheckpointer<String>, ILogger, ICacheMonitor, Nullable<TimeSpan>, Nullable<TimeSpan>)

Caché de colas de EventHub.

Campos

cache

Implementación de caché de mensajes subyacente protegida con fines de prueba

Propiedades

Partition

Caché de colas de EventHub

Métodos

Add(List<EventData>, DateTime)	Agregue una lista de EventHub EventData a la memoria caché.
AddCachePressureMonitor(ICachePressureMonitor)	Adición del monitor de presión de caché al algoritmo de presión inversa de la memoria caché
Dispose()	Realiza tareas definidas por la aplicación asociadas a la liberación o al restablecimiento de recursos no administrados.
GetCursor(StreamId, StreamSequenceToken)	Obtenga un cursor en la memoria caché para leer eventos de una secuencia.
GetMaxAddCount()	Límite del número máximo de elementos que se pueden agregar
SignalPurge()	Enviar señal de purga a la memoria caché, la caché realizará una purga basada en el tiempo en sus mensajes almacenados en caché.
TryGetNextMessage(Object, IBatchContainer)	Intente obtener el siguiente mensaje en la memoria caché del cursor proporcionado.