Implemented interface member:
78 references to Metadata
Aspire.Hosting (78)
Dcp\AppResource.cs (1)
15
public string DcpResourceName => DcpResource.
Metadata
.Name;
Dcp\DcpExecutor.cs (36)
356
if (_logStreams.TryRemove(resource.
Metadata
.Name, out var logStream))
364
_logger.LogTrace("Deleting application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.
Metadata
.Name);
371
_logger.LogTrace("Updating application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.
Metadata
.Name);
376
await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, resourceType, appModelResource, resource.
Metadata
.Name, status, s => snapshotFactory(resource, s))).ConfigureAwait(false);
381
_logInformationChannel.Writer.TryWrite(new(resource.
Metadata
.Name, LogsAvailable: true, HasSubscribers: null));
390
_logger.LogTrace("No application model resource found for {ResourceKind} resource {ResourceName}", resourceKind, resource.
Metadata
.Name);
401
_resourceState.ResourceAssociatedServicesMap.Remove((resourceKind, resource.
Metadata
.Name), out _);
403
else if (resource.
Metadata
.Annotations?.TryGetValue(CustomResource.ServiceProducerAnnotation, out var servicesProducedAnnotationJson) == true)
408
_resourceState.ResourceAssociatedServicesMap[(resourceKind, resource.
Metadata
.Name)]
505
_logStreams.GetOrAdd(resource.
Metadata
.Name, (_) =>
515
_logger.LogDebug("Starting log streaming for {ResourceName}.", resource.
Metadata
.Name);
519
var logger = _loggerService.GetInternalLogger(resource.
Metadata
.Name);
532
_logger.LogDebug("Log streaming for {ResourceName} was cancelled.", resource.
Metadata
.Name);
536
_logger.LogError(ex, "Error streaming logs for {ResourceName}.", resource.
Metadata
.Name);
552
if (endpoint.
Metadata
.OwnerReferences is null)
557
foreach (var ownerReference in endpoint.
Metadata
.OwnerReferences)
570
foreach (var ((resourceKind, resourceName), _) in _resourceState.ResourceAssociatedServicesMap.Where(e => e.Value.Contains(service.
Metadata
.Name)))
615
map.TryAdd(resource.
Metadata
.Name, resource);
619
map[resource.
Metadata
.Name] = resource;
623
map.Remove(resource.
Metadata
.Name, out _);
662
var srvResource = needAddressAllocated.FirstOrDefault(sr => sr.Service.
Metadata
.Name == updated.
Metadata
.Name);
685
var dcpSvc = await _kubernetesService.GetAsync<Service>(sar.Service.
Metadata
.Name, cancellationToken: cancellationToken).ConfigureAwait(false);
692
_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);
748
throw new InvalidDataException($"Service {svc.
Metadata
.Name} should have valid address at this point");
753
throw new InvalidOperationException($"Service '{svc.
Metadata
.Name}' needs to specify a port for endpoint '{sp.EndpointAnnotation.Name}' since it isn't using a proxy.");
761
targetPortExpression: $$$"""{{- portForServing "{{{svc.
Metadata
.Name}}}" -}}""");
978
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);
991
await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.
Metadata
.Name)).ConfigureAwait(false);
999
await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.
Metadata
.Name)).ConfigureAwait(false);
1271
await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResource.
Metadata
.Name)).ConfigureAwait(false);
1443
var spAnn = new ServiceProducerAnnotation(sp.Service.
Metadata
.Name);
1451
if (resource is Executable exe && exe.
Metadata
.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1)
1516
var cu = await _kubernetesService.GetAsync<Container>(c.
Metadata
.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1531
var eu = await _kubernetesService.GetAsync<Executable>(e.
Metadata
.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false);
1558
.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;