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

341internal static string GetResourceType<T>(T resource, IResource appModelResource) where T : CustomResource 363where TDcpResource : CustomResource, IKubernetesStaticMetadata 490PrimaryServiceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.PrimaryServiceNameAnnotation, out var psn) == true ? psn : null) 538where TDcpResource : CustomResource, IKubernetesStaticMetadata 578private Task CreateAllDcpObjectsAsync<RT>(CancellationToken cancellationToken) where RT : CustomResource, IKubernetesStaticMetadata 591where T : CustomResource, IKubernetesStaticMetadata 600private async Task CreateDcpObjectsAsync<RT>(IEnumerable<RT> objects, CancellationToken cancellationToken) where RT : CustomResource, IKubernetesStaticMetadata 708svc.Annotate(CustomResource.ResourceNameAnnotation, sp.ModelResource.Name); 709svc.Annotate(CustomResource.EndpointNameAnnotation, endpoint.Name); 764CustomResource.ServiceProducerAnnotation, 795CustomResource.ServiceProducerAnnotation, 918annotationHolder.Annotate(CustomResource.ResourceStateAnnotation, state); 927where TDcpResource : CustomResource, IKubernetesStaticMetadata 962where TDcpResource : CustomResource, IKubernetesStaticMetadata 1066Func<CustomResourceSnapshot, CustomResourceSnapshot> BuildSnapshotFunc(CustomResource dcpResource) 1102static bool IsDelayedStart(CustomResource resource) 1138private static V1Patch CreatePatch<T>(T obj, Action<T> change) where T : CustomResource 1312private 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

44where T : CustomResource, IKubernetesStaticMetadata; 46where T : CustomResource, IKubernetesStaticMetadata; 48where T : CustomResource, IKubernetesStaticMetadata; 50where T : CustomResource, IKubernetesStaticMetadata; 52where T : CustomResource, IKubernetesStaticMetadata; 56where T : CustomResource, IKubernetesStaticMetadata; 80) where T : CustomResource, IKubernetesStaticMetadata; 102where T : CustomResource, IKubernetesStaticMetadata 133where T : CustomResource, IKubernetesStaticMetadata 204where T : CustomResource, IKubernetesStaticMetadata 239where T : CustomResource, IKubernetesStaticMetadata 269where T : CustomResource, IKubernetesStaticMetadata 303where T : CustomResource, IKubernetesStaticMetadata 387long? skip = null) where T : CustomResource, IKubernetesStaticMetadata 519private static string GetResourceFor<T>() where T : CustomResource 534where T : CustomResource, IKubernetesStaticMetadata

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) 375private 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 + "\" -}}";

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

308Assert.True(executable.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var producers)); 394Assert.Equal("1", executable.Metadata.Annotations[CustomResource.ResourceReplicaCount]); 395Assert.Equal("0", executable.Metadata.Annotations[CustomResource.ResourceReplicaIndex]); 580Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 617Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 667Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 706Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 738Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 784Assert.True(container.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 941Assert.True(exe1.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations1)); 961Assert.True(exe2.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations2)); 989Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1027Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1058Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1100Assert.True(fixedExecutable.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var fixedAnnotations)); 1101Assert.True(dynamicExecutable.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var dynamicAnnotations)); 1123Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1178Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1207Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1242Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1285Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1323Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1351Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1382Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1414Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1444Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1925Assert.Equal(expectedName, exe.Metadata.Annotations[CustomResource.OtelServiceNameAnnotation]); 3949Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 3996Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4034Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4071Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4116Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4145Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4180Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4411Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4444Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4752Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4787Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4818Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4960var serviceProducers = JsonSerializer.Deserialize<List<ServiceProducerAnnotation>>(annotations[CustomResource.ServiceProducerAnnotation]); 5489Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 5526Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 5722Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 5953var resource = Assert.Single(kubernetesService.CreatedResources, r => 5955r.Metadata.Annotations.ContainsKey(CustomResource.OtelServiceInstanceIdAnnotation)); 5957return resource.Metadata.Annotations![CustomResource.OtelServiceInstanceIdAnnotation]; 7434Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 7548Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 7640Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 8454Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 8840Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 8893Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 8944Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 9031Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 9433Assert.True(exe1.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs1)); 9443Assert.True(exe2.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs2)); 9452Assert.True(exe3.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs3)); 9651&& x.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 9733s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 9773&& s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 9888Assert.True(container.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 9932Assert.True(startedExecutable.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 9977Assert.True(startedContainer.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 10223service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10274service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10311service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10350service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10481service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10511service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10562service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10592service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 10642service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 10724.Where(s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 10797.Where(s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 11161.OrderBy(e => e.Metadata.Annotations?[CustomResource.ResourceReplicaIndex], StringComparer.Ordinal) 11245Assert.Equal("1", exe.Metadata.Annotations?[CustomResource.ResourceReplicaCount]); 11246Assert.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