139internal abstract class CustomResource<TSpec, TStatus> : CustomResource

12CustomResource DcpResource { get; } 22internal class AppResource<TDcpResource> : IAppResource, IDisposable, IEquatable<AppResource<TDcpResource>> where TDcpResource : CustomResource, IKubernetesStaticMetadata 36CustomResource IAppResource.DcpResource => DcpResource; 69internal class RenderedModelResource<TDcpResource> : AppResource<TDcpResource>, IResourceReference where TDcpResource : CustomResource, IKubernetesStaticMetadata

114ctr.Annotate(CustomResource.ResourceNameAnnotation, container.Name); 115ctr.Annotate(CustomResource.OtelServiceNameAnnotation, container.Name); 116ctr.Annotate(CustomResource.OtelServiceInstanceIdAnnotation, container.GetOtelServiceInstanceId(containerObjectInstance)); 196containerExec.Annotate(CustomResource.OtelServiceNameAnnotation, containerExecutable.Name); 197containerExec.Annotate(CustomResource.OtelServiceInstanceIdAnnotation, containerExecutable.GetOtelServiceInstanceId(exeInstance)); 198containerExec.Annotate(CustomResource.ResourceNameAnnotation, containerExecutable.Name); 253dcpContainer.SetAnnotationAsObjectList(CustomResource.ResourceAppArgsAnnotation, appLaunchArgumentAnnotations);

209service.Annotate(CustomResource.ResourceNameAnnotation, hostResource.Resource.Name); 210service.Annotate(CustomResource.EndpointNameAnnotation, endpoint.Name); 211service.Annotate(CustomResource.ContainerNetworkAnnotation, KnownNetworkIdentifiers.DefaultAspireContainerNetwork.Value); 212service.Annotate(CustomResource.PrimaryServiceNameAnnotation, serverService.DcpResource.Metadata.Name); 213service.Annotate(CustomResource.ContainerTunnelInstanceName, tunnelProxyName);

342internal static string GetResourceType<T>(T resource, IResource appModelResource) where T : CustomResource 364where TDcpResource : CustomResource, IKubernetesStaticMetadata 491PrimaryServiceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.PrimaryServiceNameAnnotation, out var psn) == true ? psn : null) 539where TDcpResource : CustomResource, IKubernetesStaticMetadata 579private Task CreateAllDcpObjectsAsync<RT>(CancellationToken cancellationToken) where RT : CustomResource, IKubernetesStaticMetadata 592where T : CustomResource, IKubernetesStaticMetadata 601private async Task CreateDcpObjectsAsync<RT>(IEnumerable<RT> objects, CancellationToken cancellationToken) where RT : CustomResource, IKubernetesStaticMetadata 709svc.Annotate(CustomResource.ResourceNameAnnotation, sp.ModelResource.Name); 710svc.Annotate(CustomResource.EndpointNameAnnotation, endpoint.Name); 765CustomResource.ServiceProducerAnnotation, 796CustomResource.ServiceProducerAnnotation, 919annotationHolder.Annotate(CustomResource.ResourceStateAnnotation, state); 928where TDcpResource : CustomResource, IKubernetesStaticMetadata 963where TDcpResource : CustomResource, IKubernetesStaticMetadata 1067Func<CustomResourceSnapshot, CustomResourceSnapshot> BuildSnapshotFunc(CustomResource dcpResource) 1103static bool IsDelayedStart(CustomResource resource) 1139private static V1Patch CreatePatch<T>(T obj, Action<T> change) where T : CustomResource 1313private async Task EnsureResourceDeletedAsync<T>(IResourceReference resource, CancellationToken cancellationToken) where T : CustomResource, IKubernetesStaticMetadata

