Compartilhar via


IEventHubQueueCache Interface

Definição

Interface para um cache de mensagens de fluxo que armazena EventHub EventData

public interface IEventHubQueueCache : IDisposable, Orleans.Streams.IQueueFlowController
type IEventHubQueueCache = interface
    interface IQueueFlowController
    interface IDisposable
Public Interface IEventHubQueueCache
Implements IDisposable, IQueueFlowController
Derivado
Implementações

Métodos

Add(List<EventData>, DateTime)

Adicione uma lista de EventHub EventData ao cache.

Add(List<EventData>, DateTime)

Adicione uma lista de EventHub EventData ao cache.

Add(List<EventData>, DateTime)

Adicione uma lista de EventHub EventData ao cache.

AddCachePressureMonitor(ICachePressureMonitor)

Adicionar o monitor de pressão do cache ao algoritmo de pressão traseira do cache

GetCursor(IStreamIdentity, StreamSequenceToken)

Obtenha um cursor no cache para ler eventos de um fluxo.

GetMaxAddCount()

Obtém o número máximo de itens que podem ser adicionados.

(Herdado de IQueueFlowController)
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 do cursor fornecido.

Aplica-se a