1 type derived from CustomResource
Aspire.Hosting (1)
Dcp\Model\ModelCommon.cs (1)
132internal abstract class CustomResource<TSpec, TStatus> : CustomResource
61 references to CustomResource
Aspire.Hosting (61)
Dcp\AppResource.cs (2)
14public CustomResource DcpResource { get; } 19public AppResource(IResource modelResource, CustomResource dcpResource)
Dcp\DcpExecutor.cs (32)
287async Task WatchKubernetesResourceAsync<T>(Func<WatchEventType, T, Task> handler) where T : CustomResource 325private async Task ProcessResourceChange<T>(WatchEventType watchEventType, T resource, ConcurrentDictionary<string, T> resourceByName, string resourceKind, Func<T, CustomResourceSnapshot, CustomResourceSnapshot> snapshotFactory) where T : CustomResource 394else if (resource.Metadata.Annotations?.TryGetValue(CustomResource.ServiceProducerAnnotation, out var servicesProducedAnnotationJson) == true) 406private static string GetResourceType<T>(T resource, IResource appModelResource) where T : CustomResource 416private static ResourceStatus GetResourceStatus(CustomResource resource) 473private void StartLogStream<T>(T resource) where T : CustomResource 563CustomResource? cr = resourceKind switch 595where T : CustomResource 780svc.Annotate(CustomResource.ResourceNameAnnotation, sp.ModelResource.Name); 781svc.Annotate(CustomResource.EndpointNameAnnotation, endpoint.Name); 809exe.Annotate(CustomResource.OtelServiceNameAnnotation, executable.Name); 810exe.Annotate(CustomResource.OtelServiceInstanceIdAnnotation, exeInstance.Suffix); 811exe.Annotate(CustomResource.ResourceNameAnnotation, executable.Name); 841exeSpec.Annotate(CustomResource.OtelServiceNameAnnotation, project.Name); 842exeSpec.Annotate(CustomResource.OtelServiceInstanceIdAnnotation, exeInstance.Suffix); 843exeSpec.Annotate(CustomResource.ResourceNameAnnotation, project.Name); 844exeSpec.Annotate(CustomResource.ResourceReplicaCount, replicas.ToString(CultureInfo.InvariantCulture)); 845exeSpec.Annotate(CustomResource.ResourceReplicaIndex, i.ToString(CultureInfo.InvariantCulture)); 903exeSpec.SetAnnotationAsObjectList(CustomResource.ResourceProjectArgsAnnotation, projectArgs); 926annotationHolder.Annotate(CustomResource.ResourceStateAnnotation, state); 1020if (er.DcpResource.TryGetAnnotationAsObjectList<string>(CustomResource.ResourceProjectArgsAnnotation, out var projectArgs) && projectArgs.Count > 0) 1039er.DcpResource.SetAnnotationAsObjectList(CustomResource.ResourceAppArgsAnnotation, launchArgs.Select(a => new AppLaunchArgumentAnnotation(a.Value, isSensitive: a.IsSensitive))); 1135ctr.Annotate(CustomResource.ResourceNameAnnotation, container.Name); 1136ctr.Annotate(CustomResource.OtelServiceNameAnnotation, container.Name); 1137ctr.Annotate(CustomResource.OtelServiceInstanceIdAnnotation, containerObjectInstance.Suffix); 1260dcpContainerResource.SetAnnotationAsObjectList(CustomResource.ResourceAppArgsAnnotation, args.Select(a => new AppLaunchArgumentAnnotation(a.Value, isSensitive: a.IsSensitive))); 1412dcpResource.AnnotateAsObjectList(CustomResource.ServiceProducerAnnotation, spAnn); 1416static bool HasMultipleReplicas(CustomResource resource) 1418if (resource is Executable exe && exe.Metadata.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1) 1426private async Task CreateResourcesAsync<RT>(CancellationToken cancellationToken) where RT : CustomResource 1454private static V1Patch CreatePatch<T>(T obj, Action<T> change) where T : CustomResource 1578async Task EnsureResourceDeletedAsync<T>(string resourceName) where T : CustomResource
Dcp\KubernetesService.cs (15)
38where T : CustomResource; 40where T : CustomResource; 42where T : CustomResource; 44where T : CustomResource; 46where T : CustomResource; 50where T : CustomResource; 56CancellationToken cancellationToken = default) where T : CustomResource; 77where T : CustomResource 108where T : CustomResource 141where T : CustomResource 176where T : CustomResource 206where T : CustomResource 240where T : CustomResource 286CancellationToken cancellationToken = default) where T : CustomResource 397private static string GetResourceFor<T>() where T : CustomResource
Dcp\Model\ExecutableReplicaSet.cs (2)
41CustomResource.AnnotateAsObjectList(Annotations, annotationName, value); 46return CustomResource.TryGetAnnotationAsObjectList(Annotations, annotationName, out list);
Dcp\Model\ModelCommon.cs (1)
147where T : CustomResource
Dcp\Model\Schema.cs (2)
10public void Add<T>(string kind, string resource) where T : CustomResource 15public bool TryGet<T>(out (string Kind, string Resource) kindWithResource) where T : CustomResource
Dcp\ResourceLogSource.cs (1)
19where TResource : CustomResource
Dcp\ResourceSnapshotBuilder.cs (4)
161private static (ImmutableArray<string> Args, ImmutableArray<int>? ArgsAreSensitive, bool IsSensitive)? GetLaunchArgs(CustomResource resource) 163if (!resource.TryGetAnnotationAsObjectList(CustomResource.ResourceAppArgsAnnotation, out List<AppLaunchArgumentAnnotation>? launchArgumentAnnotations)) 186private ImmutableArray<UrlSnapshot> GetUrls(CustomResource resource, string? resourceState) 228private static ImmutableArray<VolumeSnapshot> GetVolumes(CustomResource resource)
OtlpConfigurationExtensions.cs (2)
66context.EnvironmentVariables["OTEL_RESOURCE_ATTRIBUTES"] = "service.instance.id={{- index .Annotations \"" + CustomResource.OtelServiceInstanceIdAnnotation + "\" -}}"; 67context.EnvironmentVariables["OTEL_SERVICE_NAME"] = "{{- index .Annotations \"" + CustomResource.OtelServiceNameAnnotation + "\" -}}";