54where TDcpResource : CustomResource, IKubernetesStaticMetadata 95appResource.DcpResource.AnnotateAsObjectList(CustomResource.ServiceProducerAnnotation, spAnn); 99static bool HasMultipleReplicas(CustomResource resource) 101if (resource is Executable exe && exe.Metadata.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1) 113where TDcpResource : CustomResource, IKubernetesStaticMetadata 125where TDcpResource : CustomResource, IKubernetesStaticMetadata 223where TDcpResource : CustomResource, IKubernetesStaticMetadata 252where TDcpResource : CustomResource, IKubernetesStaticMetadata 289ResourceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ResourceNameAnnotation, out var resourceName) == true ? resourceName : null, 290EndpointName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.EndpointNameAnnotation, out var endpointName) == true ? endpointName : null, 291TunnelInstanceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerTunnelInstanceName, out var tunnelInstanceName) == true ? tunnelInstanceName : null, 292ContainerNetworkName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerNetworkAnnotation, out var containerNetworkName) == true ? containerNetworkName : null

228async Task WatchKubernetesResourceAsync<T>(Func<WatchEventType, T, Task> handler) where T : CustomResource, IKubernetesStaticMetadata 300private async Task ProcessResourceChange<T>(WatchEventType watchEventType, T resource, ConcurrentDictionary<string, T> resourceByName, string resourceKind, Func<T, CustomResourceSnapshot, CustomResourceSnapshot> snapshotFactory) where T : CustomResource, IKubernetesStaticMetadata 439else if (resource.Metadata.Annotations?.TryGetValue(CustomResource.ServiceProducerAnnotation, out var servicesProducedAnnotationJson) == true) 480where T : CustomResource, IKubernetesStaticMetadata 546private static bool HasLogsAvailable(CustomResource resource) 553internal static ResourceStatus GetResourceStatus(CustomResource resource) 583private void AddDcpResourceObservedEvent(CustomResource resource, IResource appModelResource, string resourceKind, ResourceStatus status) 648private void StartLogStream<T>(T resource) where T : CustomResource, IKubernetesStaticMetadata 994CustomResource? cr = resourceKind switch 1044where T : CustomResource, IKubernetesStaticMetadata

268CustomResource.ResourceAppArgsAnnotation, 342executable.Annotate(CustomResource.OtelServiceNameAnnotation, resource.Name); 343executable.Annotate(CustomResource.OtelServiceInstanceIdAnnotation, resource.GetOtelServiceInstanceId(instance)); 344executable.Annotate(CustomResource.ResourceNameAnnotation, resource.Name); 345executable.Annotate(CustomResource.ResourceReplicaCount, replicaCount.ToString(CultureInfo.InvariantCulture)); 346executable.Annotate(CustomResource.ResourceReplicaIndex, replicaIndex.ToString(CultureInfo.InvariantCulture)); 409annotations.TryGetValue(CustomResource.ResourceReplicaIndex, out var value) &&

24where TDcpResource : CustomResource, IKubernetesStaticMetadata; 30where TDcpResource : CustomResource, IKubernetesStaticMetadata; 36where TDcpResource : CustomResource, IKubernetesStaticMetadata; 58where TDcpResource : CustomResource, IKubernetesStaticMetadata;

23where TDcpResource : CustomResource, IKubernetesStaticMetadata

40where T : CustomResource, IKubernetesStaticMetadata; 42where T : CustomResource, IKubernetesStaticMetadata; 44where T : CustomResource, IKubernetesStaticMetadata; 46where T : CustomResource, IKubernetesStaticMetadata; 48where T : CustomResource, IKubernetesStaticMetadata; 52where T : CustomResource, IKubernetesStaticMetadata; 76) where T : CustomResource, IKubernetesStaticMetadata; 99where T : CustomResource, IKubernetesStaticMetadata 130where T : CustomResource, IKubernetesStaticMetadata 163where T : CustomResource, IKubernetesStaticMetadata 198where T : CustomResource, IKubernetesStaticMetadata 228where T : CustomResource, IKubernetesStaticMetadata 262where T : CustomResource, IKubernetesStaticMetadata 321long? skip = null) where T : CustomResource, IKubernetesStaticMetadata 448private static string GetResourceFor<T>() where T : CustomResource

41CustomResource.AnnotateAsObjectList(Annotations, annotationName, value); 46return CustomResource.TryGetAnnotationAsObjectList(Annotations, annotationName, out list);

154where T : CustomResource

