Implemented interface member:
107 references to Metadata
Aspire.Hosting (78)
Dcp\AppResource.cs (1)
15
public string DcpResourceName => DcpResource.
Metadata
.Name;
Dcp\DcpExecutor.cs (36)
376
if (_logStreams.TryRemove(resource.
Metadata
.Name, out var logStream))
384
_logger.LogTrace("Deleting application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.
Metadata
.Name);
391
_logger.LogTrace("Updating application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.
Metadata
.Name);
396
await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, resourceType, appModelResource, resource.
Metadata
.Name, status, s => snapshotFactory(resource, s))).ConfigureAwait(false);
401
_logInformationChannel.Writer.TryWrite(new(resource.
Metadata
.Name, LogsAvailable: true, HasSubscribers: null));
410
_logger.LogTrace("No application model resource found for {ResourceKind} resource {ResourceName}", resourceKind, resource.
Metadata
.Name);
421
_resourceState.ResourceAssociatedServicesMap.Remove((resourceKind, resource.
Metadata
.Name), out _);
423
else if (resource.
Metadata
.Annotations?.TryGetValue(CustomResource.ServiceProducerAnnotation, out var servicesProducedAnnotationJson) == true)
428
_resourceState.ResourceAssociatedServicesMap[(resourceKind, resource.
Metadata
.Name)]
565
_logStreams.GetOrAdd(resource.
Metadata
.Name, (_) =>
575
_logger.LogDebug("Starting log streaming for {ResourceName}.", resource.
Metadata
.Name);
579
var logger = _loggerService.GetInternalLogger(resource.
Metadata
.Name);
592
_logger.LogDebug("Log streaming for {ResourceName} was cancelled.", resource.
Metadata
.Name);
596
_logger.LogError(ex, "Error streaming logs for {ResourceName}.", resource.
Metadata
.Name);
612
if (endpoint.
Metadata
.OwnerReferences is null)
617
foreach (var ownerReference in endpoint.
Metadata
.OwnerReferences)
630
foreach (var ((resourceKind, resourceName), _) in _resourceState.ResourceAssociatedServicesMap.Where(e => e.Value.Contains(service.
Metadata
.Name)))
675
map.TryAdd(resource.
Metadata
.Name, resource);
679
map[resource.
Metadata
.Name] = resource;
683
map.Remove(resource.
Metadata
.Name, out _);
722
var srvResource = needAddressAllocated.FirstOrDefault(sr => sr.Service.
Metadata
.Name == updated.
Metadata
.Name);
745
var dcpSvc = await _kubernetesService.GetAsync<Service>(sar.Service.
Metadata
.Name, cancellationToken: cancellationToken).ConfigureAwait(false);
752
_distributedApplicationLogger.LogWarning("Unable to allocate a network port for service '{ServiceName}'; service may be unreachable and its clients may not work properly.", sar.Service.
Metadata
.Name);
808
throw new InvalidDataException($"Service {svc.
Metadata
.Name} should have valid address at this point");
813
throw new InvalidOperationException($"Service '{svc.
Metadata
.Name}' needs to specify a port for endpoint '{sp.EndpointAnnotation.Name}' since it isn't using a proxy.");
824
targetPortExpression: $$$"""{{- portForServing "{{{svc.
Metadata
.Name}}}" -}}""");
1048
await _executorEvents.PublishAsync(new OnResourceChangedContext(cancellationToken, resourceType, resource, er.DcpResource.
Metadata
.Name, new ResourceStatus(KnownResourceStates.NotStarted, null, null), s => s with { State = new ResourceStateSnapshot(KnownResourceStates.NotStarted, null) })).ConfigureAwait(false);
1061
await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.
Metadata
.Name)).ConfigureAwait(false);
1069
await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.
Metadata
.Name)).ConfigureAwait(false);
1353
await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResource.
Metadata
.Name)).ConfigureAwait(false);
1525
var spAnn = new ServiceProducerAnnotation(sp.Service.
Metadata
.Name);
1534
if (resource is Executable exe && exe.
Metadata
.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1)
1654
var cu = await _kubernetesService.GetAsync<Container>(c.
Metadata
.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1669
var eu = await _kubernetesService.GetAsync<Executable>(e.
Metadata
.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1696
.SingleOrDefault(r => string.Equals(r.DcpResource.
Metadata
.Name, resourceName, StringComparisons.ResourceName));
Dcp\KubernetesService.cs (4)
176
obj.
Metadata
.Name,
184
obj.
Metadata
.Name,
344
obj.
Metadata
.Name,
346
obj.
Metadata
.Namespace(),
Dcp\Model\Container.cs (2)
540
c.
Metadata
.Name = name;
541
c.
Metadata
.NamespaceProperty = string.Empty;
Dcp\Model\ContainerExec.cs (2)
132
containerExec.
Metadata
.Name = name;
133
containerExec.
Metadata
.NamespaceProperty = string.Empty;
Dcp\Model\ContainerVolume.cs (2)
78
containerVolume.
Metadata
.Name = name;
79
containerVolume.
Metadata
.NamespaceProperty = string.Empty;
Dcp\Model\Endpoint.cs (2)
48
e.
Metadata
.Name = name;
49
e.
Metadata
.NamespaceProperty = string.Empty;
Dcp\Model\Executable.cs (2)
237
exe.
Metadata
.Name = name;
238
exe.
Metadata
.NamespaceProperty = string.Empty;
Dcp\Model\ExecutableReplicaSet.cs (2)
107
ers.
Metadata
.Name = name;
108
ers.
Metadata
.NamespaceProperty = string.Empty;
Dcp\Model\ModelCommon.cs (12)
33
public string? AppModelResourceName =>
Metadata
.Annotations?.TryGetValue(ResourceNameAnnotation, out var value) is true ? value : null;
35
public string? AppModelInitialState =>
Metadata
.Annotations?.TryGetValue(ResourceStateAnnotation, out var value) is true ? value : null;
42
if (
Metadata
.Annotations is null)
44
Metadata
.Annotations = new Dictionary<string, string>();
47
Metadata
.Annotations[annotationName] = value;
52
if (
Metadata
.Annotations is null)
54
Metadata
.Annotations = new Dictionary<string, string>();
57
AnnotateAsObjectList<TValue>(
Metadata
.Annotations, annotationName, value);
62
if (
Metadata
.Annotations is null)
64
Metadata
.Annotations = new Dictionary<string, string>();
67
Metadata
.Annotations[annotationName] = JsonSerializer.Serialize<List<TValue>>(list.ToList());
72
return TryGetAnnotationAsObjectList<TValue>(
Metadata
.Annotations, annotationName, out list);
Dcp\Model\Network.cs (2)
91
c.
Metadata
.Name = name;
92
c.
Metadata
.NamespaceProperty = string.Empty;
Dcp\Model\Service.cs (3)
81
s.
Metadata
.Name = name;
82
s.
Metadata
.NamespaceProperty = string.Empty;
91
public string? EndpointName =>
Metadata
.Annotations?.TryGetValue(EndpointNameAnnotation, out var value) is true ? value : null;
Dcp\ResourceLogSource.cs (2)
85
logger.LogWarning("Failed to write log entry to channel. Logs for {Kind} {Name} may be incomplete", resource.Kind, resource.
Metadata
.Name);
97
logger.LogError(ex, "Unexpected error happened when capturing logs for {Kind} {Name}", resource.Kind, resource.
Metadata
.Name);
Dcp\ResourceSnapshotBuilder.cs (6)
62
CreationTimeStamp = container.
Metadata
.CreationTimestamp?.ToUniversalTime(),
136
CreationTimeStamp = executable.
Metadata
.CreationTimestamp?.ToUniversalTime(),
158
CreationTimeStamp = executable.
Metadata
.CreationTimestamp?.ToUniversalTime(),
204
var name = resource.
Metadata
.Name;
207
var serviceEndpoints = new HashSet<(string EndpointName, string ServiceMetadataName)>(resourceServices.Where(s => !string.IsNullOrEmpty(s.EndpointName)).Select(s => (s.EndpointName!, s.
Metadata
.Name)));
215
var activeEndpoint = _resourceState.EndpointsMap.SingleOrDefault(e => e.Value.Spec.ServiceName == serviceName && e.Value.
Metadata
.OwnerReferences?.Any(or => or.Kind == resource.Kind && or.Name == name) == true).Value;
Aspire.Hosting.Tests (29)
Dcp\DcpExecutorTests.cs (12)
45
Assert.Equal("CustomName", container.
Metadata
.Annotations["otel-service-name"]);
208
var reference = appExecutor.GetResource(exe1.
Metadata
.Name);
555
Assert.Equal(expectedName, exe.
Metadata
.Annotations[CustomResource.OtelServiceNameAnnotation]);
593
var watchLogs = resourceLoggerService.WatchAsync(exeResource.
Metadata
.Name);
600
Assert.Equal(exeResource.
Metadata
.Name, watchSubscribersEnumerator.Current.Name);
627
var loggerState = resourceLoggerService.GetResourceLoggerState(exeResource.
Metadata
.Name);
639
Assert.Equal(exeResource.
Metadata
.Name, watchSubscribersEnumerator.Current.Name);
690
var watchLogs1 = resourceLoggerService.WatchAsync(exeResource.
Metadata
.Name);
696
Assert.Equal(exeResource.
Metadata
.Name, watchSubscribersEnumerator.Current.Name);
712
var watchLogs2 = resourceLoggerService.WatchAsync(exeResource.
Metadata
.Name);
1141
var resourceReference = appExecutor.GetResource(dcpCtr.
Metadata
.Name);
1144
Assert.Equal($"Failed to delete '{dcpCtr.
Metadata
.Name}' successfully before restart.", ex.Message);
Dcp\TestKubernetesService.cs (10)
34
_startStream = startStream ?? ((obj, logStreamType) => new MemoryStream(Encoding.UTF8.GetBytes($"Logs for {obj.
Metadata
.Name} ({logStreamType})")));
49
r.
Metadata
.Name == name &&
50
string.Equals(r.
Metadata
.NamespaceProperty ?? string.Empty, namespaceParameter ?? string.Empty)
127
string.Equals(r.
Metadata
.NamespaceProperty ?? string.Empty, namespaceParameter ?? string.Empty)
190
r.
Metadata
.Name == obj.
Metadata
.Name &&
191
string.Equals(r.
Metadata
.NamespaceProperty, obj.
Metadata
.NamespaceProperty)
195
throw new ArgumentException($"Resource '{obj.
Metadata
.NamespaceProperty}/{obj.
Metadata
.Name}' not found");
DistributedApplicationTests.cs (7)
640
await orchestrator.StopResourceAsync(redisContainer.
Metadata
.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
645
await orchestrator.StartResourceAsync(redisContainer.
Metadata
.Name, token);
677
await orchestrator.StopResourceAsync(serviceA.
Metadata
.Name, CancellationToken.None).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
682
await orchestrator.StartResourceAsync(serviceA.
Metadata
.Name, CancellationToken.None).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);
974
Assert.True(resource.Item2.
Metadata
.Annotations.TryGetValue(Container.ResourceNameAnnotation, out var value));
988
Assert.True(resource.Item2.
Metadata
.Annotations.TryGetValue(Executable.ResourceNameAnnotation, out var value));
1229
Assert.All(serviceList.Where(s => s.
Metadata
.Name.Contains("redis")), s => Assert.Equal(AddressAllocationModes.Proxyless, s.Spec.AddressAllocationMode));