Orleans.Streaming.EventStore 7.1.3

.NET 7.0

dotnet add package Orleans.Streaming.EventStore --version 7.1.3

NuGet\Install-Package Orleans.Streaming.EventStore -Version 7.1.3

This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package.

<PackageReference Include="Orleans.Streaming.EventStore" Version="7.1.3" />

For projects that support PackageReference, copy this XML node into the project file to reference the package.

paket add Orleans.Streaming.EventStore --version 7.1.3

The NuGet Team does not provide support for this client. Please contact its maintainers for support.

#r "nuget: Orleans.Streaming.EventStore, 7.1.3"

#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package.

// Install Orleans.Streaming.EventStore as a Cake Addin
#addin nuget:?package=Orleans.Streaming.EventStore&version=7.1.3

// Install Orleans.Streaming.EventStore as a Cake Tool
#tool nuget:?package=Orleans.Streaming.EventStore&version=7.1.3

The NuGet Team does not provide support for this client. Please contact its maintainers for support.

EventStore Grpc Client for Microsoft Orleans Streaming

Silo configuration:


silo.AddStreaming();
silo.AddEventStoreStreams(Constants.StreamProviderName, configurator =>
{
    var eventStoreConnectionString = "esdb://123.60.184.85:2113?tls=false";
    configurator.ConfigureEventStore(optionsBuilder =>
    {
        optionsBuilder.Configure(options =>
        {
            options.ClientSettings = EventStoreClientSettings.Create(eventStoreConnectionString);
            options.Name = "ChatRoomV2";
            // Configure Queues
            options.Queues = new List<string>
            {
                "ChatRoomV2-11111",
                "ChatRoomV2-22222",
                "ChatRoomV2-33333",
                "ChatRoomV2-44444"
            };
        });
    });

    configurator.ConfigureReceiver(optionsBuilder =>
    {
        optionsBuilder.Configure(options =>
        {
            options.SubscriptionSettings = new PersistentSubscriptionSettings(checkPointAfter: TimeSpan.FromMinutes(1), checkPointLowerBound: 1);
            options.PrefetchCount = 50;
        });
    });

    configurator.ConfigureCachePressuring(optionsBuilder =>
    {
        optionsBuilder.Configure(options =>
        {
            options.SlowConsumingMonitorFlowControlThreshold = 0.5;
            options.SlowConsumingMonitorPressureWindowSize = TimeSpan.FromMinutes(30);
        });
    });

    configurator.UseEventStoreCheckpointer(optionsBuilder =>
    {
        optionsBuilder.Configure(options =>
        {
            options.ClientSettings = EventStoreClientSettings.Create(eventStoreConnectionString);
            options.PersistInterval = TimeSpan.FromSeconds(30);
        });
    });

    configurator.ConfigureStreamPubSub();
    configurator.UseConsistentRingQueueBalancer();
});

Cluster Client Configuration

client.AddStreaming();
client.AddEventStoreStreams(Constants.StreamProviderName, configurator =>
{
    configurator.ConfigureEventStore(optionsBuilder =>
    {
        optionsBuilder.Configure(options =>
        {
            options.ClientSettings = EventStoreClientSettings.Create(eventStoreConnectionString);
            options.Name = "ChatRoomV2";
            options.Queues = new List<string>
            {
                "ChatRoomV2-11111",
                "ChatRoomV2-22222",
                "ChatRoomV2-33333",
                "ChatRoomV2-44444"
            };
        });
    });
    configurator.ConfigureStreamPubSub();
});

Product	Compatible and additional computed target framework versions.
.NET	net7.0 is compatible. net7.0-android was computed. net7.0-ios was computed. net7.0-maccatalyst was computed. net7.0-macos was computed. net7.0-tvos was computed. net7.0-windows was computed. net8.0 was computed. net8.0-android was computed. net8.0-browser was computed. net8.0-ios was computed. net8.0-maccatalyst was computed. net8.0-macos was computed. net8.0-tvos was computed. net8.0-windows was computed.

Product

.NET

Compatible target framework(s)

Included target framework(s) (in package)

Learn more about Target Frameworks and .NET Standard.

net7.0
- EventStore.Client.Grpc.PersistentSubscriptions (>= 23.0.0)
- EventStore.Client.Grpc.Streams (>= 23.0.0)
- Google.Protobuf (>= 3.22.3)
- Grpc.Core.Api (>= 2.52.0)
- Grpc.Net.Client (>= 2.52.0)
- Microsoft.Orleans.Runtime (>= 7.1.2)
- Microsoft.Orleans.Sdk (>= 7.1.2)
- Microsoft.Orleans.Serialization.Protobuf (>= 7.1.2)
- Microsoft.Orleans.Streaming (>= 7.1.2)
- System.Threading.Tasks.Extensions (>= 4.5.4)

NuGet packages (1)

Showing the top 1 NuGet packages that depend on Orleans.Streaming.EventStore:

Package	Downloads
SiloX.Orleans.Streaming.EventStore EventStore streaming module that for Microsoft Orleans.	143

GitHub repositories

This package is not used by any popular GitHub repositories.

Version	Downloads	Last updated
7.1.3	224	4/25/2023
7.1.2	187	4/6/2023
7.1.1	243	3/24/2023
7.1.0	186	3/24/2023