2 implementations of IAppHostAuxiliaryBackchannel
aspire (1)
Backchannel\AppHostAuxiliaryBackchannel.cs (1)
19internal sealed class AppHostAuxiliaryBackchannel : IAppHostAuxiliaryBackchannel
Aspire.Cli.Tests (1)
TestServices\TestAppHostAuxiliaryBackchannel.cs (1)
14internal sealed class TestAppHostAuxiliaryBackchannel : IAppHostAuxiliaryBackchannel
56 references to IAppHostAuxiliaryBackchannel
aspire (43)
Backchannel\AppHostConnectionHelper.cs (3)
26public static async Task<IAppHostAuxiliaryBackchannel?> GetSelectedConnectionAsync( 47var selectedConnection = connections.FirstOrDefault(c => 86var fallback = connections
Backchannel\AppHostConnectionResolver.cs (5)
19public IAppHostAuxiliaryBackchannel? Connection { get; init; } 133IAppHostAuxiliaryBackchannel? selectedConnection = null; 171private async Task<IAppHostAuxiliaryBackchannel?> PromptForAppHostSelectionAsync( 172List<IAppHostAuxiliaryBackchannel> candidateConnections, 196var selectedConnection = choices.FirstOrDefault(c => c.Display == selectedDisplay).Connection;
Backchannel\AuxiliaryBackchannelMonitor.cs (6)
40public IEnumerable<IAppHostAuxiliaryBackchannel> Connections => 48public IEnumerable<IAppHostAuxiliaryBackchannel> GetConnectionsByHash(string hash) => 59public IAppHostAuxiliaryBackchannel? SelectedConnection 73var selectedConnection = connections.FirstOrDefault(c => 102public IReadOnlyList<IAppHostAuxiliaryBackchannel> GetConnectionsForWorkingDirectory(DirectoryInfo workingDirectory) 486private static async Task DisconnectAsync(IAppHostAuxiliaryBackchannel connection)
Backchannel\IAuxiliaryBackchannelMonitor.cs (4)
14IEnumerable<IAppHostAuxiliaryBackchannel> Connections { get; } 21IEnumerable<IAppHostAuxiliaryBackchannel> GetConnectionsByHash(string hash); 32IAppHostAuxiliaryBackchannel? SelectedConnection { get; } 44IReadOnlyList<IAppHostAuxiliaryBackchannel> GetConnectionsForWorkingDirectory(DirectoryInfo workingDirectory);
Commands\AgentMcpCommand.cs (2)
214var connection = await GetSelectedConnectionAsync(cancellationToken).ConfigureAwait(false); 256private Task<IAppHostAuxiliaryBackchannel?> GetSelectedConnectionAsync(CancellationToken cancellationToken)
Commands\AppHostLauncher.cs (2)
206private record LaunchResult(Process? ChildProcess, IAppHostAuxiliaryBackchannel? Backchannel, DashboardUrlsState? DashboardUrls, bool ChildExitedEarly, int ChildExitCode); 247var connection = backchannelMonitor.GetConnectionsByHash(expectedHash).FirstOrDefault();
Commands\DescribeCommand.cs (2)
136var connection = result.Connection!; 194private async Task<int> ExecuteWatchAsync(IAppHostAuxiliaryBackchannel connection, IReadOnlyList<ResourceSnapshot> initialSnapshots, string? dashboardBaseUrl, string? resourceName, OutputFormat format, CancellationToken cancellationToken)
Commands\LogsCommand.cs (4)
162var connection = result.Connection!; 201IAppHostAuxiliaryBackchannel connection, 250IAppHostAuxiliaryBackchannel connection, 294IAppHostAuxiliaryBackchannel connection,
Commands\PsCommand.cs (2)
149private async Task<List<AppHostDisplayInfo>> GatherAppHostInfosAsync(List<IAppHostAuxiliaryBackchannel> connections, bool includeResources, CancellationToken cancellationToken) 153foreach (var connection in connections)
Commands\ResourceCommandHelper.cs (2)
30IAppHostAuxiliaryBackchannel connection, 53IAppHostAuxiliaryBackchannel connection,
Commands\StopCommand.cs (3)
114var connection = inScopeConnections[0].Connection!; 164var connection = connectionResult.Connection!; 181private async Task<int> StopAppHostAsync(IAppHostAuxiliaryBackchannel connection, CancellationToken cancellationToken)
Commands\WaitCommand.cs (2)
103var connection = result.Connection!; 109IAppHostAuxiliaryBackchannel connection,
Mcp\McpResourceToolRefreshService.cs (1)
83var connection = await AppHostConnectionHelper.GetSelectedConnectionAsync(_auxiliaryBackchannelMonitor, _logger, cancellationToken).ConfigureAwait(false);
Mcp\Tools\ExecuteResourceCommandTool.cs (1)
62var connection = await AppHostConnectionHelper.GetSelectedConnectionAsync(auxiliaryBackchannelMonitor, logger, cancellationToken).ConfigureAwait(false);
Mcp\Tools\ListConsoleLogsTool.cs (1)
55var connection = await AppHostConnectionHelper.GetSelectedConnectionAsync(auxiliaryBackchannelMonitor, logger, cancellationToken).ConfigureAwait(false);
Mcp\Tools\ListResourcesTool.cs (1)
59var connection = await AppHostConnectionHelper.GetSelectedConnectionAsync(auxiliaryBackchannelMonitor, logger, cancellationToken).ConfigureAwait(false);
Mcp\Tools\McpToolHelpers.cs (1)
14var connection = await AppHostConnectionHelper.GetSelectedConnectionAsync(auxiliaryBackchannelMonitor, logger, cancellationToken).ConfigureAwait(false);
Mcp\Tools\SelectAppHostTool.cs (1)
70var matchingConnection = auxiliaryBackchannelMonitor.Connections
Aspire.Cli.Tests (13)
Mcp\AppHostConnectionSelectionLogicTests.cs (1)
46var selected = monitor.SelectedConnection;
Mcp\MockPackagingService.cs (4)
66public IEnumerable<IAppHostAuxiliaryBackchannel> Connections => []; 68public IEnumerable<IAppHostAuxiliaryBackchannel> GetConnectionsByHash(string hash) => []; 72public IAppHostAuxiliaryBackchannel? SelectedConnection => null; 76public IReadOnlyList<IAppHostAuxiliaryBackchannel> GetConnectionsForWorkingDirectory(DirectoryInfo workingDirectory)
TestServices\TestAuxiliaryBackchannelMonitor.cs (8)
12private readonly ConcurrentDictionary<string, ConcurrentDictionary<string, IAppHostAuxiliaryBackchannel>> _connectionsByHash = new(); 14public IEnumerable<IAppHostAuxiliaryBackchannel> Connections => 17public IEnumerable<IAppHostAuxiliaryBackchannel> GetConnectionsByHash(string hash) => 36public IAppHostAuxiliaryBackchannel? SelectedConnection 50var selectedConnection = connections.FirstOrDefault(c => 76public IReadOnlyList<IAppHostAuxiliaryBackchannel> GetConnectionsForWorkingDirectory(DirectoryInfo workingDirectory) 99public void AddConnection(string hash, string socketPath, IAppHostAuxiliaryBackchannel connection) 101var connectionsDict = _connectionsByHash.GetOrAdd(hash, _ => new ConcurrentDictionary<string, IAppHostAuxiliaryBackchannel>());