WIP

dotnet · Mar 25, 2024 · d099b79 · d099b79
1 parent ca3897a
commit d099b79
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 6 deletions.
diff --git a/src/Aspire.Hosting.Azure.PostgreSql/AzurePostgresExtensions.cs b/src/Aspire.Hosting.Azure.PostgreSql/AzurePostgresExtensions.cs
@@ -91,7 +91,6 @@ internal static IResourceBuilder<PostgresServerResource> PublishAsAzurePostgresF
 
         var resource = new AzurePostgresResource(builder.Resource, configureConstruct);
         var resourceBuilder = builder.ApplicationBuilder.CreateResourceBuilder(resource)
-                                                        .WithParameter(AzureBicepResource.KnownParameters.PrincipalId)
                                                         .WithParameter(AzureBicepResource.KnownParameters.KeyVaultName)
                                                         .WithManifestPublishingCallback(resource.WriteToManifest)
                                                         .WithLoginAndPassword(builder.Resource);

diff --git a/src/Aspire.Hosting/Dcp/KubernetesService.cs b/src/Aspire.Hosting/Dcp/KubernetesService.cs
@@ -8,6 +8,7 @@
 using k8s.Exceptions;
 using k8s.Models;
 using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
 using Polly;
 using Polly.Retry;
 
@@ -42,7 +43,7 @@ Task<Stream> GetLogStreamAsync<T>(
         CancellationToken cancellationToken = default) where T : CustomResource;
 }
 
-internal sealed class KubernetesService(ILogger<KubernetesService> logger, DcpOptions dcpOptions, Locations locations) : IKubernetesService, IDisposable
+internal sealed class KubernetesService(ILogger<KubernetesService> logger, IOptions<DcpOptions> dcpOptions, Locations locations) : IKubernetesService, IDisposable
 {
     private static readonly TimeSpan s_initialRetryDelay = TimeSpan.FromMilliseconds(100);
     private static GroupVersion GroupVersion => Model.Dcp.GroupVersion;
@@ -309,8 +310,8 @@ private void EnsureKubernetes()
             {
                 ShouldHandle = new PredicateBuilder().Handle<IOException>(e => e.Message.StartsWith("The process cannot access the file")),
                 BackoffType = DelayBackoffType.Constant,
-                MaxRetryAttempts = dcpOptions.KubernetesConfigReadRetryCount,
-                MaxDelay = TimeSpan.FromSeconds(dcpOptions.KubernetesConfigReadRetryIntervalSeconds),
+                MaxRetryAttempts = dcpOptions.Value.KubernetesConfigReadRetryCount,
+                MaxDelay = TimeSpan.FromSeconds(dcpOptions.Value.KubernetesConfigReadRetryIntervalSeconds),
                 OnRetry = (retry) =>
                 {
                     logger.LogDebug(
@@ -326,10 +327,11 @@ private void EnsureKubernetes()
 
             pipeline.Execute(() =>
             {
+                logger.LogDebug("Reading Kubernetes configuration from '{DcpKubeconfigPath}' on thread {ThreadId}.", locations.DcpKubeconfigPath, Environment.CurrentManagedThreadId);
                 var config = KubernetesClientConfiguration.BuildConfigFromConfigFile(kubeconfigPath: locations.DcpKubeconfigPath, useRelativePaths: false);
+                logger.LogDebug("Successfully read Kubernetes configuration from '{DcpKubeconfigPath}'.", locations.DcpKubeconfigPath);
                 _kubernetes = new DcpKubernetesClient(config);
             });
-
         }
     }
 }
diff --git a/tests/testproject/TestProject.IntegrationServiceA/appsettings.json b/tests/testproject/TestProject.IntegrationServiceA/appsettings.json
@@ -2,7 +2,8 @@
   "Logging": {
     "LogLevel": {
       "Default": "Information",
-      "Microsoft.AspNetCore": "Warning"
+      "Microsoft.AspNetCore": "Warning",
+      "Aspire.Hosting.Dcp": "Debug"
     }
   },
   "AllowedHosts": "*"