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)
1199var k8sResource = new KubernetesResource("api-k8s", project.Resource, envResource); 1222var k8sResource = new KubernetesResource("cache-k8s", container.Resource, envResource);
53 references to KubernetesResource
Aspire.Hosting.Azure.Kubernetes (1)
AzureKubernetesEnvironmentResource.AksPipeline.cs (1)
102kubeResource.Parameters["identityClientId"] = new KubernetesResource.HelmValue(
Aspire.Hosting.Kubernetes (48)
Deployment\HelmDeploymentEngine.cs (1)
514KubernetesResource 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) 434private static ContainerV1 WithContainerProbes(this ContainerV1 container, KubernetesResource context) 462private 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) 1098Dictionary<IResource, KubernetesResource> deploymentTargets, 1274Dictionary<IResource, KubernetesResource> deploymentTargets, 1280if (!deploymentTargets.TryGetValue(targetResource, out var k8sResource))
KubernetesPersistentVolumeExtensions.cs (2)
329/// <see cref="KubernetesServiceExtensions.PublishAsKubernetesService{T}(IResourceBuilder{T}, Action{KubernetesResource})"/> 393/// <see cref="KubernetesServiceExtensions.PublishAsKubernetesService{T}(IResourceBuilder{T}, Action{KubernetesResource})"/>
KubernetesPublishingContext.cs (7)
81if (resource.GetDeploymentTargetAnnotation(targetEnv)?.DeploymentTarget is KubernetesResource serviceResource) 185private async Task AppendResourceContextToHelmValuesAsync(IResource resource, KubernetesResource resourceContext) 210private static Dictionary<string, KubernetesResource.HelmValue> MergeHelmValueMappings( 213params (IReadOnlyDictionary<string, KubernetesResource.HelmValue> Values, string OriginKind)[] mappingGroups) 216var result = new Dictionary<string, KubernetesResource.HelmValue>(StringComparer.Ordinal); 256Dictionary<string, KubernetesResource.HelmValue> contextItems, 467private static void ApplyNodePoolSelector(KubernetesResource serviceResource, KubernetesNodePoolResource nodePool)
KubernetesResource.cs (2)
555var referencedResource = ep.Resource == this 598var 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)
1199var k8sResource = new KubernetesResource("api-k8s", project.Resource, envResource); 1222var k8sResource = new KubernetesResource("cache-k8s", container.Resource, envResource);
KubernetesEnvironmentResourceTests.cs (2)
259var service = Assert.IsType<KubernetesResource>(containerK8sResource.GetDeploymentTargetAnnotation()!.DeploymentTarget);