10public void Add<T>(string kind, string resource) where T : CustomResource 15public bool TryGet<T>(out (string Kind, string Resource) kindWithResource) where T : CustomResource

29where TResource : CustomResource, IKubernetesStaticMetadata

245private static (ImmutableArray<string> Args, ImmutableArray<int>? ArgsAreSensitive, bool IsSensitive)? GetLaunchArgs(CustomResource resource, IReadOnlyList<string>? effectiveArgs) 247if (!resource.TryGetAnnotationAsObjectList(CustomResource.ResourceAppArgsAnnotation, out List<AppLaunchArgumentAnnotation>? launchArgumentAnnotations)) 282private ImmutableArray<UrlSnapshot> GetUrls(CustomResource resource, string? resourceState) 381private static ImmutableArray<VolumeSnapshot> GetVolumes(CustomResource resource)

135context.EnvironmentVariables[KnownOtelConfigNames.ResourceAttributes] = "service.instance.id={{- index .Annotations \"" + CustomResource.OtelServiceInstanceIdAnnotation + "\" -}}"; 136context.EnvironmentVariables[KnownOtelConfigNames.ServiceName] = "{{- index .Annotations \"" + CustomResource.OtelServiceNameAnnotation + "\" -}}";

116.OrderBy(static executable => int.Parse(executable.Metadata.Annotations[CustomResource.ResourceReplicaIndex], CultureInfo.InvariantCulture)) 122Assert.Equal(replicas, rendered.Select(executable => executable.Metadata.Annotations[CustomResource.OtelServiceInstanceIdAnnotation]).Distinct().Count()); 126Assert.Equal(index.ToString(CultureInfo.InvariantCulture), executable.Metadata.Annotations[CustomResource.ResourceReplicaIndex]); 127Assert.Equal(replicas.ToString(CultureInfo.InvariantCulture), executable.Metadata.Annotations[CustomResource.ResourceReplicaCount]); 128Assert.Equal("svc", executable.Metadata.Annotations[CustomResource.OtelServiceNameAnnotation]);

