EventHubQueueCache 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

Pacote:: Microsoft.Orleans.OrleansServiceBus v3.6.5

Origem:: EventHubQueueCache.cs

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 mensagens que armazena EventData como um CachedEventHubMessage em um cache de mensagens em pool

public class EventHubQueueCache : Orleans.ServiceBus.Providers.EventHubQueueCache<Orleans.ServiceBus.Providers.CachedEventHubMessage>

public class EventHubQueueCache : IDisposable, Orleans.ServiceBus.Providers.IEventHubQueueCache, Orleans.Streams.IQueueFlowController

type EventHubQueueCache = class
    inherit EventHubQueueCache<CachedEventHubMessage>

type EventHubQueueCache = class
    interface IEventHubQueueCache
    interface IQueueFlowController
    interface IDisposable

Public Class EventHubQueueCache
Inherits EventHubQueueCache(Of CachedEventHubMessage)

Public Class EventHubQueueCache
Implements IDisposable, IEventHubQueueCache, IQueueFlowController

Herança: Object

EventHubQueueCache<CachedEventHubMessage>
EventHubQueueCache

Herança: Object
EventHubQueueCache

Implementações: IEventHubQueueCache IQueueFlowController IDisposable

Construtores

EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Construa o cache dado um adaptador de dados personalizado.
EventHubQueueCache(Int32, IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Construa o cache dado um adaptador de dados personalizado.
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, ILogger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Construa o cache dado um adaptador de dados personalizado.
EventHubQueueCache(IStreamQueueCheckpointer<String>, ICacheDataAdapter<EventData, CachedEventHubMessage>, ICacheDataComparer<CachedEventHubMessage>, Logger, IEvictionStrategy<CachedEventHubMessage>, ICacheMonitor, Nullable<TimeSpan>)	Construa o cache dado um adaptador de dados personalizado.
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, ILogger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)	Construa o cache dado um pool de buffers. Usará o adaptador de dados padrão
EventHubQueueCache(IStreamQueueCheckpointer<String>, IObjectPool<FixedSizeBuffer>, TimePurgePredicate, Logger, SerializationManager, ICacheMonitor, Nullable<TimeSpan>)	Construa o cache dado um pool de buffers. Usará o adaptador de dados padrão
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
cache	Implementação do cache de mensagens subjacente (Herdado de EventHubQueueCache<TCachedMessage>)
defaultMaxAddCount	Número máximo padrão de itens que podem ser adicionados ao cache entre chamadas de limpeza (Herdado de EventHubQueueCache<TCachedMessage>)

Propriedades

Checkpointer	Lógica usada para armazenar a posição da fila (Herdado de EventHubQueueCache<TCachedMessage>)
Partition	Cache de mensagens que armazena EventData como um CachedEventHubMessage em um cache de mensagens em pool

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. (Herdado de EventHubQueueCache<TCachedMessage>)
Add(List<EventData>, DateTime)	Adicione uma lista de EventData do EventHub ao cache. (Herdado de EventHubQueueCache<TCachedMessage>)
AddCachePressureMonitor(ICachePressureMonitor)	Adicionar o monitor de pressão de cache ao algoritmo de pressão traseira do cache
AddCachePressureMonitor(ICachePressureMonitor)	Adicionar o monitor de pressão de cache ao algoritmo de pressão traseira do cache (Herdado de EventHubQueueCache<TCachedMessage>)
Dispose()	Realiza tarefas definidas pelo aplicativo associadas à liberação ou à redefinição de recursos não gerenciados.
Dispose()	Realiza tarefas definidas pelo aplicativo associadas à liberação ou à redefinição de recursos não gerenciados. (Herdado de EventHubQueueCache<TCachedMessage>)
GetCursor(IStreamIdentity, StreamSequenceToken)	Obtenha um cursor no cache para ler eventos de um fluxo.
GetCursor(IStreamIdentity, StreamSequenceToken)	Obtenha um cursor no cache para ler eventos de um fluxo. (Herdado de EventHubQueueCache<TCachedMessage>)
GetMaxAddCount()	O limite do número máximo de itens que podem ser adicionados
GetMaxAddCount()	O limite do número máximo de itens que podem ser adicionados (Herdado de EventHubQueueCache<TCachedMessage>)
GetOffset(CachedEventHubMessage)	Obter deslocamento da mensagem armazenada em cache. Deixado para a classe derivada, pois só ele sabe como obter isso da mensagem armazenada em cache.
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. (Herdado de EventHubQueueCache<TCachedMessage>)
OnPurge(Nullable<CachedEventHubMessage>, Nullable<CachedEventHubMessage>)	Manipula sinais de limpeza de cache
OnPurge(Nullable<TCachedMessage>, Nullable<TCachedMessage>)	Manipula sinais de limpeza de cache (Herdado de EventHubQueueCache<TCachedMessage>)
SignalPurge()	Enviar sinal de limpeza para o cache, o cache executará uma limpeza baseada em tempo em suas mensagens armazenadas em cache
SignalPurge()	Enviar sinal de limpeza para o cache, o cache executará uma limpeza baseada em tempo em suas mensagens armazenadas em cache (Herdado de EventHubQueueCache<TCachedMessage>)
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.
TryGetNextMessage(Object, IBatchContainer)	Tente obter a próxima mensagem no cache para o cursor fornecido. (Herdado de EventHubQueueCache<TCachedMessage>)

Aplica-se a

Compartilhar via