2 instantiations of ResourceWorkload
Aspire.Hosting.Native.Core (1)
Runtime\RuntimeGeneration.cs (1)
386var workload = new ResourceWorkload(new WorkloadIdentity(GenerationId, resourceId), resolvePlan, executor, options,
Aspire.Hosting.Native.Core.Tests (1)
DcpWorkloadCleanupTests.cs (1)
234using var workload = new ResourceWorkload(new(Guid.NewGuid(), Guid.NewGuid()),
13 references to ResourceWorkload
Aspire.Hosting.Native.Core (12)
Runtime\DeclarativeApplication.cs (4)
17private static async Task RetireDeclaredWorkloadsAsync(Dictionary<Guid, ResourceWorkload> workloads, 125var stopping = new Dictionary<Guid, ResourceWorkload>(); 163if (_workloads.TryGetValue(id, out var previous)) 195if (stopping.TryGetValue(id, out var previous))
Runtime\RuntimeGeneration.cs (8)
19private readonly Dictionary<Guid, ResourceWorkload> _workloads = []; 20private readonly List<ResourceWorkload> _retiredWorkloads = []; 144var removedWorkloads = new Dictionary<Guid, ResourceWorkload>(); 148if (_workloads.Remove(removed.Declaration.Handle.ResourceId, out var workload)) 386var workload = new ResourceWorkload(new WorkloadIdentity(GenerationId, resourceId), resolvePlan, executor, options, 486ResourceWorkload previous; 939if (_workloads.TryGetValue(resourceId, out var workload)) 976foreach (var workload in _workloads.Where(pair => !_declaredOwners.Contains(pair.Key)).Select(pair => pair.Value).Concat(_retiredWorkloads))
Aspire.Hosting.Native.Core.Tests (1)
DcpWorkloadCleanupTests.cs (1)
234using var workload = new ResourceWorkload(new(Guid.NewGuid(), Guid.NewGuid()),