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
54 references to IAppHostAuxiliaryBackchannel
aspire (41)
Backchannel\AppHostConnectionHelper.cs (3)
26public static async Task<IAppHostAuxiliaryBackchannel?> GetSelectedConnectionAsync( 47var selectedConnection = connections.FirstOrDefault(c => 86var fallback = connections
Backchannel\AppHostConnectionResolver.cs (2)
17public IAppHostAuxiliaryBackchannel? Connection { get; init; } 105IAppHostAuxiliaryBackchannel? selectedConnection = null;
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\LogsCommand.cs (4)
185IAppHostAuxiliaryBackchannel connection, 237IAppHostAuxiliaryBackchannel connection, 272IAppHostAuxiliaryBackchannel connection, 288IAppHostAuxiliaryBackchannel connection,
Commands\PsCommand.cs (3)
80List<IAppHostAuxiliaryBackchannel> connections; 131private async Task<List<AppHostDisplayInfo>> GatherAppHostInfosAsync(List<IAppHostAuxiliaryBackchannel> connections, CancellationToken cancellationToken) 135foreach (var connection in connections)
Commands\ResourceCommandHelper.cs (2)
30IAppHostAuxiliaryBackchannel connection, 53IAppHostAuxiliaryBackchannel connection,
Commands\ResourcesCommand.cs (2)
147private async Task<int> ExecuteSnapshotAsync(IAppHostAuxiliaryBackchannel connection, string? resourceName, OutputFormat format, CancellationToken cancellationToken) 189private async Task<int> ExecuteWatchAsync(IAppHostAuxiliaryBackchannel connection, string? resourceName, OutputFormat format, CancellationToken cancellationToken)
Commands\RunCommand.cs (3)
741async Task<IAppHostAuxiliaryBackchannel?> StartAndWaitForBackchannelAsync() 782var connection = _backchannelMonitor.GetConnectionsByHash(expectedHash).FirstOrDefault(); 805IAppHostAuxiliaryBackchannel? backchannel;
Commands\StopCommand.cs (2)
75var selectedConnection = result.Connection!; 216private Task<int> StopResourceAsync(IAppHostAuxiliaryBackchannel connection, string resourceName, CancellationToken cancellationToken)
Commands\WaitCommand.cs (2)
105var connection = result.Connection!; 111IAppHostAuxiliaryBackchannel 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)
60var 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>());