3 instantiations of KubernetesResource
Aspire.Hosting.Kubernetes (1)
KubernetesEnvironmentContext.cs (1)
24var serviceResource = new KubernetesResource(resource.Name, resource, environment);
Aspire.Hosting.Kubernetes.Tests (2)
KubernetesDeployTests.cs (2)
1201var k8sResource = new KubernetesResource("api-k8s", project.Resource, envResource); 1224var k8sResource = new KubernetesResource("cache-k8s", container.Resource, envResource);
53 references to KubernetesResource
Aspire.Hosting.Azure.Kubernetes (1)
AzureKubernetesEnvironmentResource.AksPipeline.cs (1)
107kubeResource.Parameters["identityClientId"] = new KubernetesResource.HelmValue(
Aspire.Hosting.Kubernetes (48)
Deployment\HelmDeploymentEngine.cs (1)
517KubernetesResource k8sResource)
Extensions\ResourceExtensions.cs (17)
14internal static Deployment ToDeployment(this IResource resource, KubernetesResource context) 43internal static StatefulSet ToStatefulSet(this IResource resource, KubernetesResource context) 63internal static Secret? ToSecret(this IResource resource, KubernetesResource context) 97internal static ConfigMap? ToConfigMap(this IResource resource, KubernetesResource context) 129internal static Service? ToService(this IResource resource, KubernetesResource context) 186private static PodTemplateSpecV1 ToPodTemplateSpec(this IResource resource, KubernetesResource context) 206private static PodTemplateSpecV1 WithPodSpecVolumes(this PodTemplateSpecV1 podTemplateSpec, KubernetesResource context) 295private static ContainerV1 ToContainerV1(this IResource resource, KubernetesResource context) 314private static ContainerV1 WithContainerVolumes(this ContainerV1 container, KubernetesResource context) 338private static ContainerV1 WithContainerPorts(this ContainerV1 container, KubernetesResource context) 368private static ContainerV1 WithContainerImage(this ContainerV1 container, KubernetesResource context) 375private static ContainerV1 WithContainerEntrypoint(this ContainerV1 container, KubernetesResource context) 385private static ContainerV1 WithContainerArgs(this ContainerV1 container, KubernetesResource context) 400private static ContainerV1 WithContainerEnvironmentalVariables(this ContainerV1 container, KubernetesResource context) 417private static ContainerV1 WithContainerSecrets(this ContainerV1 container, KubernetesResource context) 435private static ContainerV1 WithContainerProbes(this ContainerV1 container, KubernetesResource context) 464private static PersistentVolumeClaim CreatePersistentVolumeClaim(KubernetesResource context, VolumeMountV1 volume)
KubernetesEnvironmentContext.cs (4)
11private readonly Dictionary<IResource, KubernetesResource> _kubernetesComponents = new(new ResourceNameComparer()); 15public async Task<KubernetesResource> CreateKubernetesResourceAsync(IResource resource, DistributedApplicationExecutionContext executionContext, CancellationToken cancellationToken) 17if (_kubernetesComponents.TryGetValue(resource, out var existingResource)) 24var serviceResource = new KubernetesResource(resource.Name, resource, environment);
KubernetesEnvironmentResource.cs (12)
448var dashboardService = await environmentContext.CreateKubernetesResourceAsync(dashboard, executionContext, cancellationToken).ConfigureAwait(false); 462var deploymentTargets = new Dictionary<IResource, KubernetesResource>(new ResourceNameComparer()); 491if (existingTarget.DeploymentTarget is KubernetesResource existingServiceResource) 506var serviceResource = await environmentContext.CreateKubernetesResourceAsync(r, executionContext, cancellationToken).ConfigureAwait(false); 723private async Task ProcessIngressResources(DistributedApplicationModel model, Dictionary<IResource, KubernetesResource> deploymentTargets, ILogger logger, CancellationToken cancellationToken) 763Dictionary<IResource, KubernetesResource> deploymentTargets, 928Dictionary<IResource, KubernetesResource> deploymentTargets, 934if (!deploymentTargets.TryGetValue(targetResource, out var k8sResource)) 964private async Task ProcessGatewayResources(DistributedApplicationModel model, Dictionary<IResource, KubernetesResource> deploymentTargets, ILogger logger, CancellationToken cancellationToken) 1061Dictionary<IResource, KubernetesResource> deploymentTargets, 1237Dictionary<IResource, KubernetesResource> deploymentTargets, 1243if (!deploymentTargets.TryGetValue(targetResource, out var k8sResource))
KubernetesPersistentVolumeExtensions.cs (2)
246/// <see cref="KubernetesServiceExtensions.PublishAsKubernetesService{T}(IResourceBuilder{T}, Action{KubernetesResource})"/> 310/// <see cref="KubernetesServiceExtensions.PublishAsKubernetesService{T}(IResourceBuilder{T}, Action{KubernetesResource})"/>
KubernetesPublishingContext.cs (7)
82if (resource.GetDeploymentTargetAnnotation(targetEnv)?.DeploymentTarget is KubernetesResource serviceResource) 186private async Task AppendResourceContextToHelmValuesAsync(IResource resource, KubernetesResource resourceContext) 211private static Dictionary<string, KubernetesResource.HelmValue> MergeHelmValueMappings( 214params (IReadOnlyDictionary<string, KubernetesResource.HelmValue> Values, string OriginKind)[] mappingGroups) 217var result = new Dictionary<string, KubernetesResource.HelmValue>(StringComparer.Ordinal); 257Dictionary<string, KubernetesResource.HelmValue> contextItems, 468private static void ApplyNodePoolSelector(KubernetesResource serviceResource, KubernetesNodePoolResource nodePool)
KubernetesResource.cs (2)
535var referencedResource = ep.Resource == this 578var referencedResource = epExpr.Endpoint.Resource == this
KubernetesServiceCustomizationAnnotation.cs (2)
15public sealed class KubernetesServiceCustomizationAnnotation(Action<KubernetesResource> configure) : IResourceAnnotation 20public Action<KubernetesResource> Configure { get; } = configure ?? throw new ArgumentNullException(nameof(configure));
KubernetesServiceExtensions.cs (1)
34public static IResourceBuilder<T> PublishAsKubernetesService<T>(this IResourceBuilder<T> builder, Action<KubernetesResource> configure)
Aspire.Hosting.Kubernetes.Tests (4)
KubernetesDeployTests.cs (2)
1201var k8sResource = new KubernetesResource("api-k8s", project.Resource, envResource); 1224var k8sResource = new KubernetesResource("cache-k8s", container.Resource, envResource);
KubernetesEnvironmentResourceTests.cs (2)
259var service = Assert.IsType<KubernetesResource>(containerK8sResource.GetDeploymentTargetAnnotation()!.DeploymentTarget);