1 instantiation of Service
Aspire.Hosting (1)
Dcp\Model\Service.cs (1)
79var s = new Service(new ServiceSpec());
71 references to Service
Aspire.Hosting (37)
Dcp\AppResource.cs (6)
40public Service Service => (Service)DcpResource; 41public ServiceAppResource(Service service) : base(service) 66public Service Service => (Service)DcpResource; 78public ServiceWithModelResource(IResource modelResource, Service service, EndpointAnnotation sba) : base(modelResource, service)
Dcp\DcpExecutor.cs (25)
171Task.Run(() => CreateAllDcpObjectsAsync<Service>(cancellationToken), cancellationToken), 175var proxiedWithNoAddress = _appResources.Where(r => r.DcpResource is Service { }).Select(r => (Service)r.DcpResource) 314Task.Run(() => WatchKubernetesResourceAsync<Service>(ProcessServiceChange)), 703private async Task ProcessServiceChange(WatchEventType watchEventType, Service service) 780private async Task UpdateWithEffectiveAddressInfo(IEnumerable<Service> services, CancellationToken cancellationToken, TimeSpan? timeout = null) 782List<Service> needAddressAllocated = new(services.Where(s => !s.HasCompleteAddress)); 798var serviceChangeEnumerator = _kubernetesService.WatchAsync<Service>(cancellationToken: attemptCancellationToken); 807var srvResource = needAddressAllocated.FirstOrDefault(sr => sr.Metadata.Name == updated.Metadata.Name); 829foreach (var sar in needAddressAllocated) 831var dcpSvc = await _kubernetesService.GetAsync<Service>(sar.Metadata.Name, cancellationToken: cancellationToken).ConfigureAwait(false); 861var tunnelServices = _appResources.Where(r => r.DcpResource is Service { }).Select(r => (Service)r.DcpResource) 880var containerServices = _appResources.Where(r => r.DcpResource is Service { }).Select(r => ( 881Service: r.DcpResource as Service, 888var primaryService = _appResources.OfType<ServiceWithModelResource>().Select(sar => sar.Service) 956var svc = (Service)sp.DcpResource; 1011Service: r.DcpResource as Service, 1115var svc = Service.Create(serviceName); 1226var svc = Service.Create(serviceName); 2447.Where(r => r.DcpResource is not Service)
Dcp\DcpResourceState.cs (1)
15public readonly ConcurrentDictionary<string, Service> ServicesMap = [];
Dcp\Model\GroupVersion.cs (1)
39Schema.Add<Service>(ServiceKind, "services");
Dcp\Model\Service.cs (3)
77public static Service Create(string name) 79var s = new Service(new ServiceSpec()); 95public void ApplyAddressInfoFrom(Service other)
Dcp\ResourceSnapshotBuilder.cs (1)
294var endpointOwnerEndpoint = _resourceState.AppResources.OfType<ServiceWithModelResource>()
Aspire.Hosting.Tests (34)
Dcp\DcpExecutorTests.cs (32)
286var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 318var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 350var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 383var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 439var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 473var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 507var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 912var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA-NoPortNoTargetPort"); 957var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA-PortSetNoTargetPort"); 990var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 1025var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 1105var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 1141var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 1178var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 1215var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 2229.OfType<Service>() 2235var svc = svcs.Single();
Dcp\TestKubernetesService.cs (1)
71if (res is Service svc)
DistributedApplicationTests.cs (1)
1704var serviceList = await s.ListAsync<Service>().DefaultTimeout();