EventHubQueueCache<TCachedMessage> Classe

Referência

Definição

Namespace:: Orleans.ServiceBus.Providers

Assembly:: OrleansServiceBus.dll

Assembly:: Orleans.Streaming.EventHubs.dll

Pacote:: Microsoft.Orleans.OrleansServiceBus v1.5.10

Pacote:: Microsoft.Orleans.OrleansServiceBus v2.4.5

Importante

Algumas informações se referem a produtos de pré-lançamento que podem ser substancialmente modificados antes do lançamento. A Microsoft não oferece garantias, expressas ou implícitas, das informações aqui fornecidas.

Cache de fila do EventHub que permite que os desenvolvedores forneçam sua própria estrutura de dados armazenada em cache.

public abstract class EventHubQueueCache<TCachedMessage> : IDisposable, Orleans.ServiceBus.Providers.IEventHubQueueCache, Orleans.Streams.IQueueFlowController where TCachedMessage : struct

type EventHubQueueCache<'CachedMessage (requires 'CachedMessage : struct)> = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public MustInherit Class EventHubQueueCache(Of TCachedMessage)
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

Parâmetros de tipo

TCachedMessage

Herança: Object
EventHubQueueCache<TCachedMessage>

Derivado: Orleans.ServiceBus.Providers.EventHubQueueCache

Implementações: IEventHubQueueCache IQueueFlowController IDisposable

Construtores

EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, ILogger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)	Construa o cache de fila do EventHub.
EventHubQueueCache<TCachedMessage>(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData,TCachedMessage>, ICacheDataComparer<TCachedMessage>, Logger, IEvictionStrategy<TCachedMessage>, ICacheMonitor, Nullable<TimeSpan>)	Construa o cache de fila do EventHub.

Campos

cache	Implementação do cache de mensagens subjacente
defaultMaxAddCount	Número máximo padrão de itens que podem ser adicionados ao cache entre chamadas de limpeza

Propriedades

Checkpointer

Lógica usada para armazenar a posição da fila

Métodos

Add(List<EventData>, DateTime)	Adicione uma lista de EventData do EventHub ao cache.
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(IStreamIdentity, 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
GetOffset(TCachedMessage)	Obter deslocamento da mensagem armazenada em cache. Deixado para a classe derivada, pois só ele sabe como obter isso da mensagem armazenada em cache.
OnPurge(Nullable<TCachedMessage>, Nullable<TCachedMessage>)	Manipula sinais de limpeza de cache
SignalPurge()	Enviar sinal de limpeza para o cache, o cache executará uma limpeza baseada em tempo em suas mensagens armazenadas em cache
TryCalculateCachePressureContribution(StreamSequenceToken, Double)	cachePressureContribution deve ser um duplo entre 0 e 1, indicando quanto perigo o item está de ser removido do cache. 0 indicando que não há perigo, 1 indicando que a remoção é iminente.
TryGetNextMessage(Object, IBatchContainer)	Tente obter a próxima mensagem no cache para o cursor fornecido.

Aplica-se a

Compartilhar via