1 type derived from CustomResource
Aspire.Hosting (1)
Dcp\Model\ModelCommon.cs (1)
132internal abstract class CustomResource<TSpec, TStatus> : CustomResource
99 references to CustomResource
Aspire.Hosting (64)
Dcp\AppResource.cs (2)
14public CustomResource DcpResource { get; } 19public AppResource(IResource modelResource, CustomResource dcpResource)
Dcp\DcpExecutor.cs (35)
321async Task WatchKubernetesResourceAsync<T>(Func<WatchEventType, T, Task> handler) where T : CustomResource 359private async Task ProcessResourceChange<T>(WatchEventType watchEventType, T resource, ConcurrentDictionary<string, T> resourceByName, string resourceKind, Func<T, CustomResourceSnapshot, CustomResourceSnapshot> snapshotFactory) where T : CustomResource 429else if (resource.Metadata.Annotations?.TryGetValue(CustomResource.ServiceProducerAnnotation, out var servicesProducedAnnotationJson) == true) 481private static string GetResourceType<T>(T resource, IResource appModelResource) where T : CustomResource 492private static ResourceStatus GetResourceStatus(CustomResource resource) 564private void StartLogStream<T>(T resource) where T : CustomResource 655CustomResource? cr = resourceKind switch 692where T : CustomResource 902svc.Annotate(CustomResource.ResourceNameAnnotation, sp.ModelResource.Name); 903svc.Annotate(CustomResource.EndpointNameAnnotation, endpoint.Name); 936containerExec.Annotate(CustomResource.OtelServiceNameAnnotation, containerExecutable.Name); 937containerExec.Annotate(CustomResource.OtelServiceInstanceIdAnnotation, exeInstance.Suffix); 938containerExec.Annotate(CustomResource.ResourceNameAnnotation, containerExecutable.Name); 961exe.Annotate(CustomResource.OtelServiceNameAnnotation, executable.Name); 962exe.Annotate(CustomResource.OtelServiceInstanceIdAnnotation, exeInstance.Suffix); 963exe.Annotate(CustomResource.ResourceNameAnnotation, executable.Name); 993exeSpec.Annotate(CustomResource.OtelServiceNameAnnotation, project.Name); 994exeSpec.Annotate(CustomResource.OtelServiceInstanceIdAnnotation, exeInstance.Suffix); 995exeSpec.Annotate(CustomResource.ResourceNameAnnotation, project.Name); 996exeSpec.Annotate(CustomResource.ResourceReplicaCount, replicas.ToString(CultureInfo.InvariantCulture)); 997exeSpec.Annotate(CustomResource.ResourceReplicaIndex, i.ToString(CultureInfo.InvariantCulture)); 1055exeSpec.SetAnnotationAsObjectList(CustomResource.ResourceProjectArgsAnnotation, projectArgs); 1078annotationHolder.Annotate(CustomResource.ResourceStateAnnotation, state); 1203if (er.DcpResource.TryGetAnnotationAsObjectList<string>(CustomResource.ResourceProjectArgsAnnotation, out var projectArgs) && projectArgs.Count > 0) 1222er.DcpResource.SetAnnotationAsObjectList(CustomResource.ResourceAppArgsAnnotation, launchArgs.Select(a => new AppLaunchArgumentAnnotation(a.Value, isSensitive: a.IsSensitive))); 1326ctr.Annotate(CustomResource.ResourceNameAnnotation, container.Name); 1327ctr.Annotate(CustomResource.OtelServiceNameAnnotation, container.Name); 1328ctr.Annotate(CustomResource.OtelServiceInstanceIdAnnotation, containerObjectInstance.Suffix); 1473dcpContainerResource.SetAnnotationAsObjectList(CustomResource.ResourceAppArgsAnnotation, args.Select(a => new AppLaunchArgumentAnnotation(a.Value, isSensitive: a.IsSensitive))); 1626dcpResource.AnnotateAsObjectList(CustomResource.ServiceProducerAnnotation, spAnn); 1630static bool HasMultipleReplicas(CustomResource resource) 1632if (resource is Executable exe && exe.Metadata.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1) 1669private async Task CreateResourcesAsync<RT>(CancellationToken cancellationToken) where RT : CustomResource 1697private static V1Patch CreatePatch<T>(T obj, Action<T> change) where T : CustomResource 1825async 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; 74) where T : CustomResource; 95where T : CustomResource 126where T : CustomResource 159where T : CustomResource 194where T : CustomResource 224where T : CustomResource 258where T : CustomResource 308long? skip = null) where T : CustomResource 435private 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)
206private static (ImmutableArray<string> Args, ImmutableArray<int>? ArgsAreSensitive, bool IsSensitive)? GetLaunchArgs(CustomResource resource) 208if (!resource.TryGetAnnotationAsObjectList(CustomResource.ResourceAppArgsAnnotation, out List<AppLaunchArgumentAnnotation>? launchArgumentAnnotations)) 231private ImmutableArray<UrlSnapshot> GetUrls(CustomResource resource, string? resourceState) 273private static ImmutableArray<VolumeSnapshot> GetVolumes(CustomResource resource)
OtlpConfigurationExtensions.cs (2)
80context.EnvironmentVariables["OTEL_RESOURCE_ATTRIBUTES"] = "service.instance.id={{- index .Annotations \"" + CustomResource.OtelServiceInstanceIdAnnotation + "\" -}}"; 81context.EnvironmentVariables["OTEL_SERVICE_NAME"] = "{{- index .Annotations \"" + CustomResource.OtelServiceNameAnnotation + "\" -}}";
Aspire.Hosting.Tests (35)
Dcp\DcpExecutorTests.cs (20)
163Assert.True(exe.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations)); 206Assert.True(exe1.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations1)); 224Assert.True(exe2.TryGetAnnotationAsObjectList<AppLaunchArgumentAnnotation>(CustomResource.ResourceAppArgsAnnotation, out var argAnnotations2)); 243Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 275Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 307Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 340Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 397Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 431Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 465Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 556Assert.Equal(expectedName, exe.Metadata.Annotations[CustomResource.OtelServiceNameAnnotation]); 795Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 840Assert.True(dcpExe.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 873Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 908Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 989Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1025Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1062Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1099Assert.True(dcpCtr.TryGetAnnotationAsObjectList<ServiceProducerAnnotation>(CustomResource.ServiceProducerAnnotation, out var spAnnList)); 1268var serviceProducers = JsonSerializer.Deserialize<List<ServiceProducerAnnotation>>(annotations[CustomResource.ServiceProducerAnnotation]);
Dcp\TestKubernetesService.cs (13)
24public ConcurrentQueue<CustomResource> CreatedResources { get; } = []; 27private readonly List<Channel<(WatchEventType, CustomResource)>> _watchChannels = []; 28private readonly Func<CustomResource, string, Stream> _startStream; 32public TestKubernetesService(Func<CustomResource, string, Stream>? startStream = null, bool ignoreDeletes = false) 38public Task<T> GetAsync<T>(string name, string? namespaceParameter = null, CancellationToken _ = default) where T : CustomResource 59public Task<T> CreateAsync<T>(T obj, CancellationToken cancellationToken = default) where T : CustomResource 93public void PushResourceModified(CustomResource resource) 104public async Task<T> DeleteAsync<T>(string name, string? namespaceParameter = null, CancellationToken cancellationToken = default) where T : CustomResource 124public Task<List<T>> ListAsync<T>(string? namespaceParameter = null, CancellationToken cancellationToken = default) where T : CustomResource 132public async IAsyncEnumerable<(WatchEventType, T)> WatchAsync<T>(string? namespaceParameter = null, [EnumeratorCancellation] CancellationToken cancellationToken = default) where T : CustomResource 134var chan = Channel.CreateUnbounded<(WatchEventType, CustomResource)>(); 175) where T : CustomResource 180public Task<T> PatchAsync<T>(T obj, V1Patch patch, CancellationToken cancellationToken = default) where T : CustomResource
Helpers\KubernetesHelper.cs (2)
13public static async Task<T> GetResourceByNameAsync<T>(IKubernetesService kubernetes, string resourceName, string resourceNameSuffix, Func<T, bool> ready, CancellationToken cancellationToken = default) where T : CustomResource 28public static async Task<T> GetResourceByNameMatchAsync<T>(IKubernetesService kubernetes, string resourceNamePattern, Func<T, bool> ready, CancellationToken cancellationToken = default) where T : CustomResource