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
52 references to IAppHostAuxiliaryBackchannel
aspire (39)
Backchannel\AppHostConnectionHelper.cs (3)
26public static async Task<IAppHostAuxiliaryBackchannel?> GetSelectedConnectionAsync( 47var selectedConnection = connections.FirstOrDefault(c => 86var fallback = connections
Backchannel\AppHostConnectionResolver.cs (2)
16public IAppHostAuxiliaryBackchannel? Connection { get; init; } 104IAppHostAuxiliaryBackchannel? 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; } 39IReadOnlyList<IAppHostAuxiliaryBackchannel> GetConnectionsForWorkingDirectory(DirectoryInfo workingDirectory);
Commands\AgentMcpCommand.cs (4)
234var connection = await GetSelectedConnectionAsync(cancellationToken).ConfigureAwait(false); 277var connection = await GetSelectedConnectionAsync(cancellationToken).ConfigureAwait(false); 350var connection = await GetSelectedConnectionAsync(cancellationToken).ConfigureAwait(false); 410private 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)
739async Task<IAppHostAuxiliaryBackchannel?> StartAndWaitForBackchannelAsync() 800var connection = _backchannelMonitor.GetConnectionsByHash(expectedHash).FirstOrDefault(); 823IAppHostAuxiliaryBackchannel? backchannel;
Commands\StopCommand.cs (2)
75var selectedConnection = result.Connection!; 216private Task<int> StopResourceAsync(IAppHostAuxiliaryBackchannel connection, string resourceName, CancellationToken cancellationToken)
Mcp\Tools\ExecuteResourceCommandTool.cs (1)
64var connection = await AppHostConnectionHelper.GetSelectedConnectionAsync(auxiliaryBackchannelMonitor, logger, cancellationToken).ConfigureAwait(false);
Mcp\Tools\ListConsoleLogsTool.cs (1)
56var connection = await AppHostConnectionHelper.GetSelectedConnectionAsync(auxiliaryBackchannelMonitor, logger, cancellationToken).ConfigureAwait(false);
Mcp\Tools\ListResourcesTool.cs (1)
64var connection = await AppHostConnectionHelper.GetSelectedConnectionAsync(auxiliaryBackchannelMonitor, logger, cancellationToken).ConfigureAwait(false);
Mcp\Tools\SelectAppHostTool.cs (1)
72var matchingConnection = auxiliaryBackchannelMonitor.Connections
Aspire.Cli.Tests (13)
Mcp\AppHostConnectionSelectionLogicTests.cs (1)
46var selected = monitor.SelectedConnection;
Mcp\MockPackagingService.cs (4)
64public IEnumerable<IAppHostAuxiliaryBackchannel> Connections => []; 66public IEnumerable<IAppHostAuxiliaryBackchannel> GetConnectionsByHash(string hash) => []; 70public IAppHostAuxiliaryBackchannel? SelectedConnection => null; 74public 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>());