rename dts to blob

Author: YunchuWang

samples/LargePayloadConsoleApp/Program.cs

@@ -57,7 +57,7 @@
             }
 
             // If we ever see a token in the activity, externalization is not being resolved correctly.
-            if (value.StartsWith("dts:v1:", StringComparison.Ordinal))
+            if (value.StartsWith("blob:v1:", StringComparison.Ordinal))
             {
                 throw new InvalidOperationException("Activity received a payload token instead of raw input.");
             }

src/Abstractions/Converters/BlobPayloadStore.cs

@@ -12,7 +12,7 @@ namespace Microsoft.DurableTask.Converters;
 
 /// <summary>
 /// Azure Blob Storage implementation of <see cref="IPayloadStore"/>.
-/// Stores payloads as blobs and returns opaque tokens in the form "dts:v1:&lt;container&gt;:&lt;blobName&gt;".
+/// 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
 {
@@ -77,16 +77,16 @@ public async Task<string> DownloadAsync(string token, CancellationToken cancella
         return await reader.ReadToEndAsync();
     }
 
-    static string EncodeToken(string container, string name) => $"dts:v1:{container}:{name}";
+    static string EncodeToken(string container, string name) => $"blob:v1:{container}:{name}";
 
     static (string Container, string Name) DecodeToken(string token)
     {
-        if (!token.StartsWith("dts:v1:", StringComparison.Ordinal))
+        if (!token.StartsWith("blob:v1:", StringComparison.Ordinal))
         {
             throw new ArgumentException("Invalid external payload token.", nameof(token));
         }
 
-        string rest = token.Substring("dts:v1:".Length);
+        string rest = token.Substring("blob:v1:".Length);
         int sep = rest.IndexOf(':');
         if (sep <= 0 || sep >= rest.Length - 1)
         {

src/Abstractions/Converters/LargePayloadDataConverter.cs

@@ -19,7 +19,7 @@ namespace Microsoft.DurableTask.Converters;
 /// <exception cref="ArgumentNullException">Thrown when <paramref name="innerConverter"/>, <paramref name="payloadStore"/>, or <paramref name="largePayloadStorageOptions"/> is null.</exception>
 public sealed class LargePayloadDataConverter(DataConverter innerConverter, IPayloadStore payloadStore, LargePayloadStorageOptions largePayloadStorageOptions) : DataConverter
 {
-    const string TokenPrefix = "dts:v1:"; // matches BlobExternalPayloadStore
+    const string TokenPrefix = "blob:v1:"; // matches BlobExternalPayloadStore
 
     readonly DataConverter innerConverter = innerConverter ?? throw new ArgumentNullException(nameof(innerConverter));
     readonly IPayloadStore payLoadStore = payloadStore ?? throw new ArgumentNullException(nameof(payloadStore));

test/Grpc.IntegrationTests/LargePayloadTests.cs

@@ -384,7 +384,7 @@ public Task<string> UploadAsync(ReadOnlyMemory<byte> payloadBytes, CancellationT
         {
             Interlocked.Increment(ref this.uploadCount);
             string json = System.Text.Encoding.UTF8.GetString(payloadBytes.Span);
-            string token = $"dts:v1:test:{Guid.NewGuid():N}";
+            string token = $"blob:v1:test:{Guid.NewGuid():N}";
             this.tokenToPayload[token] = json;
             return Task.FromResult(token);
         }