3 instantiations of CircuitId
Microsoft.AspNetCore.Components.Server (2)
Circuits\CircuitIdFactory.cs (2)
46return new CircuitId(Base64UrlTextEncoder.Encode(secret), Base64UrlTextEncoder.Encode(id)); 77circuitId = new CircuitId(text, Base64UrlTextEncoder.Encode(id));
Microsoft.AspNetCore.Components.Server.Tests (1)
Circuits\TestCircuitHost.cs (1)
66circuitId is null ? new CircuitId(Guid.NewGuid().ToString(), Guid.NewGuid().ToString()) : circuitId.Value,
114 references to CircuitId
Microsoft.AspNetCore.Components.Server (83)
CircuitDisconnectMiddleware.cs (5)
52private async Task<CircuitId?> GetCircuitIdAsync(HttpContext context) 67if (!CircuitIdFactory.TryParseCircuitId(text, out var circuitId)) 81private async Task TerminateCircuitGracefully(CircuitId circuitId) 92public static partial void CircuitTerminatingGracefully(ILogger logger, CircuitId circuitId); 95public static partial void CircuitTerminatedGracefully(ILogger logger, CircuitId circuitId);
Circuits\CircuitHost.cs (21)
46CircuitId circuitId, 96public CircuitId CircuitId { get; } 931public static partial void DisposeStarted(ILogger logger, CircuitId circuitId); 934public static partial void DisposeSucceeded(ILogger logger, CircuitId circuitId); 937public static partial void DisposeFailed(ILogger logger, CircuitId circuitId, Exception exception); 940public static partial void CircuitOpened(ILogger logger, CircuitId circuitId); 943public static partial void ConnectionUp(ILogger logger, CircuitId circuitId, string connectionId); 946public static partial void ConnectionDown(ILogger logger, CircuitId circuitId, string connectionId); 949public static partial void CircuitClosed(ILogger logger, CircuitId circuitId); 974public static partial void CircuitUnhandledException(ILogger logger, CircuitId circuitId, Exception exception); 977public static partial void CircuitTransmittingClientError(ILogger logger, CircuitId circuitId); 980public static partial void CircuitTransmittedClientErrorSuccess(ILogger logger, CircuitId circuitId); 983public static partial void CircuitTransmitErrorFailed(ILogger logger, CircuitId circuitId, Exception exception); 986public static partial void UnhandledExceptionClientDisconnected(ILogger logger, CircuitId circuitId, Exception exception); 1013public static partial void LocationChange(ILogger logger, string uri, CircuitId circuitId); 1016public static partial void LocationChangeSucceeded(ILogger logger, string uri, CircuitId circuitId); 1019public static partial void LocationChangeFailed(ILogger logger, string uri, CircuitId circuitId, Exception exception); 1022public static partial void LocationChanging(ILogger logger, string uri, CircuitId circuitId); 1025public static partial void OnRenderCompletedFailed(ILogger logger, long renderId, CircuitId circuitId, Exception e); 1070public static partial void LocationChangeFailedInCircuit(ILogger logger, string uri, CircuitId circuitId, Exception exception); 1073public static partial void FailedToSaveStateToClient(ILogger logger, CircuitId circuitId, Exception exception);
Circuits\CircuitId.cs (3)
18internal readonly struct CircuitId : IEquatable<CircuitId> 30public bool Equals(CircuitId other) 48return obj is CircuitId other ? Equals(other) : false;
Circuits\CircuitIdFactory.cs (2)
32public CircuitId CreateCircuitId() 49public bool TryParseCircuitId(string? text, out CircuitId circuitId)
Circuits\CircuitPersistenceManager.cs (1)
96public async Task<PersistedCircuitState> ResumeCircuitAsync(CircuitId circuitId, CancellationToken cancellation = default)
Circuits\CircuitRegistry.cs (23)
57ConnectedCircuits = new ConcurrentDictionary<CircuitId, CircuitHost>(); 70internal ConcurrentDictionary<CircuitId, CircuitHost> ConnectedCircuits { get; } 116var circuitId = circuitHost.CircuitId; 172public virtual async Task<CircuitHost> ConnectAsync(CircuitId circuitId, ISingleClientProxy clientProxy, string connectionId, CancellationToken cancellationToken) 231protected virtual (CircuitHost circuitHost, bool previouslyConnected) ConnectCore(CircuitId circuitId, ISingleClientProxy clientProxy, string connectionId) 340var circuitId = circuitHost.CircuitId; 379public ValueTask TerminateAsync(CircuitId circuitId) 449public static partial void CircuitConnectStarted(ILogger logger, CircuitId circuitHost); 452public static partial void FailedToFindCircuit(ILogger logger, CircuitId circuitHost); 455public static partial void ConnectingToActiveCircuit(ILogger logger, CircuitId circuitId, string connectionId); 458public static partial void ConnectingToDisconnectedCircuit(ILogger logger, CircuitId circuitId, string connectionId); 461public static partial void FailedToReconnectToCircuit(ILogger logger, CircuitId circuitId, Exception exception = null); 464public static partial void CircuitDisconnectStarted(ILogger logger, CircuitId circuitId, string connectionId); 467public static partial void CircuitNotActive(ILogger logger, CircuitId circuitId); 470public static partial void CircuitConnectedToDifferentConnection(ILogger logger, CircuitId circuitId, string connectionId); 473public static partial void CircuitMarkedDisconnected(ILogger logger, CircuitId circuitId); 476public static partial void CircuitEvicted(ILogger logger, CircuitId circuitId, EvictionReason evictionReason); 479public static partial void CircuitDisconnectedPermanently(ILogger logger, CircuitId circuitId); 482public static partial void CircuitExceptionHandlerFailed(ILogger logger, CircuitId circuitId, Exception exception); 485public static partial void ReconnectionSucceeded(ILogger logger, CircuitId circuitId); 488public static partial void PersistedCircuitStateDiscarded(ILogger logger, CircuitId circuitId); 491public static partial void CircuitPauseStarted(ILogger logger, CircuitId circuitId, string connectionId); 494public static partial void CircuitPauseFailed(ILogger logger, CircuitId circuitId, string connectionId);
Circuits\DefaultInMemoryCircuitPersistenceProvider.cs (10)
44public Task PersistCircuitAsync(CircuitId circuitId, PersistedCircuitState persistedCircuitState, CancellationToken cancellation = default) 56private void PersistCore(CircuitId circuitId, PersistedCircuitState persistedCircuitState) 99public Task<PersistedCircuitState> RestoreCircuitAsync(CircuitId circuitId, CancellationToken cancellation = default) 116private PersistedCircuitState RestoreCore(CircuitId circuitId) 147public CircuitId CircuitId { get; set; } 153public static partial void CircuitStateEvicted(ILogger logger, CircuitId circuitId, EvictionReason reason); 156public static partial void CircuitResumeStarted(ILogger logger, CircuitId circuitId); 159public static partial void FailedToFindCircuitState(ILogger logger, CircuitId circuitId); 162public static partial void CircuitStateFound(ILogger logger, CircuitId circuitId); 168public static partial void CircuitPauseStarted(ILogger logger, CircuitId circuitId);
Circuits\HybridCacheCircuitPersistenceProvider.cs (11)
44public async Task PersistCircuitAsync(CircuitId circuitId, PersistedCircuitState persistedCircuitState, CancellationToken cancellation = default) 63public async Task<PersistedCircuitState> RestoreCircuitAsync(CircuitId circuitId, CancellationToken cancellation = default) 102public static partial void CircuitStateEvicted(ILogger logger, CircuitId circuitId, string reason); 105public static partial void CircuitResumeStarted(ILogger logger, CircuitId circuitId); 108public static partial void FailedToFindCircuitState(ILogger logger, CircuitId circuitId); 111public static partial void CircuitStateFound(ILogger logger, CircuitId circuitId); 117public static partial void CircuitPauseStarted(ILogger logger, CircuitId circuitId); 120public static partial void ExceptionPersistingCircuit(ILogger logger, CircuitId circuitId, Exception exception); 123public static partial void ExceptionRestoringCircuit(ILogger logger, CircuitId circuitId, Exception exception); 126public static partial void ExceptionDuringExpiration(ILogger logger, CircuitId circuitId, Exception exception); 129public static partial void ExceptionRemovingExpiredCircuit(ILogger logger, CircuitId circuitId, Exception exception);
Circuits\ICircuitPersistenceProvider.cs (2)
9Task PersistCircuitAsync(CircuitId circuitId, PersistedCircuitState persistedCircuitState, CancellationToken cancellation = default); 11Task<PersistedCircuitState> RestoreCircuitAsync(CircuitId circuitId, CancellationToken cancellation = default);
ComponentHub.cs (5)
214if (!_circuitIdFactory.TryParseCircuitId(circuitIdSecret, out var circuitId)) 279if (!_circuitIdFactory.TryParseCircuitId(circuitIdSecret, out var circuitId)) 590public static partial void CircuitAlreadyInitialized(ILogger logger, CircuitId circuitId); 605private static partial void CreatedCircuitCore(ILogger logger, CircuitId circuitId, string circuitIdSecret, string connectionId); 607public static void CreatedCircuit(ILogger logger, CircuitId circuitId, string circuitSecret, string connectionId)
Microsoft.AspNetCore.Components.Server.Tests (31)
CircuitDisconnectMiddlewareTest.cs (3)
143var circuitId = circuitIdFactory.CreateCircuitId(); 177var circuitId = circuitIdFactory.CreateCircuitId(); 215var circuitId = circuitIdFactory.CreateCircuitId();
Circuits\CircuitIdFactoryTest.cs (4)
16var secret = factory.CreateCircuitId(); 44var id = factory.CreateCircuitId(); 47var isValid = factory.TryParseCircuitId(id.Secret, out var parsed); 74var secret = factory.CreateCircuitId();
Circuits\CircuitPersistenceManagerTest.cs (5)
247.Setup(p => p.PersistCircuitAsync(It.IsAny<CircuitId>(), It.IsAny<PersistedCircuitState>(), It.IsAny<CancellationToken>())) 278It.IsAny<CircuitId>(), 404var circuitId = new CircuitIdFactory(dataProtectionProvider).CreateCircuitId(); 568public Task<PersistedCircuitState> RestoreCircuitAsync(CircuitId circuitId, CancellationToken cancellation = default) 573public Task PersistCircuitAsync(CircuitId circuitId, PersistedCircuitState state, CancellationToken cancellation = default)
Circuits\CircuitRegistryTest.cs (3)
585protected override (CircuitHost, bool) ConnectCore(CircuitId circuitId, ISingleClientProxy clientProxy, string connectionId) 631public async Task PersistCircuitAsync(CircuitId circuitId, PersistedCircuitState persistedCircuitState, CancellationToken cancellation = default) 641public Task<PersistedCircuitState> RestoreCircuitAsync(CircuitId circuitId, CancellationToken cancellation = default)
Circuits\ComponentHubTest.cs (2)
164providerMock.Setup(m => m.RestoreCircuitAsync(It.IsAny<CircuitId>(), It.IsAny<CancellationToken>())) 264providerMock.Setup(m => m.RestoreCircuitAsync(It.IsAny<CircuitId>(), It.IsAny<CancellationToken>()))
Circuits\DefaultInMemoryCircuitPersistenceProviderTest.cs (9)
19var circuitId = TestCircuitIdFactory.CreateTestFactory().CreateCircuitId(); 36var circuitId = TestCircuitIdFactory.CreateTestFactory().CreateCircuitId(); 51var circuitId = TestCircuitIdFactory.CreateTestFactory().CreateCircuitId(); 75var circuitId = TestCircuitIdFactory.CreateTestFactory().CreateCircuitId(); 127var circuitId1 = factory.CreateCircuitId(); 128var circuitId2 = factory.CreateCircuitId(); 129var circuitId3 = factory.CreateCircuitId(); 130var circuitIds = new Dictionary<string, CircuitId> 151var evictedId = circuitIds[evicted];
Circuits\HybridCacheCircuitPersistenceProviderTest.cs (3)
21var circuitId = TestCircuitIdFactory.CreateTestFactory().CreateCircuitId(); 47var circuitId = TestCircuitIdFactory.CreateTestFactory().CreateCircuitId(); 63var circuitId = TestCircuitIdFactory.CreateTestFactory().CreateCircuitId();
Circuits\TestCircuitHost.cs (2)
20private TestCircuitHost(CircuitId circuitId, AsyncServiceScope scope, CircuitOptions options, CircuitClientProxy client, RemoteRenderer renderer, IReadOnlyList<ComponentDescriptor> descriptors, RemoteJSRuntime jsRuntime, RemoteNavigationManager navigationManager, CircuitHandler[] circuitHandlers, CircuitMetrics circuitMetrics, CircuitActivitySource circuitActivitySource, ILogger logger) 26CircuitId? circuitId = null,