1 write to _snapshotBuilder
Aspire.Hosting (1)
Dcp\DcpExecutor.cs (1)
131_snapshotBuilder = new(_resourceState);
9 references to _snapshotBuilder
Aspire.Hosting (9)
Dcp\DcpExecutor.cs (9)
375Task.Run(() => WatchKubernetesResourceAsync<Executable>((t, r) => ProcessResourceChange(t, r, _resourceState.ExecutablesMap, Model.Dcp.ExecutableKind, (e, s) => _snapshotBuilder.ToSnapshot(e, s)))), 376Task.Run(() => WatchKubernetesResourceAsync<Container>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainersMap, Model.Dcp.ContainerKind, (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 377Task.Run(() => WatchKubernetesResourceAsync<ContainerExec>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainerExecsMap, Model.Dcp.ContainerExecKind, (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 802return _snapshotBuilder.ToSnapshot(container, s); 806return _snapshotBuilder.ToSnapshot(exe, s); 810return _snapshotBuilder.ToSnapshot(containerExec, s); 1611Executable exe => s => _snapshotBuilder.ToSnapshot(exe, s), 1612ContainerExec exe => s => _snapshotBuilder.ToSnapshot(exe, s), 2041await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResourceName, new ResourceStatus(null, null, null), s => _snapshotBuilder.ToSnapshot((Container)cr.DcpResource, s))).ConfigureAwait(false);