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)

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

305var service = Assert.Single(kubernetesService.CreatedResources.OfType<Service>()); 996var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1034var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1065var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1130var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1181var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1210var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1245var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1288var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1326var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1357var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1388var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1420var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1447var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1564var fixedService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "FixedProgram"); 1565var dynamicService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "DynamicProgram"); 1608var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1647var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 1688var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1721var service = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1759var service = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 1806var persistentService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "PersistentProgram"); 1807var dynamicService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "DynamicProgram"); 1854var service = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "PersistentProgram"); 3956var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA-NoPortNoTargetPort"); 4003var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA-PortSetNoTargetPort"); 4037var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA"); 4074var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA"); 4119var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA"); 4152var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4187var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4224if (resource is Service service) 4236if (resource is Service) 4249if (resourceType == typeof(Service) && watchIndex == 1) 4256if (context.ResourceType != typeof(Service)) 4261var service = (Service)context.Resource; 4285if (context.ResourceType == typeof(Service)) 4287var service = (Service)context.Resource; 4316var service = Assert.Single(kubernetesService.CreatedResources.OfType<Service>()); 4417var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4447var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4518var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4566var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4600var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4648var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4690var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4758var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4790var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4824var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 9717.OfType<Service>() 9723var svc = svcs.Single(); 9804Assert.DoesNotContain(kubernetesService.CreatedResources.OfType<Service>(), 9844var tunnelService = Assert.Single(kubernetesService.CreatedResources.OfType<Service>(), 10295var tunnelService = Assert.Single( 10296kubernetesService.CreatedResources.OfType<Service>(), 10346var tunnelService = Assert.Single( 10347kubernetesService.CreatedResources.OfType<Service>(), 10383var tunnelService = Assert.Single( 10384kubernetesService.CreatedResources.OfType<Service>(), 10422var tunnelService = Assert.Single( 10423kubernetesService.CreatedResources.OfType<Service>(), 10554kubernetesService.CreatedResources.OfType<Service>(), 10584kubernetesService.CreatedResources.OfType<Service>(), 10634var tunnelService = Assert.Single( 10635kubernetesService.CreatedResources.OfType<Service>(), 10665if (resource is Service service && 10715if (resource is Service service && 10797.OfType<Service>() 10802var executableBTunnelService = Assert.Single(tunnelServices, s => s.AppModelResourceName == executableB.Resource.Name); 10870.OfType<Service>() 10874var upstreamTunnelService = Assert.Single(tunnelServices, s => s.AppModelResourceName == upstreamExecutable.Resource.Name);

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

1936var otherRedisService = await WaitForAllocatedProxylessServiceAsync(s, redisNoPort.Resource, redisNoPort.Resource.PrimaryEndpoint) 1992var serviceList = await s.ListAsync<Service>().DefaultTimeout(); 2016var otherRedisService = await WaitForAllocatedProxylessServiceAsync(s, redisNoPort.Resource, redisNoPort.Resource.PrimaryEndpoint) 2414private static Task<Service> WaitForAllocatedProxylessServiceAsync(IKubernetesService kubernetesService, RedisResource redis, EndpointReference endpoint, CancellationToken cancellationToken = default) 2427return KubernetesHelper.GetResourceByNameAsync<Service>( 2435private static int AssertAllocatedProxylessPort(Service service)