3 implementations of IAppHostAuxiliaryBackchannel
aspire (1)
Backchannel\AppHostAuxiliaryBackchannel.cs (1)
21internal sealed class AppHostAuxiliaryBackchannel : IAppHostAuxiliaryBackchannel
Aspire.Cli.Tests (2)
Commands\TerminalCommandTests.cs (1)
660private sealed class CapturingTerminalAppHostBackchannel : IAppHostAuxiliaryBackchannel
TestServices\TestAppHostAuxiliaryBackchannel.cs (1)
15internal sealed class TestAppHostAuxiliaryBackchannel : IAppHostAuxiliaryBackchannel
101 references to IAppHostAuxiliaryBackchannel
aspire (85)
Backchannel\AppHostConnectionHelper.cs (3)
26public static async Task<IAppHostAuxiliaryBackchannel?> GetSelectedConnectionAsync( 47var selectedConnection = connections.FirstOrDefault(c => 86var fallback = connections
Backchannel\AppHostConnectionResolver.cs (6)
23public IAppHostAuxiliaryBackchannel? Connection { get; init; } 202IAppHostAuxiliaryBackchannel? selectedConnection = null; 288private static bool IsInWorktreeOfWorkingDirectory(IAppHostAuxiliaryBackchannel connection, string workingDirectory) 321private async Task<IAppHostAuxiliaryBackchannel?> PromptForAppHostSelectionAsync( 322List<IAppHostAuxiliaryBackchannel> candidateConnections, 347var selectedConnection = choices.FirstOrDefault(c => c.Display == selectedDisplay).Connection;
Backchannel\AuxiliaryBackchannelMonitor.cs (7)
55public IEnumerable<IAppHostAuxiliaryBackchannel> Connections => 63public IEnumerable<IAppHostAuxiliaryBackchannel> GetConnectionsByHash(string hash) => 66public async IAsyncEnumerable<IReadOnlyList<IAppHostAuxiliaryBackchannel>> WatchConnectionsAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 143public IAppHostAuxiliaryBackchannel? SelectedConnection 157var selectedConnection = connections.FirstOrDefault(c => 186public IReadOnlyList<IAppHostAuxiliaryBackchannel> GetConnectionsForWorkingDirectory(DirectoryInfo workingDirectory) 568private static async Task DisconnectAsync(IAppHostAuxiliaryBackchannel connection)
Backchannel\IAuxiliaryBackchannelMonitor.cs (5)
14IEnumerable<IAppHostAuxiliaryBackchannel> Connections { get; } 21IEnumerable<IAppHostAuxiliaryBackchannel> GetConnectionsByHash(string hash); 32IAppHostAuxiliaryBackchannel? SelectedConnection { get; } 44IReadOnlyList<IAppHostAuxiliaryBackchannel> GetConnectionsForWorkingDirectory(DirectoryInfo workingDirectory); 58IAsyncEnumerable<IReadOnlyList<IAppHostAuxiliaryBackchannel>> WatchConnectionsAsync(CancellationToken cancellationToken = default);
Backchannel\OrphanedAppHostCollector.cs (3)
25List<IAppHostAuxiliaryBackchannel> orphans; 47foreach (var connection in orphans) 89internal static bool IsOrphaned(IAppHostAuxiliaryBackchannel connection)
Backchannel\ResourceSnapshotWatcher.cs (2)
18private readonly IAppHostAuxiliaryBackchannel _connection; 31IAppHostAuxiliaryBackchannel connection,
Backchannel\ResourceWaitService.cs (1)
44IAppHostAuxiliaryBackchannel connection,
Commands\AgentMcpCommand.cs (2)
262var connection = await GetSelectedConnectionAsync(cancellationToken).ConfigureAwait(false); 304private Task<IAppHostAuxiliaryBackchannel?> GetSelectedConnectionAsync(CancellationToken cancellationToken)
Commands\AppHostFollowDisconnectHelpers.cs (2)
30internal static bool HasAppHostExited(IAppHostAuxiliaryBackchannel connection) 59internal static void WriteStatusMessage(IInteractionService interactionService, IAppHostAuxiliaryBackchannel connection)
Commands\AppHostLauncher.cs (5)
475private record LaunchResult(IProcessExecution? ChildProcess, IAppHostAuxiliaryBackchannel? Backchannel, DashboardUrlsState? DashboardUrls, bool ChildExitedEarly, int ChildExitCode, DateTimeOffset? ChildStartedAt = null); 534IAppHostAuxiliaryBackchannel? connection = null; 711internal static async Task<bool?> WaitForAppHostReadyAsync(IAppHostAuxiliaryBackchannel connection, CancellationToken cancellationToken) 718IAppHostAuxiliaryBackchannel connection, 747IAppHostAuxiliaryBackchannel connection,
Commands\DescribeCommand.cs (1)
147var connection = result.Connection!;
Commands\ExportCommand.cs (2)
137IAppHostAuxiliaryBackchannel? connection, 252IAppHostAuxiliaryBackchannel connection,
Commands\LogsCommand.cs (5)
173var connection = result.Connection!; 233IAppHostAuxiliaryBackchannel connection, 297IAppHostAuxiliaryBackchannel connection, 375IAppHostAuxiliaryBackchannel connection, 416IAppHostAuxiliaryBackchannel connection,
Commands\McpCallCommand.cs (1)
71var connection = result.Connection!;
Commands\McpToolsCommand.cs (1)
57var connection = result.Connection!;
Commands\PsCommand.cs (6)
167private async Task<List<IAppHostAuxiliaryBackchannel>> ScanForConnectionsAsync(CancellationToken cancellationToken) 176private sealed record ConnectionsUpdate(IReadOnlyList<IAppHostAuxiliaryBackchannel> Connections) : PsFollowUpdate; 320private static List<IAppHostAuxiliaryBackchannel> OrderConnections(IEnumerable<IAppHostAuxiliaryBackchannel> connections) 327private async Task<List<AppHostDisplayInfo>> GatherAppHostInfosAsync(List<IAppHostAuxiliaryBackchannel> connections, CancellationToken cancellationToken) 331foreach (var connection in connections)
Commands\ResourceCommand.cs (7)
142var connection = result.Connection!; 185IAppHostAuxiliaryBackchannel connection, 222private static async Task<ResourceSnapshotCommand?> GetCommandMetadataAsync(IAppHostAuxiliaryBackchannel connection, string resourceName, string commandName, bool includeHidden, CancellationToken cancellationToken) 233private static async Task<(string Name, string Description)[]> GetAvailableCommandMetadataAsync(IAppHostAuxiliaryBackchannel connection, string resourceName, bool includeHidden, CancellationToken cancellationToken) 642var connection = await ResolveConnectionForAvailableCommandsAsync(parseResult, cancellationToken).ConfigureAwait(false); 663private async Task<IAppHostAuxiliaryBackchannel?> ResolveConnectionForAvailableCommandsAsync(ParseResult parseResult, CancellationToken cancellationToken) 682private async Task<IAppHostAuxiliaryBackchannel?> ResolveExplicitConnectionForAvailableCommandsAsync(FileInfo appHostProjectFile, CancellationToken cancellationToken)
Commands\ResourceCommandHelper.cs (2)
32IAppHostAuxiliaryBackchannel connection, 64IAppHostAuxiliaryBackchannel connection,
Commands\StopCommand.cs (6)
232var connection = inScopeConnections[0].Connection!; 491private async Task<int> StopAppHostAsync(IAppHostAuxiliaryBackchannel connection, string appHostIdentifier, CancellationToken cancellationToken) 538private string GetSingleAppHostDisplayPath(IAppHostAuxiliaryBackchannel connection) 551private static string GetAppHostPath(IAppHostAuxiliaryBackchannel connection) 558private static FileInfo? GetAppHostFile(IAppHostAuxiliaryBackchannel connection) 590private static string GetAppHostIdentifier(IAppHostAuxiliaryBackchannel connection, string displayPath, bool includeProcessId)
Commands\TelemetryCommandHelpers.cs (2)
273var connection = result.Connection!; 672IAppHostAuxiliaryBackchannel? Connection,
Commands\TerminalAttachCommand.cs (2)
26/// list of terminal replicas via <see cref="IAppHostAuxiliaryBackchannel.GetTerminalInfoAsync"/>.</item> 102var connection = connectionResult.Connection!;
Commands\TerminalPsCommand.cs (2)
28/// <item>Calls <see cref="IAppHostAuxiliaryBackchannel.ListTerminalsAsync"/> to enumerate every 111var connection = connectionResult.Connection!;
Commands\WaitCommand.cs (2)
95var connection = result.Connection!; 101IAppHostAuxiliaryBackchannel connection,
Mcp\McpResourceToolRefreshService.cs (1)
84var connection = await AppHostConnectionHelper.GetSelectedConnectionAsync(_auxiliaryBackchannelMonitor, _logger, cancellationToken).ConfigureAwait(false);
Mcp\Tools\ExecuteResourceCommandTool.cs (1)
86var connection = await AppHostConnectionHelper.GetSelectedConnectionAsync(auxiliaryBackchannelMonitor, logger, cancellationToken).ConfigureAwait(false);
Mcp\Tools\ListConsoleLogsTool.cs (1)
67var connection = await AppHostConnectionHelper.GetSelectedConnectionAsync(auxiliaryBackchannelMonitor, logger, cancellationToken).ConfigureAwait(false);
Mcp\Tools\ListResourcesTool.cs (1)
63var connection = await AppHostConnectionHelper.GetSelectedConnectionAsync(auxiliaryBackchannelMonitor, logger, cancellationToken).ConfigureAwait(false);
Mcp\Tools\McpToolHelpers.cs (4)
20var connection = await AppHostConnectionHelper.GetSelectedConnectionAsync(auxiliaryBackchannelMonitor, logger, cancellationToken).ConfigureAwait(false); 168IAppHostAuxiliaryBackchannel connection, 197var connection = await AppHostConnectionHelper.GetSelectedConnectionAsync(auxiliaryBackchannelMonitor, NullLogger.Instance, cancellationToken).ConfigureAwait(false); 210IAppHostAuxiliaryBackchannel connection,
Mcp\Tools\SelectAppHostTool.cs (1)
70var matchingConnection = auxiliaryBackchannelMonitor.Connections
Projects\RunningInstanceManager.cs (1)
100public async Task<bool> StopAndMonitorAsync(IAppHostAuxiliaryBackchannel backchannel, CancellationToken cancellationToken)
Aspire.Cli.Tests (16)
Commands\TerminalCommandTests.cs (1)
657/// <see cref="IAppHostAuxiliaryBackchannel.GetTerminalInfoAsync"/>. All other calls
Mcp\AppHostConnectionSelectionLogicTests.cs (1)
46var selected = monitor.SelectedConnection;
Mcp\MockPackagingService.cs (5)
45public IEnumerable<IAppHostAuxiliaryBackchannel> Connections => []; 47public IEnumerable<IAppHostAuxiliaryBackchannel> GetConnectionsByHash(string hash) => []; 51public IAppHostAuxiliaryBackchannel? SelectedConnection => null; 55public async IAsyncEnumerable<IReadOnlyList<IAppHostAuxiliaryBackchannel>> WatchConnectionsAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 61public IReadOnlyList<IAppHostAuxiliaryBackchannel> GetConnectionsForWorkingDirectory(DirectoryInfo workingDirectory)
TestServices\TestAuxiliaryBackchannelMonitor.cs (9)
14private readonly ConcurrentDictionary<string, ConcurrentDictionary<string, IAppHostAuxiliaryBackchannel>> _connectionsByHash = new(); 17public IEnumerable<IAppHostAuxiliaryBackchannel> Connections => 20public IEnumerable<IAppHostAuxiliaryBackchannel> GetConnectionsByHash(string hash) => 41public async IAsyncEnumerable<IReadOnlyList<IAppHostAuxiliaryBackchannel>> WatchConnectionsAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 58public IAppHostAuxiliaryBackchannel? SelectedConnection 72var selectedConnection = connections.FirstOrDefault(c => 98public IReadOnlyList<IAppHostAuxiliaryBackchannel> GetConnectionsForWorkingDirectory(DirectoryInfo workingDirectory) 121public void AddConnection(string hash, string socketPath, IAppHostAuxiliaryBackchannel connection) 123var connectionsDict = _connectionsByHash.GetOrAdd(hash, _ => new ConcurrentDictionary<string, IAppHostAuxiliaryBackchannel>());