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)

13public required AppResource<Service> ServiceResource { get; init; }

437var svc = Service.Create(serviceName); 469var svcAppResource = new AppResource<Service>(svc);

196var createServices = Task.Run(() => CreateAllDcpObjectsAsync<Service>(ct), ct); 202var proxiedWithNoAddress = _appResources.Get().OfType<AppResource<Service>>().Select(r => r.DcpResource) 386Task IDcpObjectFactory.UpdateWithEffectiveAddressInfo(IEnumerable<Service> services, CancellationToken cancellationToken, TimeSpan? timeout) 472private async Task UpdateWithEffectiveAddressInfo(IEnumerable<Service> services, CancellationToken cancellationToken, TimeSpan? timeout = null) 504foreach (var sar in needAddressAllocated) 522var containerServices = _appResources.Get().OfType<AppResource<Service>>().Select(r => ( 530var primaryService = _appResources.Get().OfType<ServiceWithModelResource>().Select(sar => sar.Service) 700var svc = Service.Create(serviceName); 1170.Where(r => r.DcpResource is not Service)

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

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

129Task.Run(() => WatchKubernetesResourceAsync<Service>(ProcessServiceChange)), 881var service = endpoint.Spec.ServiceName is { } serviceName 920private 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)

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

643var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 681var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 712var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 777var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 828var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 857var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 892var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 935var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 973var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1004var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1035var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1067var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1094var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1211var fixedService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "FixedProgram"); 1212var dynamicService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "DynamicProgram"); 1255var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1294var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 1335var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1368var service = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1406var service = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 1453var persistentService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "PersistentProgram"); 1454var dynamicService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "DynamicProgram"); 1501var service = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "PersistentProgram"); 3490var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA-NoPortNoTargetPort"); 3537var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA-PortSetNoTargetPort"); 3571var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA"); 3608var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA"); 3653var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA"); 3686var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 3721var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 3804var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 3834var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 3905var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 3953var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 3987var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4035var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4077var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4145var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4177var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4211var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 8978.OfType<Service>() 8984var svc = svcs.Single(); 9062Assert.DoesNotContain(kubernetesService.CreatedResources.OfType<Service>(), 9100var tunnelService = Assert.Single(kubernetesService.CreatedResources.OfType<Service>(), 9547.OfType<Service>() 9552var executableBTunnelService = Assert.Single(tunnelServices, s => s.AppModelResourceName == executableB.Resource.Name); 9620.OfType<Service>() 9624var upstreamTunnelService = Assert.Single(tunnelServices, s => s.AppModelResourceName == upstreamExecutable.Resource.Name);

73if (res is Service svc) 232var service = CreatedResources.OfType<Service>().FirstOrDefault(s => s.Metadata.Name == serviceProduced.ServiceName);

1875var otherRedisService = await WaitForAllocatedProxylessServiceAsync(s, redisNoPort.Resource, redisNoPort.Resource.PrimaryEndpoint) 1929var serviceList = await s.ListAsync<Service>().DefaultTimeout(); 1953var otherRedisService = await WaitForAllocatedProxylessServiceAsync(s, redisNoPort.Resource, redisNoPort.Resource.PrimaryEndpoint) 2351private static Task<Service> WaitForAllocatedProxylessServiceAsync(IKubernetesService kubernetesService, RedisResource redis, EndpointReference endpoint, CancellationToken cancellationToken = default) 2364return KubernetesHelper.GetResourceByNameAsync<Service>( 2372private static int AssertAllocatedProxylessPort(Service service)