Interface for supporting azuremanaged

Author: YunchuWang

samples/LargePayloadConsoleApp/Program.cs

@@ -135,8 +135,6 @@ await ctx.Entities.CallEntityAsync(
 Console.WriteLine($"Deserialized output equals original: {deserializedOutput == largeInput}");
 Console.WriteLine($"Deserialized input length: {deserializedInput.Length}");
 
-
-
 // Run entity samples
 Console.WriteLine();
 Console.WriteLine("Running LargeEntityOperationInput...");
@@ -199,7 +197,4 @@ public void Set(string value)
     {
         this.State = value;
     }
-}
-
-
-
+}

src/Extensions/AzureBlobPayloads/DependencyInjection/DurableTaskClientBuilderExtensions.AzureBlobPayloads.cs

@@ -22,7 +22,6 @@ public static class DurableTaskClientBuilderExtensionsAzureBlobPayloads
     /// <param name="builder">The builder to configure.</param>
     /// <param name="configure">The callback to configure the storage options.</param>
     /// <returns>The original builder, for call chaining.</returns>
-    /// <returns></returns>
     public static IDurableTaskClientBuilder UseExternalizedPayloads(
         this IDurableTaskClientBuilder builder,
         Action<LargePayloadStorageOptions> configure)

src/Extensions/AzureBlobPayloads/DependencyInjection/DurableTaskWorkerBuilderExtensions.AzureBlobPayloads.cs

@@ -1,13 +1,13 @@
 // Copyright (c) Microsoft Corporation.
 // Licensed under the MIT License.
 
+using Grpc.Core.Interceptors;
+using Grpc.Net.Client;
 using Microsoft.DurableTask.Converters;
 using Microsoft.DurableTask.Worker;
+using Microsoft.DurableTask.Worker.Grpc;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Options;
-using Microsoft.DurableTask.Worker.Grpc;
-using Grpc.Net.Client;
-using Grpc.Core.Interceptors;
 
 namespace Microsoft.DurableTask;
 
@@ -64,5 +64,3 @@ public static IDurableTaskWorkerBuilder UseExternalizedPayloads(
         return builder;
     }
 }
-
-

src/Extensions/AzureBlobPayloads/Factories/AzureBlobPayloadCallInvokerFactory.cs

@@ -0,0 +1,27 @@
+// Copyright (c) Microsoft Corporation.
+// Licensed under the MIT License.
+
+using Grpc.Core;
+using Grpc.Core.Interceptors;
+using Grpc.Net.Client;
+
+namespace Microsoft.DurableTask;
+
+/// <summary>
+/// Static factory for creating large payload interceptors without exposing internal implementation details.
+/// </summary>
+public static class AzureBlobPayloadCallInvokerFactory
+{
+    /// <summary>
+    /// Creates a CallInvoker with large payload support interceptor applied to the given GrpcChannel.
+    /// </summary>
+    /// <param name="channel">The gRPC channel to intercept.</param>
+    /// <param name="options">The large payload storage options.</param>
+    /// <returns>A CallInvoker with the large payload interceptor applied.</returns>
+    public static CallInvoker Create(GrpcChannel channel, LargePayloadStorageOptions options)
+    {
+        IPayloadStore payloadStore = new BlobPayloadStore(options);
+        // return channel.Intercept(new AzureBlobPayloadsInterceptor(payloadStore, options));
+        return channel.CreateCallInvoker().Intercept(new AzureBlobPayloadsInterceptor(payloadStore, options));
+    }
+}

src/Extensions/AzureBlobPayloads/Interceptors/AzureBlobPayloadsInterceptor.cs

@@ -13,7 +13,7 @@ namespace Microsoft.DurableTask;
 /// gRPC interceptor that externalizes large payloads to an <see cref="IPayloadStore"/> on requests
 /// and resolves known payload tokens on responses.
 /// </summary>
-sealed class AzureBlobPayloadsInterceptor(IPayloadStore payloadStore, LargePayloadStorageOptions options) : Interceptor
+internal sealed class AzureBlobPayloadsInterceptor(IPayloadStore payloadStore, LargePayloadStorageOptions options) : Interceptor
 {
     readonly IPayloadStore payloadStore = payloadStore;
     readonly LargePayloadStorageOptions options = options;

src/Extensions/AzureBlobPayloads/PayloadStore/BlobPayloadStore.cs

@@ -16,7 +16,7 @@ namespace Microsoft.DurableTask;
 /// Azure Blob Storage implementation of <see cref="IPayloadStore"/>.
 /// Stores payloads as blobs and returns opaque tokens in the form "blob:v1:&lt;container&gt;:&lt;blobName&gt;".
 /// </summary>
-public sealed class BlobPayloadStore : IPayloadStore
+internal sealed class BlobPayloadStore : IPayloadStore
 {
     const string TokenPrefix = "blob:v1:";
     const string ContentEncodingGzip = "gzip";