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

352internal static string GetResourceType<T>(T resource, IResource appModelResource) where T : CustomResource 374where TDcpResource : CustomResource, IKubernetesStaticMetadata 501PrimaryServiceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.PrimaryServiceNameAnnotation, out var psn) == true ? psn : null) 549where TDcpResource : CustomResource, IKubernetesStaticMetadata 589private Task CreateAllDcpObjectsAsync<RT>(CancellationToken cancellationToken) where RT : CustomResource, IKubernetesStaticMetadata 602where T : CustomResource, IKubernetesStaticMetadata 611private 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, 834annotationHolder.Annotate(CustomResource.ResourceStateAnnotation, state); 843where TDcpResource : CustomResource, IKubernetesStaticMetadata 878where TDcpResource : CustomResource, IKubernetesStaticMetadata 982Func<CustomResourceSnapshot, CustomResourceSnapshot> BuildSnapshotFunc(CustomResource dcpResource) 1018static bool IsDelayedStart(CustomResource resource) 1054private static V1Patch CreatePatch<T>(T obj, Action<T> change) where T : CustomResource 1231private async Task EnsureResourceDeletedAsync<T>(IResourceReference resource, CancellationToken cancellationToken) where T : CustomResource, IKubernetesStaticMetadata

96where TDcpResource : CustomResource, IKubernetesStaticMetadata 137appResource.DcpResource.AnnotateAsObjectList(CustomResource.ServiceProducerAnnotation, spAnn); 141static bool HasMultipleReplicas(CustomResource resource) 143if (resource is Executable exe && exe.Metadata.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1) 155where TDcpResource : CustomResource, IKubernetesStaticMetadata 167where TDcpResource : CustomResource, IKubernetesStaticMetadata 265where TDcpResource : CustomResource, IKubernetesStaticMetadata 294where TDcpResource : CustomResource, IKubernetesStaticMetadata 331ResourceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ResourceNameAnnotation, out var resourceName) == true ? resourceName : null, 332EndpointName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.EndpointNameAnnotation, out var endpointName) == true ? endpointName : null, 333TunnelInstanceName: r.DcpResource.Metadata.Annotations?.TryGetValue(CustomResource.ContainerTunnelInstanceName, out var tunnelInstanceName) == true ? tunnelInstanceName : null, 334ContainerNetworkName: 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, 349executable.Annotate(CustomResource.OtelServiceNameAnnotation, resource.Name); 350executable.Annotate(CustomResource.OtelServiceInstanceIdAnnotation, resource.GetOtelServiceInstanceId(instance)); 351executable.Annotate(CustomResource.ResourceNameAnnotation, resource.Name); 352executable.Annotate(CustomResource.ResourceReplicaCount, replicaCount.ToString(CultureInfo.InvariantCulture)); 353executable.Annotate(CustomResource.ResourceReplicaIndex, replicaIndex.ToString(CultureInfo.InvariantCulture)); 416annotations.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 546private static string GetResourceFor<T>() where T : CustomResource 561where 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

482private static HashSet<int> GetSensitiveEffectiveArgumentIndexes(CustomResource resource) 492CustomResource.ResourceAppArgsAnnotation, 504private static (ImmutableArray<string> Args, ImmutableArray<int>? ArgsAreSensitive, bool IsSensitive)? GetLaunchArgs(CustomResource resource, IReadOnlyList<string>? effectiveArgs) 506if (!resource.TryGetAnnotationAsObjectList(CustomResource.ResourceAppArgsAnnotation, out List<AppLaunchArgumentAnnotation>? launchArgumentAnnotations)) 541private ImmutableArray<UrlSnapshot> GetUrls(CustomResource resource, string? resourceState) 634private static ImmutableArray<VolumeSnapshot> GetVolumes(CustomResource resource)

