From 15ecd262078c72edf54b7493bff7f40dbfb79190 Mon Sep 17 00:00:00 2001 From: "naiyuantian@microsoft.com" Date: Wed, 21 Jan 2026 10:16:51 -0800 Subject: [PATCH] initial commit --- .../OrchestrationService/NetheriteOrchestrationService.cs | 6 +++--- src/DurableTask.Netherite/Scaling/AzureBlobLoadPublisher.cs | 2 +- .../Scaling/AzureTableLoadPublisher.cs | 2 +- src/common.props | 2 +- 4 files changed, 6 insertions(+), 6 deletions(-) diff --git a/src/DurableTask.Netherite/OrchestrationService/NetheriteOrchestrationService.cs b/src/DurableTask.Netherite/OrchestrationService/NetheriteOrchestrationService.cs index 4fc5081c..01c2829f 100644 --- a/src/DurableTask.Netherite/OrchestrationService/NetheriteOrchestrationService.cs +++ b/src/DurableTask.Netherite/OrchestrationService/NetheriteOrchestrationService.cs @@ -82,7 +82,7 @@ internal async ValueTask GetClientAsync() Client client; Client checkedClient; - internal NetheriteOrchestrationServiceSettings Settings { get; private set; } + public NetheriteOrchestrationServiceSettings Settings { get; private set; } internal uint NumberPartitions { get; private set; } internal string PathPrefix { get; private set; } internal string ContainerName { get; private set; } @@ -252,14 +252,14 @@ public bool TryGetScalingMonitor(out ScalingMonitor monitor) return false; } - internal ILoadPublisherService GetLoadPublisher() + public ILoadPublisherService GetLoadPublisher() { return string.IsNullOrEmpty(this.Settings.LoadInformationAzureTableName) ? new AzureBlobLoadPublisher(this.Settings.BlobStorageConnection, this.Settings.HubName, this.Settings.TaskhubParametersFilePath) : new AzureTableLoadPublisher(this.Settings.TableStorageConnection, this.Settings.LoadInformationAzureTableName, this.Settings.HubName); } - internal NetheriteMetricsProvider GetNetheriteMetricsProvider(ILoadPublisherService loadPublisher, ConnectionInfo eventHubsConnection) + public NetheriteMetricsProvider GetNetheriteMetricsProvider(ILoadPublisherService loadPublisher, ConnectionInfo eventHubsConnection) { return new NetheriteMetricsProvider(loadPublisher, eventHubsConnection); } diff --git a/src/DurableTask.Netherite/Scaling/AzureBlobLoadPublisher.cs b/src/DurableTask.Netherite/Scaling/AzureBlobLoadPublisher.cs index 41f5fcea..6b2f528d 100644 --- a/src/DurableTask.Netherite/Scaling/AzureBlobLoadPublisher.cs +++ b/src/DurableTask.Netherite/Scaling/AzureBlobLoadPublisher.cs @@ -18,7 +18,7 @@ namespace DurableTask.Netherite.Scaling using System.Threading; using System.Threading.Tasks; - class AzureBlobLoadPublisher : ILoadPublisherService + public class AzureBlobLoadPublisher : ILoadPublisherService { readonly string taskHubName; readonly BlobContainerClient blobContainerClient; diff --git a/src/DurableTask.Netherite/Scaling/AzureTableLoadPublisher.cs b/src/DurableTask.Netherite/Scaling/AzureTableLoadPublisher.cs index 033dcf90..7c3837e2 100644 --- a/src/DurableTask.Netherite/Scaling/AzureTableLoadPublisher.cs +++ b/src/DurableTask.Netherite/Scaling/AzureTableLoadPublisher.cs @@ -14,7 +14,7 @@ namespace DurableTask.Netherite.Scaling using System.Threading; using System.Threading.Tasks; - class AzureTableLoadPublisher : ILoadPublisherService + public class AzureTableLoadPublisher : ILoadPublisherService { readonly TableClient table; readonly string taskHubName; diff --git a/src/common.props b/src/common.props index b0ad35e2..90bce840 100644 --- a/src/common.props +++ b/src/common.props @@ -4,7 +4,7 @@ 3 1 - 0 + 1 $(MajorVersion).$(MinorVersion).$(PatchVersion) $(MajorVersion).0.0.0