Implemented interface member:
68 references to Metadata
Aspire.Hosting (68)
Dcp\AppResource.cs (1)
15
public string DcpResourceName => DcpResource.
Metadata
.Name;
Dcp\DcpExecutor.cs (30)
347
if (_logStreams.TryRemove(resource.
Metadata
.Name, out var logStream))
355
_logger.LogTrace("Deleting application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.
Metadata
.Name);
362
_logger.LogTrace("Updating application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.
Metadata
.Name);
367
await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, resourceType, appModelResource, resource.
Metadata
.Name, status, s => snapshotFactory(resource, s))).ConfigureAwait(false);
372
_logInformationChannel.Writer.TryWrite(new(resource.
Metadata
.Name, LogsAvailable: true, HasSubscribers: null));
381
_logger.LogTrace("No application model resource found for {ResourceKind} resource {ResourceName}", resourceKind, resource.
Metadata
.Name);
392
_resourceState.ResourceAssociatedServicesMap.Remove((resourceKind, resource.
Metadata
.Name), out _);
394
else if (resource.
Metadata
.Annotations?.TryGetValue(CustomResource.ServiceProducerAnnotation, out var servicesProducedAnnotationJson) == true)
399
_resourceState.ResourceAssociatedServicesMap[(resourceKind, resource.
Metadata
.Name)]
490
_logStreams.GetOrAdd(resource.
Metadata
.Name, (_) =>
500
_logger.LogDebug("Starting log streaming for {ResourceName}.", resource.
Metadata
.Name);
504
var logger = _loggerService.GetInternalLogger(resource.
Metadata
.Name);
517
_logger.LogDebug("Log streaming for {ResourceName} was cancelled.", resource.
Metadata
.Name);
521
_logger.LogError(ex, "Error streaming logs for {ResourceName}.", resource.
Metadata
.Name);
537
if (endpoint.
Metadata
.OwnerReferences is null)
542
foreach (var ownerReference in endpoint.
Metadata
.OwnerReferences)
555
foreach (var ((resourceKind, resourceName), _) in _resourceState.ResourceAssociatedServicesMap.Where(e => e.Value.Contains(service.
Metadata
.Name)))
600
map.TryAdd(resource.
Metadata
.Name, resource);
604
map[resource.
Metadata
.Name] = resource;
608
map.Remove(resource.
Metadata
.Name, out _);
647
var srvResource = needAddressAllocated.FirstOrDefault(sr => sr.Service.
Metadata
.Name == updated.
Metadata
.Name);
670
var dcpSvc = await _kubernetesService.GetAsync<Service>(sar.Service.
Metadata
.Name, cancellationToken: cancellationToken).ConfigureAwait(false);
677
_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);
726
throw new InvalidDataException($"Service {svc.
Metadata
.Name} should have valid address at this point");
731
throw new InvalidOperationException($"Service '{svc.
Metadata
.Name}' needs to specify a port for endpoint '{sp.EndpointAnnotation.Name}' since it isn't using a proxy.");
739
targetPortExpression: $$$"""{{- portForServing "{{{svc.
Metadata
.Name}}}" -}}""");
1418
if (resource is Executable exe && exe.
Metadata
.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1)
1483
var cu = await _kubernetesService.GetAsync<Container>(c.
Metadata
.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1498
var eu = await _kubernetesService.GetAsync<Executable>(e.
Metadata
.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
Dcp\KubernetesService.cs (4)
158
obj.
Metadata
.Name,
166
obj.
Metadata
.Name,
306
obj.
Metadata
.Name,
308
obj.
Metadata
.Namespace(),
Dcp\Model\Container.cs (2)
522
c.
Metadata
.Name = name;
523
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\ResourceSnapshotBuilder.cs (4)
57
CreationTimeStamp = container.
Metadata
.CreationTimestamp?.ToUniversalTime(),
131
CreationTimeStamp = executable.
Metadata
.CreationTimestamp?.ToUniversalTime(),
153
CreationTimeStamp = executable.
Metadata
.CreationTimestamp?.ToUniversalTime(),
199
var name = resource.
Metadata
.Name;