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);

195var createServices = Task.Run(() => CreateAllDcpObjectsAsync<Service>(ct), ct); 201var proxiedWithNoAddress = _appResources.Get().OfType<AppResource<Service>>().Select(r => r.DcpResource) 385Task IDcpObjectFactory.UpdateWithEffectiveAddressInfo(IEnumerable<Service> services, CancellationToken cancellationToken, TimeSpan? timeout) 471private async Task UpdateWithEffectiveAddressInfo(IEnumerable<Service> services, CancellationToken cancellationToken, TimeSpan? timeout = null) 503foreach (var sar in needAddressAllocated) 521var containerServices = _appResources.Get().OfType<AppResource<Service>>().Select(r => ( 529var primaryService = _appResources.Get().OfType<ServiceWithModelResource>().Select(sar => sar.Service) 692var svc = Service.Create(serviceName); 1117.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)), 872private 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>()

636var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 668var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 700var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 733var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 784var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 813var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 848var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 884var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 922var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 953var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 984var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1016var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1043var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1160var fixedService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "FixedProgram"); 1161var dynamicService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "DynamicProgram"); 1204var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1243var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 1284var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1317var service = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "CoolProgram"); 1355var service = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 1402var persistentService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "PersistentProgram"); 1403var dynamicService = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "DynamicProgram"); 3393var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA-NoPortNoTargetPort"); 3438var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA-PortSetNoTargetPort"); 3471var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA"); 3508var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA"); 3546var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "ServiceA"); 3579var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 3614var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 3697var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 3727var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 3798var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 3846var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 3880var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 3928var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 3970var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4038var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4070var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 4104var svc = kubernetesService.CreatedResources.OfType<Service>().Single(s => s.Name() == "database"); 8871.OfType<Service>() 8877var svc = svcs.Single(); 8955Assert.DoesNotContain(kubernetesService.CreatedResources.OfType<Service>(), 8993var tunnelService = Assert.Single(kubernetesService.CreatedResources.OfType<Service>(), 9440.OfType<Service>() 9445var executableBTunnelService = Assert.Single(tunnelServices, s => s.AppModelResourceName == executableB.Resource.Name); 9513.OfType<Service>() 9517var 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);

1868var otherRedisService = await WaitForAllocatedProxylessServiceAsync(s, redisNoPort.Resource, redisNoPort.Resource.PrimaryEndpoint) 1922var serviceList = await s.ListAsync<Service>().DefaultTimeout(); 1946var otherRedisService = await WaitForAllocatedProxylessServiceAsync(s, redisNoPort.Resource, redisNoPort.Resource.PrimaryEndpoint) 2344private static Task<Service> WaitForAllocatedProxylessServiceAsync(IKubernetesService kubernetesService, RedisResource redis, EndpointReference endpoint, CancellationToken cancellationToken = default) 2357return KubernetesHelper.GetResourceByNameAsync<Service>( 2365private static int AssertAllocatedProxylessPort(Service service)