79var s = new Service(new ServiceSpec());

82internal sealed class ServiceWithModelResource : RenderedModelResource<Service> 84public Service Service => DcpResource; 96public ServiceWithModelResource(IResource modelResource, Service service, EndpointAnnotation sba) : base(modelResource, service)

45public required AppResource<Service> ServiceResource { get; init; } 184var service = Service.Create(serviceName); 217ServiceResource = new AppResource<Service>(service),

187var createServices = Task.Run(() => CreateAllDcpObjectsAsync<Service>(ct), ct); 193var proxiedWithNoAddress = _appResources.Get().OfType<AppResource<Service>>().Select(r => r.DcpResource) 352Task IDcpObjectFactory.UpdateWithEffectiveAddressInfo(IEnumerable<Service> services, CancellationToken cancellationToken, TimeSpan? timeout) 438private async Task UpdateWithEffectiveAddressInfo(IEnumerable<Service> services, CancellationToken cancellationToken, TimeSpan? timeout = null) 470foreach (var sar in needAddressAllocated) 488var containerServices = _appResources.Get().OfType<AppResource<Service>>().Select(r => ( 496var primaryService = _appResources.Get().OfType<ServiceWithModelResource>().Select(sar => sar.Service) 683var svc = Service.Create(serviceName); 1156.Where(r => r.DcpResource is not Service)

139internal static void ApplyServiceAddressToEndpoint(Service observedService, IEnumerable<IAppResource> appResources) 169var svc = sp.DcpResource; 287var tunnelServices = allAppResources.Get().OfType<AppResource<Service>>().Select(r => (

15public readonly ConcurrentDictionary<string, Service> ServicesMap = [];

158Task.Run(() => WatchKubernetesResourceAsync<Service>(ProcessServiceChange)), 935var service = endpoint.Spec.ServiceName is { } serviceName 974private async Task ProcessServiceChange(WatchEventType watchEventType, Service service)

42Task UpdateWithEffectiveAddressInfo(IEnumerable<Service> services, CancellationToken cancellationToken, TimeSpan? timeout = null);

39Schema.Add<Service>(ServiceKind, "services");

77public static Service Create(string name) 79var s = new Service(new ServiceSpec()); 95public void ApplyAddressInfoFrom(Service other)

345var endpointOwnerEndpoint = _resourceState.AppResources.OfType<ServiceWithModelResource>()

304var service = Assert.Single(kubernetesService.CreatedResources.OfType<Service>()); 995var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1033var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1064var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1129var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1180var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1209var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1244var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1287var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1325var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1356var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1387var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1419var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1446var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1563var fixedService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "FixedProgram"); 1564var dynamicService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "DynamicProgram"); 1607var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1646var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 1687var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1720var service = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1758var service = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 1805var persistentService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "PersistentProgram"); 1806var dynamicService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "DynamicProgram"); 1853var service = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "PersistentProgram"); 3955var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA-NoPortNoTargetPort"); 4002var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA-PortSetNoTargetPort"); 4036var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA"); 4073var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA"); 4118var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA"); 4151var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4186var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4223if (resource is Service service) 4235if (resource is Service) 4248if (resourceType == typeof(Service) && watchIndex == 1) 4255if (context.ResourceType != typeof(Service)) 4260var service = (Service)context.Resource; 4284if (context.ResourceType == typeof(Service)) 4286var service = (Service)context.Resource; 4315var service = Assert.Single(kubernetesService.CreatedResources.OfType<Service>()); 4416var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4446var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4517var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4565var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4599var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4647var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4689var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4757var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4789var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4823var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 9648.OfType<Service>() 9654var svc = svcs.Single(); 9732Assert.DoesNotContain(kubernetesService.CreatedResources.OfType<Service>(), 9770var tunnelService = Assert.Single(kubernetesService.CreatedResources.OfType<Service>(), 10221var tunnelService = Assert.Single( 10222kubernetesService.CreatedResources.OfType<Service>(), 10272var tunnelService = Assert.Single( 10273kubernetesService.CreatedResources.OfType<Service>(), 10309var tunnelService = Assert.Single( 10310kubernetesService.CreatedResources.OfType<Service>(), 10348var tunnelService = Assert.Single( 10349kubernetesService.CreatedResources.OfType<Service>(), 10480kubernetesService.CreatedResources.OfType<Service>(), 10510kubernetesService.CreatedResources.OfType<Service>(), 10560var tunnelService = Assert.Single( 10561kubernetesService.CreatedResources.OfType<Service>(), 10591if (resource is Service service && 10641if (resource is Service service && 10723.OfType<Service>() 10728var executableBTunnelService = Assert.Single(tunnelServices, s => s.AppModelResourceName == executableB.Resource.Name); 10796.OfType<Service>() 10800var upstreamTunnelService = Assert.Single(tunnelServices, s => s.AppModelResourceName == upstreamExecutable.Resource.Name);

104if (_allocateServiceAddresses && res is Service svc) 263var service = CreatedResources.OfType<Service>().FirstOrDefault(s => s.Metadata.Name == serviceProduced.ServiceName);

1879var otherRedisService = await WaitForAllocatedProxylessServiceAsync(s, redisNoPort.Resource, redisNoPort.Resource.PrimaryEndpoint) 1933var serviceList = await s.ListAsync<Service>().DefaultTimeout(); 1957var otherRedisService = await WaitForAllocatedProxylessServiceAsync(s, redisNoPort.Resource, redisNoPort.Resource.PrimaryEndpoint) 2355private static Task<Service> WaitForAllocatedProxylessServiceAsync(IKubernetesService kubernetesService, RedisResource redis, EndpointReference endpoint, CancellationToken cancellationToken = default) 2368return KubernetesHelper.GetResourceByNameAsync<Service>( 2376private static int AssertAllocatedProxylessPort(Service service)