3 implementations of IAppHostAuxiliaryBackchannel
aspire (1)
Backchannel\AppHostAuxiliaryBackchannel.cs (1)
21internal sealed class AppHostAuxiliaryBackchannel : IAppHostAuxiliaryBackchannel
Aspire.Cli.Tests (2)
Commands\TerminalCommandTests.cs (1)
661private sealed class CapturingTerminalAppHostBackchannel : IAppHostAuxiliaryBackchannel
TestServices\TestAppHostAuxiliaryBackchannel.cs (1)
16internal sealed class TestAppHostAuxiliaryBackchannel : IAppHostAuxiliaryBackchannel
101 references to IAppHostAuxiliaryBackchannel
aspire (88)
Backchannel\AppHostConnectionHelper.cs (3)
27public static async Task<IAppHostAuxiliaryBackchannel?> GetSelectedConnectionAsync( 52var selectedConnection = connections.FirstOrDefault(c => 94var fallback = connections
Backchannel\AppHostConnectionResolver.cs (6)
24public IAppHostAuxiliaryBackchannel? Connection { get; init; } 203IAppHostAuxiliaryBackchannel? selectedConnection = null; 289private static bool IsInWorktreeOfWorkingDirectory(IAppHostAuxiliaryBackchannel connection, string workingDirectory) 322private async Task<IAppHostAuxiliaryBackchannel?> PromptForAppHostSelectionAsync( 323List<IAppHostAuxiliaryBackchannel> candidateConnections, 348var selectedConnection = choices.FirstOrDefault(c => c.Display == selectedDisplay).Connection;
Backchannel\AuxiliaryBackchannelMonitor.cs (9)
57public IEnumerable<IAppHostAuxiliaryBackchannel> Connections => 60public async IAsyncEnumerable<IReadOnlyList<IAppHostAuxiliaryBackchannel>> WatchConnectionsAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 131public IAppHostAuxiliaryBackchannel? SelectedConnection 136var connection = SelectConnection(Connections, ref selectedAppHostPath); 157internal static IAppHostAuxiliaryBackchannel? SelectConnection( 158IEnumerable<IAppHostAuxiliaryBackchannel> connections, 175var selectedConnection = candidates.FirstOrDefault(c => 206public IReadOnlyList<IAppHostAuxiliaryBackchannel> GetConnectionsForWorkingDirectory(DirectoryInfo workingDirectory) 698private static async Task DisconnectAsync(IAppHostAuxiliaryBackchannel connection)
Backchannel\IAuxiliaryBackchannelMonitor.cs (4)
14IEnumerable<IAppHostAuxiliaryBackchannel> Connections { get; } 25IAppHostAuxiliaryBackchannel? SelectedConnection { get; } 37IReadOnlyList<IAppHostAuxiliaryBackchannel> GetConnectionsForWorkingDirectory(DirectoryInfo workingDirectory); 51IAsyncEnumerable<IReadOnlyList<IAppHostAuxiliaryBackchannel>> WatchConnectionsAsync(CancellationToken cancellationToken = default);
Backchannel\OrphanedAppHostCollector.cs (3)
24List<IAppHostAuxiliaryBackchannel> orphans; 46foreach (var connection in orphans) 88internal 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 (7)
427private record LaunchResult(IProcessExecution? ChildProcess, IAppHostAuxiliaryBackchannel? Backchannel, DashboardUrlsState? DashboardUrls, bool ChildExitedEarly, int ChildExitCode, DateTimeOffset? ChildStartedAt = null); 494IAppHostAuxiliaryBackchannel? connection = null; 667internal static bool IsLaunchedByChildCli(IAppHostAuxiliaryBackchannel candidate, int childProcessId, long? childStableStartedAt) 701IAppHostAuxiliaryBackchannel candidate, 750internal static async Task<bool?> WaitForAppHostReadyAsync(IAppHostAuxiliaryBackchannel connection, CancellationToken cancellationToken) 757IAppHostAuxiliaryBackchannel connection, 786IAppHostAuxiliaryBackchannel 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)
143var connection = result.Connection!; 186IAppHostAuxiliaryBackchannel connection, 223private static async Task<ResourceSnapshotCommand?> GetCommandMetadataAsync(IAppHostAuxiliaryBackchannel connection, string resourceName, string commandName, bool includeHidden, CancellationToken cancellationToken) 234private static async Task<(string Name, string Description)[]> GetAvailableCommandMetadataAsync(IAppHostAuxiliaryBackchannel connection, string resourceName, bool includeHidden, CancellationToken cancellationToken) 643var connection = await ResolveConnectionForAvailableCommandsAsync(parseResult, cancellationToken).ConfigureAwait(false); 664private async Task<IAppHostAuxiliaryBackchannel?> ResolveConnectionForAvailableCommandsAsync(ParseResult parseResult, CancellationToken cancellationToken) 683private async Task<IAppHostAuxiliaryBackchannel?> ResolveExplicitConnectionForAvailableCommandsAsync(FileInfo appHostProjectFile, CancellationToken cancellationToken)
Commands\ResourceCommandHelper.cs (2)
32IAppHostAuxiliaryBackchannel connection, 64IAppHostAuxiliaryBackchannel connection,
Commands\StopCommand.cs (6)
233var connection = inScopeConnections[0].Connection!; 483private async Task<int> StopAppHostAsync(IAppHostAuxiliaryBackchannel connection, string appHostIdentifier, CancellationToken cancellationToken) 530private string GetSingleAppHostDisplayPath(IAppHostAuxiliaryBackchannel connection) 543private static string GetAppHostPath(IAppHostAuxiliaryBackchannel connection) 550private static FileInfo? GetAppHostFile(IAppHostAuxiliaryBackchannel connection) 575private 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)
67var matchingConnection = auxiliaryBackchannelMonitor.Connections
Projects\RunningInstanceManager.cs (1)
98public async Task<bool> StopAndMonitorAsync(IAppHostAuxiliaryBackchannel backchannel, CancellationToken cancellationToken)
Aspire.Cli.Tests (13)
Commands\TerminalCommandTests.cs (1)
658/// <see cref="IAppHostAuxiliaryBackchannel.GetTerminalInfoAsync"/>. All other calls
Mcp\AppHostConnectionSelectionLogicTests.cs (1)
46var selected = monitor.SelectedConnection;
Mcp\MockPackagingService.cs (4)
45public IEnumerable<IAppHostAuxiliaryBackchannel> Connections => []; 49public IAppHostAuxiliaryBackchannel? SelectedConnection => null; 53public async IAsyncEnumerable<IReadOnlyList<IAppHostAuxiliaryBackchannel>> WatchConnectionsAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 59public IReadOnlyList<IAppHostAuxiliaryBackchannel> GetConnectionsForWorkingDirectory(DirectoryInfo workingDirectory)
TestServices\TestAuxiliaryBackchannelMonitor.cs (7)
13private readonly ConcurrentDictionary<string, IAppHostAuxiliaryBackchannel> _connectionsBySocketPath = new(StringComparers.FileSystemPath); 16public IEnumerable<IAppHostAuxiliaryBackchannel> Connections => 37public async IAsyncEnumerable<IReadOnlyList<IAppHostAuxiliaryBackchannel>> WatchConnectionsAsync([EnumeratorCancellation] CancellationToken cancellationToken = default) 54public IAppHostAuxiliaryBackchannel? SelectedConnection 61var connection = AuxiliaryBackchannelMonitor.SelectConnection(Connections, ref selectedAppHostPath); 67public IReadOnlyList<IAppHostAuxiliaryBackchannel> GetConnectionsForWorkingDirectory(DirectoryInfo workingDirectory) 74public void AddConnection(string socketPath, IAppHostAuxiliaryBackchannel connection)