21 references to TrayCliProtocol
aspire (8)
Backchannel\TrayWatchStream.cs (6)
72using var heartbeat = new PeriodicTimer(TrayCliProtocol.HeartbeatInterval, timeProvider); 78Version = TrayCliProtocol.Version, 210if (candidates.Count == TrayCliProtocol.MaximumAppHosts) 289Version = TrayCliProtocol.Version, 299return json.Length > TrayCliProtocol.MaximumMessageLength ? Error("limit_exceeded") : new Update(json, false); 421Version = TrayCliProtocol.Version,
Commands\StopCommand.TrayProtocol.cs (2)
55if (parseResult.GetValue(s_protocolVersionOption) != TrayCliProtocol.Version || 112Version = TrayCliProtocol.Version,
Aspire.Cli.Tests (13)
Backchannel\TrayWatchStreamTests.cs (12)
47time.Advance(TrayCliProtocol.HeartbeatInterval); 203for (var i = 0; i <= TrayCliProtocol.MaximumAppHosts; i++) 211var connection = Connection("/" + new string('x', TrayCliProtocol.MaximumMessageLength), 1); 218Assert.True(json.Length <= TrayCliProtocol.MaximumMessageLength); 344time.Advance(TrayCliProtocol.HeartbeatInterval); 568for (var i = 0; i < TrayCliProtocol.MaximumAppHosts; i++) 602Assert.Equal(Enumerable.Range(1, TrayCliProtocol.MaximumAppHosts), snapshot.AppHosts!.Select(host => host.AppHostPid)); 604Assert.InRange(calls, TrayWatchStream.MaximumConcurrentDashboardLookups, TrayCliProtocol.MaximumAppHosts - 1); 607Assert.True(TrayWatchStream.DashboardSnapshotTimeout < TrayCliProtocol.LivenessTimeout); 976time.Advance(TrayCliProtocol.HeartbeatInterval); 1040Version = TrayCliProtocol.Version, 1044var stop = new TrayStopMessage { Version = TrayCliProtocol.Version, Outcome = "stopped", ExitCode = 0 };
Commands\TrayProtocolCommandTests.cs (1)
303Assert.Equal(TrayCliProtocol.Version, message.Version);