EventHubQueueCache Classe

Definição

Namespace:

Orleans.Streaming.EventHubs

Assembly:

Orleans.Streaming.EventHubs.dll

Pacote:

Microsoft.Orleans.Streaming.EventHubs v8.2.0

Cache de fila do 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

Herança

Object

EventHubQueueCache

Implementações

IEventHubQueueCache IQueueFlowController IDisposable

Construtores

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

Cache de fila do EventHub.

Campos

cache

Implementação do cache de mensagens subjacente Protegido para fins de teste

Propriedades

Partition

Cache de fila do EventHub

Métodos

Add(List<EventData>, DateTime)	Adicione uma lista de EventData do EventHub ao cache.
AddCachePressureMonitor(ICachePressureMonitor)	Adicionar o monitor de pressão de cache ao algoritmo de pressão traseira do cache
Dispose()	Realiza tarefas definidas pelo aplicativo associadas à liberação ou à redefinição de recursos não gerenciados.
GetCursor(StreamId, StreamSequenceToken)	Obtenha um cursor no cache para ler eventos de um fluxo.
GetMaxAddCount()	O limite do número máximo de itens que podem ser adicionados
SignalPurge()	Enviar sinal de limpeza para o cache, o cache executará uma limpeza baseada em tempo em suas mensagens armazenadas em cache
TryGetNextMessage(Object, IBatchContainer)	Tente obter a próxima mensagem no cache para o cursor fornecido.