Petabridge.Cmd.Cluster 1.0.0

Akka.Cluster Petabridge.Cmd palettes for cluster management and monitoring.

Install-Package Petabridge.Cmd.Cluster -Version 1.0.0
dotnet add package Petabridge.Cmd.Cluster --version 1.0.0
<PackageReference Include="Petabridge.Cmd.Cluster" 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 --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, 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 as a Cake Addin
#addin nuget:?package=Petabridge.Cmd.Cluster&version=1.0.0

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

Release Notes

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.

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories (1)

Showing the top 1 popular GitHub repositories that depend on Petabridge.Cmd.Cluster:

Repository Stars
A scalable cloud computing blockchain platform

Version History

Version Downloads Last updated
1.0.0 181 7/26/2021
0.8.5 5,842 5/3/2021
0.8.4 213 4/30/2021
0.8.3 6,683 3/18/2021
0.8.2 19,406 11/24/2020
0.8.1 9,389 11/16/2020
0.8.0 39,959 3/11/2020
0.8.0-rc2 333 3/10/2020
0.8.0-rc1 304 3/3/2020
0.7.1 6,861 3/3/2020
0.7.0 27,490 10/3/2019
0.6.3 8,774 7/30/2019
0.6.2 5,566 6/19/2019
0.6.1 1,274 5/19/2019
0.6.0 5,449 5/9/2019
0.5.0 51,195 3/6/2019
0.4.1 2,953 12/7/2018
0.4.0 940 11/27/2018
0.3.3 27,765 2/27/2018
0.3.2 15,489 12/20/2017
0.3.1 2,848 9/19/2017
0.3.0 596 9/14/2017
0.2.2 5,262 6/25/2017
0.2.1 568 6/6/2017
0.2.0 5,137 5/21/2017
0.1.2 563 4/25/2017
0.1.1 571 4/21/2017
0.1.0 687 4/18/2017