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