Petabridge.Cmd.Cluster.Sharding 1.0.0 The ID prefix of this package has been reserved for one of the owners of this package by Prefix Reserved

There is a newer version of this package available.
See the version list below for details.
Install-Package Petabridge.Cmd.Cluster.Sharding -Version 1.0.0
dotnet add package Petabridge.Cmd.Cluster.Sharding --version 1.0.0
<PackageReference Include="Petabridge.Cmd.Cluster.Sharding" Version="1.0.0" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add Petabridge.Cmd.Cluster.Sharding --version 1.0.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
#r "nuget: Petabridge.Cmd.Cluster.Sharding, 1.0.0"
#r directive can be used in F# Interactive, C# scripting and .NET Interactive. Copy this into the interactive tool or source code of the script to reference the package.
// Install Petabridge.Cmd.Cluster.Sharding as a Cake Addin
#addin nuget:?package=Petabridge.Cmd.Cluster.Sharding&version=1.0.0

// Install Petabridge.Cmd.Cluster.Sharding as a Cake Tool
#tool nuget:?package=Petabridge.Cmd.Cluster.Sharding&version=1.0.0
The NuGet Team does not provide support for this client. Please contact its maintainers for support.

Akka.Cluster.Sharding Petabridge.Cmd palettes for shard management and monitoring.

There are no supported framework assets in this package.

Learn more about Target Frameworks and .NET Standard.

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories

This package is not used by any popular GitHub repositories.

Version Downloads Last updated
1.0.2 2,275 11/16/2021
1.0.1 6,124 8/3/2021
1.0.0 889 7/26/2021
0.8.5 9,570 5/3/2021
0.8.4 149 4/30/2021
0.8.3 5,172 3/18/2021
0.8.2 9,956 11/24/2020
0.8.1 8,865 11/16/2020
0.8.0 27,770 3/11/2020
0.8.0-rc2 210 3/10/2020
0.8.0-rc1 271 3/3/2020
0.7.1-beta 2,825 3/3/2020
0.7.0-beta 3,501 10/3/2019
0.6.3-beta 2,453 7/30/2019
0.6.2-beta 1,096 6/19/2019
0.6.1-beta 714 5/19/2019
0.6.0-beta 754 5/9/2019
0.5.0-beta 1,163 3/6/2019

Petabridge.Cmd v1.0.0 is a major release of Petabridge.Cmd that doesn't include any breaking changes for older clients.
Programmatic `IPbmClient` Support**
It is now possible to invoke Petabridge.Cmd programmatically, as of Petabridge.Cmd 1.0.0 - and this can be done in one of two ways:
1. In-process, inside the same Akka.NET `ActorSystem` that is running the `PetabridgeCmd` host;
2. Remotely, from an external process that connects to the `PetabridgeCmd` host using the same TCP port used by the `pbm` CLI clients.
We've added [extensive documentation to the Petabridge.Cmd website which documents how to use these new `IPbmClient` implementations](, but we've also included a small example here:
// <configureHost>
// create a Petabridge.Cmd host from our ActorSystem
// host is configured to run on port 11555 via HOCON
var pbmHost = PetabridgeCmd.Get(Sys);
// start the host
// </configureHost>
// <clientActorSystem>
// create client ActorSystem
using ActorSystem clientSystem = ActorSystem.Create("ClientSystem");
// grab copy of the PetabridgeCmdClient extension (Petabridge.Cmd.Common NuGet package)
var clientExt = PetabridgeCmdClient.Get(clientSystem);
// create IpEndPoint or DnsEndPoint for contacting remote host
// either one of these would work
var ip = new IPEndPoint(IPAddress.Loopback, 11555);
var dns = new DnsEndPoint("localhost", 11555);
// start a new IPbmClient attached to one of these EndPoints
// by default this operation will time out in 5 seconds.
// you can extend that by passing in a custom CancellationToken
IPbmClient remoteClient = await clientExt.StartRemoteClient(ip);
// </clientActorSystem>
// <runClient>
// invoke a "log peek" command, just like you would on CLI
CommandSession session = await remoteClient.ExecuteTextCommandAsync("log peek");
// grab a hold of the Akka.Streams materializer from ActorSystem
var materializer = Sys.Materializer();
// pipe the Akka.Streams Source<CommandResponse> to a Sink<CommandResponse>
// in this case, we're just going to send everything to a TestActor.
// This Akka.Streams "graph" can be materialized into a Task, which will
// complete once the stream is marked as complete by the Petabridge.Cmd host.
var completionTask = session.Stream.RunForeach(rsp =>
}, materializer);
// a client can also cancel the stream using the KillSwitch included
// inside the CommandSession object
// once either of those two events occur, the Task returned earlier
// will be complete
await completionTask;
// and we can validate that the TestActor received at least one CommandResponse
var response = ExpectMsg<CommandResponse>();
// </runClient>
Multiple Concurrent Client Sessions**
Another major architectural change we've introduced to Petabridge.Cmd in order to support programmatic clients is the notion of multiple client-facing sessions all originating from the same connection. Petabridge.Cmd now effectively supports command multi-plexing on the server and client side.
In effect, a single `IPbmClient` can now run multiple streaming commands at once - such as `log tail`, `cluster tail`, and `remote tail`, all over the same TCP connection.
This is a minor breaking change to some command palettes - all of the official Petabridge ones will be updated shortly to support this, but user-defined `CommandPalette`s may also need to be updated in order to support this. We will update our "[Creating Custom Commands](" documentation shortly to help developers implement these changes successfully - the changes required are minor.