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