21private const string ServiceInstanceIdTemplate = "{{- index .Annotations \"" + CustomResource.OtelServiceInstanceIdAnnotation + "\" -}}"; 151context.EnvironmentVariables[KnownOtelConfigNames.ServiceName] = "{{- index .Annotations \"" + CustomResource.OtelServiceNameAnnotation + "\" -}}";

106.OrderBy(static executable => int.Parse(executable.Metadata.Annotations[CustomResource.ResourceReplicaIndex], CultureInfo.InvariantCulture)) 112Assert.Equal(replicas, rendered.Select(executable => executable.Metadata.Annotations[CustomResource.OtelServiceInstanceIdAnnotation]).Distinct().Count()); 116Assert.Equal(index.ToString(CultureInfo.InvariantCulture), executable.Metadata.Annotations[CustomResource.ResourceReplicaIndex]); 117Assert.Equal(replicas.ToString(CultureInfo.InvariantCulture), executable.Metadata.Annotations[CustomResource.ResourceReplicaCount]); 118Assert.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]); 623Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 660Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 710Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 749Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 781Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 827Assert.True(container.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 984Assert.True(exe1.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations1)); 1004Assert.True(exe2.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations2)); 1032Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1070Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1101Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1143Assert.True(fixedExecutable.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var fixedAnnotations)); 1144Assert.True(dynamicExecutable.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var dynamicAnnotations)); 1166Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1221Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1250Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1285Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1328Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1366Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1394Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1425Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1457Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1487Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 2334CustomResource.ServiceProducerAnnotation, 2411Assert.Equal(expectedName, exe.Metadata.Annotations[CustomResource.OtelServiceNameAnnotation]); 4435Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4482Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4520Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4557Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4602Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4631Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4666Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4897Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 4930Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 5290Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 5325Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 5356Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 5566var serviceProducers = JsonSerializer.Deserialize<List<ServiceProducerAnnotation>>(annotations[CustomResource.ServiceProducerAnnotation]); 6095Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 6132Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 6169Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 6407Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 6638var resource = Assert.Single(kubernetesService.CreatedResources, r => 6640r.Metadata.Annotations.ContainsKey(CustomResource.OtelServiceInstanceIdAnnotation)); 6642return resource.Metadata.Annotations![CustomResource.OtelServiceInstanceIdAnnotation]; 8119Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 8233Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 8325Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 9139Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 9525Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 9578Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 9629Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 9716Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs)); 10118Assert.True(exe1.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs1)); 10128Assert.True(exe2.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs2)); 10137Assert.True(exe3.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var displayArgs3)); 10336&& x.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 10421s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10463&& s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10578Assert.True(container.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 10622Assert.True(startedExecutable.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 10667Assert.True(startedContainer.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 10913service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 10964service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 11001service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 11040service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 11171service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 11201service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 11252service => service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)); 11282service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 11332service.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 11414.Where(s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 11487.Where(s => s.Metadata.Annotations.ContainsKey(CustomResource.ContainerTunnelInstanceName)) 11851.OrderBy(e => e.Metadata.Annotations?[CustomResource.ResourceReplicaIndex], StringComparer.Ordinal) 11935Assert.Equal("1", exe.Metadata.Annotations?[CustomResource.ResourceReplicaCount]); 11936Assert.Equal("0", exe.Metadata.Annotations?[CustomResource.ResourceReplicaIndex]);

274CustomResource.ResourceAppArgsAnnotation,

10using DcpCustomResource = Aspire.Hosting.Dcp.Model.CustomResource; 69executable.Annotate(DcpCustomResource.ResourceNameAnnotation, project.Name); 99executable.Annotate(DcpCustomResource.ResourceNameAnnotation, configuredProject.Resource.Name); 127executable.Annotate(DcpCustomResource.ResourceNameAnnotation, project.Resource.Name); 179executable.Annotate(DcpCustomResource.ResourceNameAnnotation, resource.Name); 233executable.Annotate(DcpCustomResource.ResourceNameAnnotation, resource.Name); 285executable.Annotate(DcpCustomResource.ResourceNameAnnotation, resource.Name); 343executable.Annotate(DcpCustomResource.ResourceNameAnnotation, project.Name); 380executable.Annotate(DcpCustomResource.ResourceNameAnnotation, project.Name); 386executable.SetAnnotationAsObjectList(DcpCustomResource.ResourceAppArgsAnnotation, Array.Empty<AppLaunchArgumentAnnotation>()); 422executable.Annotate(DcpCustomResource.ResourceNameAnnotation, project.Name); 429DcpCustomResource.ResourceAppArgsAnnotation, 466executable.Annotate(DcpCustomResource.ResourceNameAnnotation, project.Name); 495executable.Annotate(DcpCustomResource.ResourceNameAnnotation, project.Name); 528executable.Annotate(DcpCustomResource.ResourceNameAnnotation, project.Name); 552executable.Annotate(DcpCustomResource.ResourceNameAnnotation, project.Name); 575executable.Annotate(DcpCustomResource.ResourceNameAnnotation, project.Name); 603executable.Annotate(DcpCustomResource.ResourceNameAnnotation, resource.Name); 635executable.Annotate(DcpCustomResource.ResourceNameAnnotation, project.Name); 663executable.Annotate(DcpCustomResource.ResourceNameAnnotation, resource.Name); 785executable.SetAnnotationAsObjectList(DcpCustomResource.ResourceAppArgsAnnotation, launchArgumentAnnotations);

25CustomResource Resource); 31public ConcurrentQueue<CustomResource> CreatedResources { get; } = []; 39private readonly List<Channel<(WatchEventType, CustomResource)>> _watchChannels = []; 40private readonly Func<CustomResource, string, bool?, Stream> _startStream; 42private readonly Action<CustomResource>? _beforeCreate; 43private readonly Func<CustomResource, CancellationToken, Task>? _beforeCreateAsync; 54Func<CustomResource, string, Stream>? startStream = null, 56Func<CustomResource, string, bool?, Stream>? startStreamWithFollow = null, 57Action<CustomResource>? beforeCreate = null, 58Func<CustomResource, CancellationToken, Task>? beforeCreateAsync = null, 77public Task<T> GetAsync<T>(string name, string? namespaceParameter = null, CancellationToken _ = default) where T : CustomResource, IKubernetesStaticMetadata 98public async Task<T> CreateAsync<T>(T obj, CancellationToken cancellationToken = default) where T : CustomResource, IKubernetesStaticMetadata 115svc.Metadata.Annotations?.ContainsKey(CustomResource.ContainerTunnelInstanceName) is true) 151foreach (var modifiedResource in modifiedResources) 165public void PushResourceModified(CustomResource resource) 185public void PushResourceUnchanged(CustomResource resource, WatchEventType eventType = WatchEventType.Modified) 200public void PushResourceDeleted(CustomResource resource) 218foreach (var res in CreatedResources.Where(r => !DeletedResources.Contains(r.Metadata.Name))) 232private void StampResourceUid(CustomResource resource) 245private void StampResourceVersion(CustomResource resource) 250private static T Copy<T>(T resource) where T : CustomResource 257private List<CustomResource> AllocateProxylessContainerServicePorts(CustomResource resource) 260container.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var servicesProduced) is not true) 265var modifiedResources = new List<CustomResource>(); 289public async Task<T> DeleteAsync<T>(string name, string? namespaceParameter = null, CancellationToken cancellationToken = default) where T : CustomResource, IKubernetesStaticMetadata 309public Task<List<T>> ListAsync<T>(string? namespaceParameter = null, CancellationToken cancellationToken = default) where T : CustomResource, IKubernetesStaticMetadata 317public async IAsyncEnumerable<(WatchEventType, T)> WatchAsync<T>(string? namespaceParameter = null, [EnumeratorCancellation] CancellationToken cancellationToken = default) where T : CustomResource, IKubernetesStaticMetadata 319var chan = Channel.CreateUnbounded<(WatchEventType, CustomResource)>(); 380) where T : CustomResource, IKubernetesStaticMetadata 385public 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