2 types derived from WorkloadPlan
Aspire.Hosting.Native.Core (2)
Runtime\ResourceWorkload.cs (2)
18: WorkloadPlan 31: WorkloadPlan
62 references to WorkloadPlan
Aspire.Hosting.Native.Core (44)
Model\DeclaredWorkload.cs (4)
10internal sealed record DeclaredWorkload(WorkloadPlan Plan, SymbolicWorkloadBindings Bindings, 13public static DeclaredWorkload Create(WorkloadPlan plan) 38private static bool EquivalentPlan(WorkloadPlan left, WorkloadPlan right) =>
Runtime\DeclarativeApplication.cs (4)
261WorkloadPlan Resolve(DeclaredLifecycleCommand command) => 270var plan = Resolve(command); 288var plan = Resolve(health); 380private async Task<bool> RunLifecycleCommandAsync(WorkloadPlan plan, CancellationToken cancellationToken)
Runtime\ProviderLifecycle.cs (3)
39private readonly Func<WorkloadPlan, CancellationToken, Task<bool>> _execute; 46Func<WorkloadPlan, CancellationToken, Task<bool>> execute, Action<LogStream, string> log, 78var plan = SymbolicWorkloadBindings.Copy(template, environment, arguments.ToImmutable());
Runtime\ResourceWorkload.cs (9)
74Task<IWorkloadLease> StartAsync(WorkloadIdentity identity, WorkloadPlan plan, CancellationToken cancellationToken); 80Task<IWorkloadPreparation> PrepareAsync(WorkloadIdentity identity, WorkloadPlan template, CancellationToken cancellationToken); 86Task StartAsync(WorkloadPlan plan, CancellationToken cancellationToken); 101public Task<IWorkloadLease> StartAsync(WorkloadIdentity identity, WorkloadPlan plan, CancellationToken cancellationToken) => 108Func<WorkloadPlan> resolvePlan, 117WorkloadPlan? allocationTemplate, 121public ResourceWorkload(WorkloadIdentity identity, Func<WorkloadPlan> resolvePlan, IWorkloadExecutor executor, 129public ResourceWorkload(WorkloadIdentity identity, WorkloadPlan plan, IWorkloadExecutor executor, 279var plan = resolvePlan();
Runtime\RuntimeGeneration.cs (16)
270internal Task<WorkloadEndpoint> StartWorkload(Guid resourceId, WorkloadPlan plan) => 273internal Task<WorkloadEndpoint> StartSymbolicWorkload(Guid resourceId, long revision, WorkloadPlan template, 286private void ValidateSymbolicBindings(Guid resourceId, long revision, WorkloadPlan template, 314private WorkloadPlan ResolveSymbolicWorkload(Guid resourceId, long revision, WorkloadPlan template, 343var plan = SymbolicWorkloadBindings.Copy(template, environment, arguments.ToImmutable()); 374private Task<WorkloadEndpoint> StartWorkloadCore(Guid resourceId, WorkloadPlan plan, Func<WorkloadPlan> resolvePlan) 467internal Task<WorkloadEndpoint> ReplaceWorkloadAsync(Guid resourceId, long revision, WorkloadPlan plan) => 470internal Task<WorkloadEndpoint> ReplaceSymbolicWorkloadAsync(Guid resourceId, long revision, WorkloadPlan template, 483private async Task<WorkloadEndpoint> ReplaceWorkloadCoreAsync(Guid resourceId, long revision, WorkloadPlan plan, Func<WorkloadPlan> resolvePlan) 1111public Task<WorkloadEndpoint> StartWorkload(WorkloadPlan plan) 1117public Task<WorkloadEndpoint> StartSymbolicWorkload(long revision, WorkloadPlan template, 1124public Task<WorkloadEndpoint> ReplaceSymbolicWorkloadAsync(long revision, WorkloadPlan template, 1138public Task<WorkloadEndpoint> ReplaceWorkloadAsync(long revision, WorkloadPlan plan)
Runtime\SymbolicWorkload.cs (3)
15public void Validate(WorkloadPlan template) 33public static WorkloadPlan Copy(WorkloadPlan template, ImmutableArray<WorkloadEnvironment> environment,
Runtime\WorkloadDefinition.cs (5)
22public static void Validate(WorkloadPlan plan) => ValidateCore(plan, requireLocalPaths: true); 25public static void ValidateDeclaration(WorkloadPlan plan) => ValidateCore(plan, requireLocalPaths: false); 27private static void ValidateCore(WorkloadPlan plan, bool requireLocalPaths) 45private static void ValidateEnvironmentAndArguments(WorkloadPlan plan) 58private static void ValidateEndpoints(WorkloadPlan plan)
Aspire.Hosting.Native.Core.Tests (7)
TestServices\WorkloadTestExecutor.cs (7)
15public ConcurrentQueue<WorkloadPlan> Plans { get; } = new(); 28public Func<WorkloadPlan, WorkloadStatus>? StatusForPlan { get; init; } 33public async Task<IWorkloadPreparation> PrepareAsync(WorkloadIdentity identity, WorkloadPlan template, CancellationToken cancellationToken) 45public async Task<IWorkloadLease> StartAsync(WorkloadIdentity identity, WorkloadPlan plan, CancellationToken cancellationToken) 66private sealed class Lease(WorkloadTestExecutor executor, WorkloadIdentity identity, WorkloadPlan plan) : IWorkloadLease 94private sealed class Preparation(WorkloadTestExecutor executor, WorkloadIdentity identity, WorkloadPlan template) : IWorkloadPreparation 102public async Task StartAsync(WorkloadPlan plan, CancellationToken cancellationToken)
Aspire.Hosting.Native.Server (11)
Api\DeclarativeWorkloadApi.cs (5)
92var plan = SymbolicWorkloadBindings.Copy(current.Plan, current.Plan.Environment, current.Plan.Arguments.Add("")); 115var plan = current.Plan switch 117ContainerWorkload container => (WorkloadPlan)(container with { Ports = ports }), 138var plan = current.Plan switch 140ContainerWorkload container => (WorkloadPlan)(container with { Ports = ports }),
Api\PublishingApi.cs (1)
33var plan = workload?.Plan;
Dcp\DcpWorkloadExecutor.cs (5)
30public Task<IWorkloadLease> StartAsync(WorkloadIdentity identity, WorkloadPlan plan, CancellationToken cancellationToken) => 33public async Task<IWorkloadPreparation> PrepareAsync(WorkloadIdentity identity, WorkloadPlan template, CancellationToken cancellationToken) 92private async Task<IWorkloadLease> StartCoreAsync(WorkloadIdentity identity, WorkloadPlan plan, 242private sealed class Lease(DcpWorkloadExecutor executor, WorkloadIdentity identity, WorkloadPlan template, 253public async Task StartAsync(WorkloadPlan plan, CancellationToken cancellationToken)