Freigeben über


SiloMemoryStreamConfigurator<TSerializer> Klasse

Definition

Konfiguriert Speicherdatenströme.

public class SiloMemoryStreamConfigurator<TSerializer> : Orleans.Hosting.SiloRecoverableStreamConfigurator, Orleans.Hosting.IPersistentStreamConfigurator, Orleans.Hosting.ISiloMemoryStreamConfigurator where TSerializer : class, IMemoryMessageBodySerializer
public class SiloMemoryStreamConfigurator<TSerializer> : Orleans.Hosting.SiloRecoverableStreamConfigurator, Orleans.Hosting.ISiloMemoryStreamConfigurator where TSerializer : class, IMemoryMessageBodySerializer
type SiloMemoryStreamConfigurator<'Serializer (requires 'Serializer : null and 'Serializer :> IMemoryMessageBodySerializer)> = class
    inherit SiloRecoverableStreamConfigurator
    interface ISiloMemoryStreamConfigurator
    interface IMemoryStreamConfigurator
    interface INamedServiceConfigurator
    interface ISiloRecoverableStreamConfigurator
    interface ISiloPersistentStreamConfigurator
    interface IPersistentStreamConfigurator
Public Class SiloMemoryStreamConfigurator(Of TSerializer)
Inherits SiloRecoverableStreamConfigurator
Implements IPersistentStreamConfigurator, ISiloMemoryStreamConfigurator
Public Class SiloMemoryStreamConfigurator(Of TSerializer)
Inherits SiloRecoverableStreamConfigurator
Implements ISiloMemoryStreamConfigurator

Typparameter

TSerializer

Der Nachrichtentextserialisierungstyp, der implementieren IMemoryMessageBodySerializermuss.

Vererbung
Implementiert

Konstruktoren

SiloMemoryStreamConfigurator<TSerializer>(String, Action<Action<IServiceCollection>>)

Initialisiert eine neue Instanz der SiloMemoryStreamConfigurator<TSerializer>-Klasse.

SiloMemoryStreamConfigurator<TSerializer>(String, Action<Action<IServiceCollection>>, Action<Action<IApplicationPartManager>>)

Konfiguriert Speicherdatenströme.

Eigenschaften

ConfigureDelegate

Ruft den Delegat ab, der zum Konfigurieren des Diensts verwendet wird.

(Geerbt von NamedServiceConfigurator)
Name

Ruft den Dienstnamen ab.

(Geerbt von NamedServiceConfigurator)

Erweiterungsmethoden

ConfigurePartitioning(IMemoryStreamConfigurator, Int32)

Konfiguriert die Partitionierung für Speicherdatenströme.

Configure<TOptions>(INamedServiceConfigurator, Action<OptionsBuilder<TOptions>>)

Konfiguriert Optionen für einen benannten Dienst.

ConfigureComponent<TComponent>(INamedServiceConfigurator, Func<IServiceProvider,String,TComponent>)

Fügt einem benannten Dienst eine Singletonkomponente hinzu.

ConfigureComponent<TOptions,TComponent>(INamedServiceConfigurator, Func<IServiceProvider,String,TComponent>, Action<OptionsBuilder<TOptions>>)

Fügt einem benannten Dienst eine Singletonkomponente hinzu und konfiguriert Optionen für den benannten Dienst.

ConfigureLifecycle<T>(INamedServiceConfigurator)

Konfiguriert Speicherdatenströme.

ConfigureStreamPubSub(IPersistentStreamConfigurator, StreamPubSubType)

Konfiguriert den Stream pub/sub-Typ.

UseAzureBlobLeaseProvider(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<AzureBlobLeaseProviderOptions>>)

Konfigurieren des Silos für die Verwendung des Azure Blob Lease-Anbieters

UseConsistentRingQueueBalancer(ISiloPersistentStreamConfigurator)

Konfiguriert den Streamanbieter für die Verwendung des konsistenten Ringwarteschlangenausgleichs.

UseDynamicAzureDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

Streamen sie den Warteschlangenausgleich, der Azure-Bereitstellungsinformationen und Silostatusstatus aus dem Mitgliedschafts oracle für den Lastenausgleich verwendet.
Erfordert die Ausführung eines Silos in Azure. Dieser Balancer verwendet sowohl die Informationen über den vollständigen Satz von Silos, die vom Azure-Rollencode gemeldet werden, als auch die Informationen aus dem Mitgliedschaftsorakel über derzeit aktive (lebendige) Silos und balanciert Warteschlangen aus nicht aktiven Silos neu aus.

UseDynamicClusterConfigDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

Konfiguriert den Streamanbieter für die Verwendung des Bereitstellungsausgleichs für die dynamische Clusterkonfiguration.

UseLeaseBasedQueueBalancer(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<LeaseBasedQueueBalancerOptions>>)

Konfiguriert den Streamanbieter für die Verwendung des leasebasierten Warteschlangenausgleichs.

UseStaticAzureDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

Streamen sie den Warteschlangenausgleich, der Azure-Bereitstellungsinformationen für den Lastenausgleich verwendet. Erfordert die Ausführung eines Silos in Azure. Dieser Balancer verwendet beide Informationen über den vollständigen Satz von Silos, die vom Azure-Rollencode gemeldet werden, verwendet jedoch NICHT die Informationen aus dem Mitgliedschaftsorakel zu derzeit lebenden Silos. Das heißt, es werden Warteschlangen nicht basierend auf dynamischen Änderungen in der Clustermitgliedschaft neu ausgeglichen.

UseStaticClusterConfigDeploymentBalancer(ISiloPersistentStreamConfigurator, Nullable<TimeSpan>)

Konfiguriert den Streamanbieter für die Verwendung des Bereitstellungsausgleichs für statische Clusterkonfigurationen.

ConfigureLifecycle(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<StreamLifecycleOptions>>)

Konfiguriert den Lebenszyklus.

ConfigurePartitionBalancing(ISiloPersistentStreamConfigurator, Func<IServiceProvider,String,IStreamQueueBalancer>)

Konfiguriert den Partitionsausgleich.

ConfigurePartitionBalancing<TOptions>(ISiloPersistentStreamConfigurator, Func<IServiceProvider,String,IStreamQueueBalancer>, Action<OptionsBuilder<TOptions>>)

Konfiguriert den Partitionsausgleich.

ConfigurePullingAgent(ISiloPersistentStreamConfigurator, Action<OptionsBuilder<StreamPullingAgentOptions>>)

Konfiguriert den Pulling-Agent.

ConfigureCacheEviction(ISiloRecoverableStreamConfigurator, Action<OptionsBuilder<StreamCacheEvictionOptions>>)

Konfiguriert Cacheräumungsoptionen für einen zuverlässigen Streamanbieter.

ConfigureStatistics(ISiloRecoverableStreamConfigurator, Action<OptionsBuilder<StreamStatisticOptions>>)

Konfiguriert Statistikoptionen für einen zuverlässigen Streamanbieter.

Gilt für: