Compartilhar via


IEventHubQueueCache Interface

Definição

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

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 EventData do EventHub ao cache.

AddCachePressureMonitor(ICachePressureMonitor)

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

GetCursor(StreamId, 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 para o cursor fornecido.

Aplica-se a