309Assert.True(executable.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var producers)); 395Assert.Equal("1", executable.Metadata.Annotations[CustomResource.ResourceReplicaCount]); 396Assert.Equal("0", executable.Metadata.Annotations[CustomResource.ResourceReplicaIndex]); 581Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 618Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 668Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 707Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 739Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 785Assert.True(container.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 942Assert.True(exe1.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations1)); 962Assert.True(exe2.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations2)); 990Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1028Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1059Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1101Assert.True(fixedExecutable.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var fixedAnnotations)); 1102Assert.True(dynamicExecutable.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var dynamicAnnotations)); 1124Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1179Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1208Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1243Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1286Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1324Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1352Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1383Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1415Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1445Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1926Assert.Equal(expectedName, exe.Metadata.Annotations[CustomResource.OtelServiceNameAnnotation]); 3950Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 3997Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4035Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4072Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4117Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4146Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4181Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4412Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4445Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4753Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4788Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4819Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4961var serviceProducers = JsonSerializer.Deserialize<List<ServiceProducerAnnotation>>(annotations[CustomResource.ServiceProducerAnnotation]); 5490Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 5527Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 5723Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 5954var resource = Assert.Single(kubernetesService.CreatedResources, r => 5956r.Metadata.Annotations.ContainsKey(CustomResource.OtelServiceInstanceIdAnnotation)); 5958return resource.Metadata.Annotations![CustomResource.OtelServiceInstanceIdAnnotation]; 7435Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 7549Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 7641Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 8455Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 8841Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 8894Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 8945Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 9032Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 9434Assert.True(exe1.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs1)); 9444Assert.True(exe2.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs2)); 9453Assert.True(exe3.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs3)); 9652&& x.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 9734s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 9774&& s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 9889Assert.True(container.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 9933Assert.True(startedExecutable.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 9978Assert.True(startedContainer.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 10198service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10249service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10286service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10325service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10456service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10486service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10537service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10567service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 10617service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 10699.Where(s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 10772.Where(s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 11136.OrderBy(e => e.Metadata.Annotations?[CustomResource.ResourceReplicaIndex], StringComparer.Ordinal) 11220Assert.Equal("1", exe.Metadata.Annotations?[CustomResource.ResourceReplicaCount]); 11221Assert.Equal("0", exe.Metadata.Annotations?[CustomResource.ResourceReplicaIndex]);

9using DcpCustomResource = Aspire.Hosting.Dcp.Model.CustomResource; 68executable.Annotate(DcpCustomResource.ResourceNameAnnotation, project.Name); 100executable.Annotate(DcpCustomResource.ResourceNameAnnotation, resource.Name); 133executable.Annotate(DcpCustomResource.ResourceNameAnnotation, project.Name); 161executable.Annotate(DcpCustomResource.ResourceNameAnnotation, resource.Name); 283executable.SetAnnotationAsObjectList(DcpCustomResource.ResourceAppArgsAnnotation, launchArgumentAnnotations);

25CustomResource Resource); 31public ConcurrentQueue<CustomResource> CreatedResources { get; } = []; 34private readonly List<Channel<(WatchEventType, CustomResource)>> _watchChannels = []; 35private readonly Func<CustomResource, string, bool?, Stream> _startStream; 37private readonly Action<CustomResource>? _beforeCreate; 38private readonly Func<CustomResource, CancellationToken, Task>? _beforeCreateAsync; 49Func<CustomResource, string, Stream>? startStream = null, 51Func<CustomResource, string, bool?, Stream>? startStreamWithFollow = null, 52Action<CustomResource>? beforeCreate = null, 53Func<CustomResource, CancellationToken, Task>? beforeCreateAsync = null, 72public Task<T> GetAsync<T>(string name, string? namespaceParameter = null, CancellationToken _ = default) where T : CustomResource, IKubernetesStaticMetadata 93public async Task<T> CreateAsync<T>(T obj, CancellationToken cancellationToken = default) where T : CustomResource, IKubernetesStaticMetadata 110svc.Metadata.Annotations?.ContainsKey(CustomResource.ContainerTunnelInstanceName) is true) 146foreach (var modifiedResource in modifiedResources) 160public void PushResourceModified(CustomResource resource) 180public void PushResourceUnchanged(CustomResource resource, WatchEventType eventType = WatchEventType.Modified) 195public void PushResourceDeleted(CustomResource resource) 213foreach (var res in CreatedResources.Where(r => !DeletedResources.Contains(r.Metadata.Name))) 227private void StampResourceUid(CustomResource resource) 240private void StampResourceVersion(CustomResource resource) 245private static T Copy<T>(T resource) where T : CustomResource 252private List<CustomResource> AllocateProxylessContainerServicePorts(CustomResource resource) 255container.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var servicesProduced) is not true) 260var modifiedResources = new List<CustomResource>(); 284public async Task<T> DeleteAsync<T>(string name, string? namespaceParameter = null, CancellationToken cancellationToken = default) where T : CustomResource, IKubernetesStaticMetadata 304public Task<List<T>> ListAsync<T>(string? namespaceParameter = null, CancellationToken cancellationToken = default) where T : CustomResource, IKubernetesStaticMetadata 312public async IAsyncEnumerable<(WatchEventType, T)> WatchAsync<T>(string? namespaceParameter = null, [EnumeratorCancellation] CancellationToken cancellationToken = default) where T : CustomResource, IKubernetesStaticMetadata 314var chan = Channel.CreateUnbounded<(WatchEventType, CustomResource)>(); 375) where T : CustomResource, IKubernetesStaticMetadata 380public Task<T> PatchAsync<T>(T obj, V1Patch patch, CancellationToken cancellationToken = default) where T : CustomResource, IKubernetesStaticMetadata

13public static async Task<T> GetResourceByNameAsync<T>(IKubernetesService kubernetes, string resourceName, string resourceNameSuffix, Func<T, bool> ready, CancellationToken cancellationToken = default) where T : CustomResource, IKubernetesStaticMetadata 28public static async Task<T> GetResourceByNameMatchAsync<T>(IKubernetesService kubernetes, string resourceNamePattern, Func<T, bool> ready, CancellationToken cancellationToken = default) where T : CustomResource, IKubernetesStaticMetadata