Implemented interface member:
64 references to Metadata
Aspire.Hosting (64)
Dcp\AppResource.cs (1)
15
public string DcpResourceName => DcpResource.
Metadata
.Name;
Dcp\DcpExecutor.cs (28)
344
if (_logStreams.TryRemove(resource.
Metadata
.Name, out var logStream))
352
_logger.LogTrace("Deleting application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.
Metadata
.Name);
359
_logger.LogTrace("Updating application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.
Metadata
.Name);
364
await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, resourceType, appModelResource, resource.
Metadata
.Name, status, s => snapshotFactory(resource, s))).ConfigureAwait(false);
369
_logInformationChannel.Writer.TryWrite(new(resource.
Metadata
.Name, LogsAvailable: true, HasSubscribers: null));
378
_logger.LogTrace("No application model resource found for {ResourceKind} resource {ResourceName}", resourceKind, resource.
Metadata
.Name);
389
_resourceState.ResourceAssociatedServicesMap.Remove((resourceKind, resource.
Metadata
.Name), out _);
391
else if (resource.
Metadata
.Annotations?.TryGetValue(CustomResource.ServiceProducerAnnotation, out var servicesProducedAnnotationJson) == true)
396
_resourceState.ResourceAssociatedServicesMap[(resourceKind, resource.
Metadata
.Name)]
443
_logStreams.GetOrAdd(resource.
Metadata
.Name, (_) =>
453
_logger.LogDebug("Starting log streaming for {ResourceName}.", resource.
Metadata
.Name);
457
var logger = _loggerService.GetInternalLogger(resource.
Metadata
.Name);
479
_logger.LogDebug("Log streaming for {ResourceName} was cancelled.", resource.
Metadata
.Name);
483
_logger.LogError(ex, "Error streaming logs for {ResourceName}.", resource.
Metadata
.Name);
499
if (endpoint.
Metadata
.OwnerReferences is null)
504
foreach (var ownerReference in endpoint.
Metadata
.OwnerReferences)
517
foreach (var ((resourceKind, resourceName), _) in _resourceState.ResourceAssociatedServicesMap.Where(e => e.Value.Contains(service.
Metadata
.Name)))
562
map.TryAdd(resource.
Metadata
.Name, resource);
566
map[resource.
Metadata
.Name] = resource;
570
map.Remove(resource.
Metadata
.Name, out _);
609
var srvResource = needAddressAllocated.FirstOrDefault(sr => sr.Service.
Metadata
.Name == updated.
Metadata
.Name);
632
var dcpSvc = await _kubernetesService.GetAsync<Service>(sar.Service.
Metadata
.Name, cancellationToken: cancellationToken).ConfigureAwait(false);
639
_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);
688
throw new InvalidDataException($"Service {svc.
Metadata
.Name} should have valid address at this point");
693
throw new InvalidOperationException($"Service '{svc.
Metadata
.Name}' needs to specify a port for endpoint '{sp.EndpointAnnotation.Name}' since it isn't using a proxy.");
701
targetPortExpression: $$$"""{{- portForServing "{{{svc.
Metadata
.Name}}}" -}}""");
1340
if (resource is Executable exe && exe.
Metadata
.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1)
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)
370
c.
Metadata
.Name = name;
371
c.
Metadata
.NamespaceProperty = string.Empty;
Dcp\Model\ContainerExec.cs (2)
132
containerExec.
Metadata
.Name = name;
133
containerExec.
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)
205
exe.
Metadata
.Name = name;
206
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(),
188
var name = resource.
Metadata
.Name;