Implemented interface member:
78 references to Metadata
Aspire.Hosting (78)
Dcp\AppResource.cs (1)
15public string DcpResourceName => DcpResource.Metadata.Name;
Dcp\DcpExecutor.cs (36)
352if (_logStreams.TryRemove(resource.Metadata.Name, out var logStream)) 360_logger.LogTrace("Deleting application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.Metadata.Name); 367_logger.LogTrace("Updating application model resource {ResourceName} with {ResourceKind} resource {ResourceName}", appModelResource.Name, resourceKind, resource.Metadata.Name); 372await _executorEvents.PublishAsync(new OnResourceChangedContext(_shutdownCancellation.Token, resourceType, appModelResource, resource.Metadata.Name, status, s => snapshotFactory(resource, s))).ConfigureAwait(false); 377_logInformationChannel.Writer.TryWrite(new(resource.Metadata.Name, LogsAvailable: true, HasSubscribers: null)); 386_logger.LogTrace("No application model resource found for {ResourceKind} resource {ResourceName}", resourceKind, resource.Metadata.Name); 397_resourceState.ResourceAssociatedServicesMap.Remove((resourceKind, resource.Metadata.Name), out _); 399else if (resource.Metadata.Annotations?.TryGetValue(CustomResource.ServiceProducerAnnotation, out var servicesProducedAnnotationJson) == true) 404_resourceState.ResourceAssociatedServicesMap[(resourceKind, resource.Metadata.Name)] 495_logStreams.GetOrAdd(resource.Metadata.Name, (_) => 505_logger.LogDebug("Starting log streaming for {ResourceName}.", resource.Metadata.Name); 509var logger = _loggerService.GetInternalLogger(resource.Metadata.Name); 522_logger.LogDebug("Log streaming for {ResourceName} was cancelled.", resource.Metadata.Name); 526_logger.LogError(ex, "Error streaming logs for {ResourceName}.", resource.Metadata.Name); 542if (endpoint.Metadata.OwnerReferences is null) 547foreach (var ownerReference in endpoint.Metadata.OwnerReferences) 560foreach (var ((resourceKind, resourceName), _) in _resourceState.ResourceAssociatedServicesMap.Where(e => e.Value.Contains(service.Metadata.Name))) 605map.TryAdd(resource.Metadata.Name, resource); 609map[resource.Metadata.Name] = resource; 613map.Remove(resource.Metadata.Name, out _); 652var srvResource = needAddressAllocated.FirstOrDefault(sr => sr.Service.Metadata.Name == updated.Metadata.Name); 675var dcpSvc = await _kubernetesService.GetAsync<Service>(sar.Service.Metadata.Name, cancellationToken: cancellationToken).ConfigureAwait(false); 682_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); 731throw new InvalidDataException($"Service {svc.Metadata.Name} should have valid address at this point"); 736throw new InvalidOperationException($"Service '{svc.Metadata.Name}' needs to specify a port for endpoint '{sp.EndpointAnnotation.Name}' since it isn't using a proxy."); 744targetPortExpression: $$$"""{{- portForServing "{{{svc.Metadata.Name}}}" -}}"""); 961await _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); 974await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 982await _executorEvents.PublishAsync(new OnResourceFailedToStartContext(cancellationToken, resourceType, er.ModelResource, er.DcpResource.Metadata.Name)).ConfigureAwait(false); 1243await _executorEvents.PublishAsync(new OnResourceStartingContext(cancellationToken, KnownResourceTypes.Container, cr.ModelResource, cr.DcpResource.Metadata.Name)).ConfigureAwait(false); 1415var spAnn = new ServiceProducerAnnotation(sp.Service.Metadata.Name); 1423if (resource is Executable exe && exe.Metadata.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1) 1488var cu = await _kubernetesService.GetAsync<Container>(c.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 1503var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 1530.SingleOrDefault(r => string.Equals(r.DcpResource.Metadata.Name, resourceName, StringComparisons.ResourceName));
Dcp\KubernetesService.cs (4)
158obj.Metadata.Name, 166obj.Metadata.Name, 306obj.Metadata.Name, 308obj.Metadata.Namespace(),
Dcp\Model\Container.cs (2)
533c.Metadata.Name = name; 534c.Metadata.NamespaceProperty = string.Empty;
Dcp\Model\ContainerExec.cs (2)
132containerExec.Metadata.Name = name; 133containerExec.Metadata.NamespaceProperty = string.Empty;
Dcp\Model\ContainerVolume.cs (2)
78containerVolume.Metadata.Name = name; 79containerVolume.Metadata.NamespaceProperty = string.Empty;
Dcp\Model\Endpoint.cs (2)
48e.Metadata.Name = name; 49e.Metadata.NamespaceProperty = string.Empty;
Dcp\Model\Executable.cs (2)
237exe.Metadata.Name = name; 238exe.Metadata.NamespaceProperty = string.Empty;
Dcp\Model\ExecutableReplicaSet.cs (2)
107ers.Metadata.Name = name; 108ers.Metadata.NamespaceProperty = string.Empty;
Dcp\Model\ModelCommon.cs (12)
33public string? AppModelResourceName => Metadata.Annotations?.TryGetValue(ResourceNameAnnotation, out var value) is true ? value : null; 35public string? AppModelInitialState => Metadata.Annotations?.TryGetValue(ResourceStateAnnotation, out var value) is true ? value : null; 42if (Metadata.Annotations is null) 44Metadata.Annotations = new Dictionary<string, string>(); 47Metadata.Annotations[annotationName] = value; 52if (Metadata.Annotations is null) 54Metadata.Annotations = new Dictionary<string, string>(); 57AnnotateAsObjectList<TValue>(Metadata.Annotations, annotationName, value); 62if (Metadata.Annotations is null) 64Metadata.Annotations = new Dictionary<string, string>(); 67Metadata.Annotations[annotationName] = JsonSerializer.Serialize<List<TValue>>(list.ToList()); 72return TryGetAnnotationAsObjectList<TValue>(Metadata.Annotations, annotationName, out list);
Dcp\Model\Network.cs (2)
91c.Metadata.Name = name; 92c.Metadata.NamespaceProperty = string.Empty;
Dcp\Model\Service.cs (3)
81s.Metadata.Name = name; 82s.Metadata.NamespaceProperty = string.Empty; 91public string? EndpointName => Metadata.Annotations?.TryGetValue(EndpointNameAnnotation, out var value) is true ? value : null;
Dcp\ResourceLogSource.cs (2)
85logger.LogWarning("Failed to write log entry to channel. Logs for {Kind} {Name} may be incomplete", resource.Kind, resource.Metadata.Name); 97logger.LogError(ex, "Unexpected error happened when capturing logs for {Kind} {Name}", resource.Kind, resource.Metadata.Name);
Dcp\ResourceSnapshotBuilder.cs (6)
57CreationTimeStamp = container.Metadata.CreationTimestamp?.ToUniversalTime(), 131CreationTimeStamp = executable.Metadata.CreationTimestamp?.ToUniversalTime(), 153CreationTimeStamp = executable.Metadata.CreationTimestamp?.ToUniversalTime(), 199var name = resource.Metadata.Name; 202var serviceEndpoints = new HashSet<(string EndpointName, string ServiceMetadataName)>(resourceServices.Where(s => !string.IsNullOrEmpty(s.EndpointName)).Select(s => (s.EndpointName!, s.Metadata.Name))); 210var 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;