20 references to TrayCliProtocol
aspire (8)
Backchannel\TrayWatchStream.cs (6)
72using var heartbeat = new PeriodicTimer(TrayCliProtocol.HeartbeatInterval, timeProvider); 78Version = TrayCliProtocol.Version, 208if (candidates.Count == TrayCliProtocol.MaximumAppHosts) 287Version = TrayCliProtocol.Version, 297return json.Length > TrayCliProtocol.MaximumMessageLength ? Error("limit_exceeded") : new Update(json, false); 419Version = TrayCliProtocol.Version,
Commands\StopCommand.TrayProtocol.cs (2)
55if (parseResult.GetValue(s_protocolVersionOption) != TrayCliProtocol.Version || 112Version = TrayCliProtocol.Version,
Aspire.Cli.Tests (12)
Backchannel\TrayWatchStreamTests.cs (11)
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); 510for (var i = 0; i < TrayCliProtocol.MaximumAppHosts; i++) 544Assert.Equal(Enumerable.Range(1, TrayCliProtocol.MaximumAppHosts), snapshot.AppHosts!.Select(host => host.AppHostPid)); 546Assert.InRange(calls, TrayWatchStream.MaximumConcurrentDashboardLookups, TrayCliProtocol.MaximumAppHosts - 1); 549Assert.True(TrayWatchStream.DashboardSnapshotTimeout < TrayCliProtocol.LivenessTimeout); 918time.Advance(TrayCliProtocol.HeartbeatInterval); 982Version = TrayCliProtocol.Version, 986var stop = new TrayStopMessage { Version = TrayCliProtocol.Version, Outcome = "stopped", ExitCode = 0 };
Commands\TrayProtocolCommandTests.cs (1)
303Assert.Equal(TrayCliProtocol.Version, message.Version);