6 instantiations of WorkloadEndpoint
Aspire.Hosting.Native.Core.Tests (2)
TestServices\WorkloadTestExecutor.cs (2)
68public WorkloadEndpoint Endpoint { get; } = new("test-instance", 98public WorkloadEndpoint Endpoint => _lease?.Endpoint ?? new("",
Aspire.Hosting.Native.Server (4)
Dcp\DcpWorkloadExecutor.cs (4)
71lease.Endpoint = new("", endpoints.ToImmutable()); 190lease.Endpoint = new WorkloadEndpoint(System.Net.IPAddress.Loopback.ToString(), 0, instanceId); 207lease.Endpoint = new WorkloadEndpoint(instanceId, endpoints.ToImmutable()); 251public WorkloadEndpoint Endpoint { get; set; } = new(System.Net.IPAddress.Loopback.ToString(), 0, "");
34 references to WorkloadEndpoint
Aspire.Hosting.Native.Core (26)
Runtime\DeclarativeApplication.cs (4)
87List<Task<WorkloadEndpoint>> starts = []; 189var starts = new List<Task<WorkloadEndpoint>>(); 221Func<WorkloadEndpoint, CancellationToken, Task> Allocated, Func<Task> Retire) CreateLifecycle(Guid resourceId) 276async Task Allocated(WorkloadEndpoint endpoint, CancellationToken cancellationToken)
Runtime\ResourceWorkload.cs (8)
92WorkloadEndpoint Endpoint { get; } 112Action<ResourceState, WorkloadEndpoint?> publish, 115Func<WorkloadEndpoint, CancellationToken, Task> allocated, 118Action<WorkloadEndpoint>? publishAllocation, 123Action<ResourceState, WorkloadEndpoint?> publish, Action<LogStream, string> log) 131Action<ResourceState, WorkloadEndpoint?> publish, Action<LogStream, string> log) 137private readonly TaskCompletionSource<WorkloadEndpoint> _ready = new(TaskCreationOptions.RunContinuationsAsynchronously); 244public Task<WorkloadEndpoint> Start()
Runtime\RuntimeGeneration.cs (14)
270internal Task<WorkloadEndpoint> StartWorkload(Guid resourceId, WorkloadPlan plan) => 273internal Task<WorkloadEndpoint> StartSymbolicWorkload(Guid resourceId, long revision, WorkloadPlan template, 374private Task<WorkloadEndpoint> StartWorkloadCore(Guid resourceId, WorkloadPlan plan, Func<WorkloadPlan> resolvePlan) 405private void PublishAllocation(Guid resourceId, WorkloadEndpoint endpoint) 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) 513Task<WorkloadEndpoint> started; 565private void PublishWorkload(Guid resourceId, ResourceState state, WorkloadEndpoint? endpoint) 1072public WorkloadEndpoint? Allocation { get; set; } 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)
Aspire.Hosting.Native.Core.Tests (2)
TestServices\WorkloadTestExecutor.cs (2)
68public WorkloadEndpoint Endpoint { get; } = new("test-instance", 98public WorkloadEndpoint Endpoint => _lease?.Endpoint ?? new("",
Aspire.Hosting.Native.Server (6)
Api\RuntimeApi.cs (4)
147var endpoint = await owner.StartWorkload(ContainerPlan(container)).ConfigureAwait(false); 156var endpoint = await owner.ReplaceWorkloadAsync(revision, ContainerPlan(container)).ConfigureAwait(false); 179var endpoint = await owner.StartWorkload(ExecutablePlan(executable)).ConfigureAwait(false); 188var endpoint = await owner.ReplaceWorkloadAsync(revision, ExecutablePlan(executable)).ConfigureAwait(false);
Api\WorkloadApi.cs (1)
153private static WorkloadAllocation CopyAllocation(WorkloadEndpoint allocation) => new()
Dcp\DcpWorkloadExecutor.cs (1)
251public WorkloadEndpoint Endpoint { get; set; } = new(System.Net.IPAddress.Loopback.ToString(), 0, "");