CachedMessageBlock Classe

Définition

Espace de noms:

Orleans.Providers.Streams.Common

Assembly:

Orleans.Streaming.dll

Paquet:

Microsoft.Orleans.Streaming v8.2.0

CachedMessageBlock est un bloc de structures étroitement emballées contenant des données de suivi pour les messages mis en cache. Ces données sont étroitement emballées pour réduire la pression gc. Les données de suivi sont utilisées par le cache de file d’attente pour parcourir le cache qui sert les messages de file d’attente ordonnés par flux.

public class CachedMessageBlock : Orleans.Providers.Streams.Common.PooledResource<Orleans.Providers.Streams.Common.CachedMessageBlock>

type CachedMessageBlock = class
    inherit PooledResource<CachedMessageBlock>

Public Class CachedMessageBlock
Inherits PooledResource(Of CachedMessageBlock)

Héritage

Object

PooledResource<CachedMessageBlock>

CachedMessageBlock

Constructeurs

CachedMessageBlock(Int32)

Bloc de messages mis en cache.

Propriétés

HasCapacity	Obtient une valeur indiquant si d’autres messages peuvent être ajoutés au bloc.
IsEmpty	Obtient une valeur indiquant si ce bloc est vide.
Item[Int32]	Accédez au message mis en cache à l’index fourni.
ItemCount	Obtient le nombre de messages dans ce bloc.
NewestMessage	Obtient le message le plus récent de ce bloc.
NewestMessageIndex	Obtient l’index du message le plus récent ajouté au bloc.
Node	Nœud de liste liée, de sorte que ce bloc de messages peut être conservé dans une liste liée.
OldestMessage	Obtient le message le plus ancien du bloc.
OldestMessageIndex	Obtient l’index du message le plus ancien de ce bloc.
Pool	Obtient le pool vers lequel renvoyer cette ressource lors de sa suppression. Un pool doit définir cette propriété lors de l’allocation de ressources. (Hérité de PooledResource<T>)

Méthodes

Add(CachedMessage)	Ajoutez un message de la file d’attente au bloc. Convertit le message de file d’attente en message mis en cache et le stocke à la fin du bloc.
Dispose()	Retourne l’élément au pool. (Hérité de PooledResource<T>)
GetIndexOfFirstMessageLessThanOrEqualTo(StreamSequenceToken)	Obtient l’index du premier message de ce bloc qui a un jeton de séquence au niveau ou avant le jeton fourni
GetNewestSequenceToken(ICacheDataAdapter)	Obtient le jeton de séquence du message le plus récent de ce bloc
GetOldestSequenceToken(ICacheDataAdapter)	Obtient le jeton de séquence du message le plus ancien de ce bloc
GetSequenceToken(Int32, ICacheDataAdapter)	Obtient le jeton de séquence du message mis en cache à l’index fourni
OnResetState()	Réinitialise cet état de blocs à celui d’un bloc vide.
Remove()	Supprime un message au début du bloc (données les plus anciennes).
SignalPurge()	Si cet objet doit être utilisé dans un pool d’objets de taille fixe, cet appel doit être remplacé par l’implémentation de purge qui retourne l’objet au pool. (Hérité de PooledResource<T>)
TryFindFirstMessage(StreamId, ICacheDataAdapter, Int32)	Tente de trouver le premier message dans le bloc qui fait partie du flux fourni.
TryFindNextMessage(Int32, StreamId, ICacheDataAdapter, Int32)	Tente d’obtenir le message suivant à partir du flux fourni, en commençant par l’index de début.