Added support for Change Feed event schemas 3, 4, and 5 (Azure#27103)

Author: seanmcc-msft

sdk/storage/Azure.Storage.Blobs.ChangeFeed/CHANGELOG.md

@@ -1,14 +1,7 @@
 # Release History
 
 ## 12.0.0-preview.20 (Unreleased)
-
-### Features Added
-
-### Breaking Changes
-
-### Bugs Fixed
-
-### Other Changes
+- Added support for event schema V3, V4, and V5.
 
 ## 12.0.0-preview.19 (2022-02-07)
 - Added support for service version 2021-04-10.

sdk/storage/Azure.Storage.Blobs.ChangeFeed/api/Azure.Storage.Blobs.ChangeFeed.netstandard2.0.cs

@@ -32,18 +32,26 @@ internal BlobChangeFeedEvent() { }
     public partial class BlobChangeFeedEventData
     {
         internal BlobChangeFeedEventData() { }
+        public Azure.Storage.Blobs.ChangeFeed.Models.BlobChangeFeedEventAsyncOperationInfo AsyncOperationInfo { get { throw null; } }
+        public Azure.Storage.Blobs.Models.AccessTier? BlobAccessTier { get { throw null; } }
         public Azure.Storage.Blobs.ChangeFeed.BlobOperationName BlobOperationName { get { throw null; } }
         public Azure.Storage.Blobs.Models.BlobType BlobType { get { throw null; } }
+        public string BlobVersion { get { throw null; } }
         public string ClientRequestId { get { throw null; } }
+        public string ContainerVersion { get { throw null; } }
         public long ContentLength { get { throw null; } }
         public long? ContentOffset { get { throw null; } }
         public string ContentType { get { throw null; } }
         public System.Uri DestinationUri { get { throw null; } }
         public Azure.ETag ETag { get { throw null; } }
+        public Azure.Storage.Blobs.ChangeFeed.Models.ChangeFeedEventPreviousInfo PreviousInfo { get { throw null; } }
         public bool? Recursive { get { throw null; } }
         public System.Guid RequestId { get { throw null; } }
         public string Sequencer { get { throw null; } }
+        public string Snapshot { get { throw null; } }
         public System.Uri SourceUri { get { throw null; } }
+        public System.Collections.Generic.Dictionary<string, Azure.Storage.Blobs.ChangeFeed.Models.BlobChangeFeedEventUpdatedBlobProperty> UpdatedBlobProperties { get { throw null; } }
+        public Azure.Storage.Blobs.ChangeFeed.Models.BlobChangeFeedEventUpdatedBlobTags UpdatedBlobTags { get { throw null; } }
         public System.Uri Uri { get { throw null; } }
     }
     [System.Runtime.InteropServices.StructLayoutAttribute(System.Runtime.InteropServices.LayoutKind.Sequential)]
@@ -59,6 +67,7 @@ internal BlobChangeFeedEventData() { }
         public static Azure.Storage.Blobs.ChangeFeed.BlobChangeFeedEventType BlobSnapshotCreated { get { throw null; } }
         public static Azure.Storage.Blobs.ChangeFeed.BlobChangeFeedEventType BlobTierChanged { get { throw null; } }
         public static Azure.Storage.Blobs.ChangeFeed.BlobChangeFeedEventType Control { get { throw null; } }
+        public static Azure.Storage.Blobs.ChangeFeed.BlobChangeFeedEventType RestorePointMarkerCreated { get { throw null; } }
         public static Azure.Storage.Blobs.ChangeFeed.BlobChangeFeedEventType UnspecifiedEventType { get { throw null; } }
         public bool Equals(Azure.Storage.Blobs.ChangeFeed.BlobChangeFeedEventType other) { throw null; }
         [System.ComponentModel.EditorBrowsableAttribute(System.ComponentModel.EditorBrowsableState.Never)]
@@ -77,7 +86,11 @@ public static partial class BlobChangeFeedExtensions
     public static partial class BlobChangeFeedModelFactory
     {
         public static Azure.Storage.Blobs.ChangeFeed.BlobChangeFeedEvent BlobChangeFeedEvent(string topic, string subject, Azure.Storage.Blobs.ChangeFeed.BlobChangeFeedEventType eventType, System.DateTimeOffset eventTime, System.Guid id, Azure.Storage.Blobs.ChangeFeed.BlobChangeFeedEventData eventData, long dataVersion, string metadataVersion) { throw null; }
-        public static Azure.Storage.Blobs.ChangeFeed.BlobChangeFeedEventData BlobChangeFeedEventData(string api, string clientRequestId, System.Guid requestId, Azure.ETag eTag, string contentType, long contentLength, Azure.Storage.Blobs.Models.BlobType blobType, long contentOffset, System.Uri destinationUri, System.Uri sourceUri, System.Uri uri, bool recursive, string sequencer) { throw null; }
+        public static Azure.Storage.Blobs.ChangeFeed.Models.BlobChangeFeedEventAsyncOperationInfo BlobChangeFeedEventAsyncOperationInfo(Azure.Storage.Blobs.Models.AccessTier? destinationAccessTier, bool wasAsyncOperation, string copyId) { throw null; }
+        public static Azure.Storage.Blobs.ChangeFeed.BlobChangeFeedEventData BlobChangeFeedEventData(string blobOperationName, string clientRequestId, System.Guid requestId, Azure.ETag eTag, string contentType, long contentLength, Azure.Storage.Blobs.Models.BlobType blobType, string blobVersion, string containerVersion, Azure.Storage.Blobs.Models.AccessTier? blobAccessTier, long contentOffset, System.Uri destinationUri, System.Uri sourceUri, System.Uri uri, bool recursive, string sequencer, Azure.Storage.Blobs.ChangeFeed.Models.ChangeFeedEventPreviousInfo previousInfo, string snapshot, System.Collections.Generic.Dictionary<string, Azure.Storage.Blobs.ChangeFeed.Models.BlobChangeFeedEventUpdatedBlobProperty> updatedBlobProperties, Azure.Storage.Blobs.ChangeFeed.Models.BlobChangeFeedEventAsyncOperationInfo asyncOperationInfo, Azure.Storage.Blobs.ChangeFeed.Models.BlobChangeFeedEventUpdatedBlobTags updatedBlobTags) { throw null; }
+        public static Azure.Storage.Blobs.ChangeFeed.Models.BlobChangeFeedEventUpdatedBlobProperty BlobChangeFeedEventUpdatedBlobProperty(string propertyName, string previousValue, string newValue) { throw null; }
+        public static Azure.Storage.Blobs.ChangeFeed.Models.BlobChangeFeedEventUpdatedBlobTags BlobChangeFeedEventUpdatedBlobTags(System.Collections.Generic.Dictionary<string, string> previousTags, System.Collections.Generic.Dictionary<string, string> newTags) { throw null; }
+        public static Azure.Storage.Blobs.ChangeFeed.Models.ChangeFeedEventPreviousInfo ChangeFeedEventPreviousInfo(string softDeleteSnapshot, bool wasBlobSoftDeleted, string blobVersion, string lastVersion, Azure.Storage.Blobs.Models.AccessTier? previousTier) { throw null; }
     }
     [System.Runtime.InteropServices.StructLayoutAttribute(System.Runtime.InteropServices.LayoutKind.Sequential)]
     public readonly partial struct BlobOperationName : System.IEquatable<Azure.Storage.Blobs.ChangeFeed.BlobOperationName>
@@ -88,11 +101,13 @@ public static partial class BlobChangeFeedModelFactory
         public static Azure.Storage.Blobs.ChangeFeed.BlobOperationName AbortCopyBlob { get { throw null; } }
         public static Azure.Storage.Blobs.ChangeFeed.BlobOperationName ControlEvent { get { throw null; } }
         public static Azure.Storage.Blobs.ChangeFeed.BlobOperationName CopyBlob { get { throw null; } }
+        public static Azure.Storage.Blobs.ChangeFeed.BlobOperationName CreateRestorePointMarker { get { throw null; } }
         public static Azure.Storage.Blobs.ChangeFeed.BlobOperationName DeleteBlob { get { throw null; } }
         public static Azure.Storage.Blobs.ChangeFeed.BlobOperationName PutBlob { get { throw null; } }
         public static Azure.Storage.Blobs.ChangeFeed.BlobOperationName PutBlockList { get { throw null; } }
         public static Azure.Storage.Blobs.ChangeFeed.BlobOperationName SetBlobMetadata { get { throw null; } }
         public static Azure.Storage.Blobs.ChangeFeed.BlobOperationName SetBlobProperties { get { throw null; } }
+        public static Azure.Storage.Blobs.ChangeFeed.BlobOperationName SetBlobTags { get { throw null; } }
         public static Azure.Storage.Blobs.ChangeFeed.BlobOperationName SetBlobTier { get { throw null; } }
         public static Azure.Storage.Blobs.ChangeFeed.BlobOperationName SnapshotBlob { get { throw null; } }
         public static Azure.Storage.Blobs.ChangeFeed.BlobOperationName UndeleteBlob { get { throw null; } }
@@ -108,3 +123,35 @@ public static partial class BlobChangeFeedModelFactory
         public override string ToString() { throw null; }
     }
 }
+namespace Azure.Storage.Blobs.ChangeFeed.Models
+{
+    public partial class BlobChangeFeedEventAsyncOperationInfo
+    {
+        internal BlobChangeFeedEventAsyncOperationInfo() { }
+        public string CopyId { get { throw null; } }
+        public Azure.Storage.Blobs.Models.AccessTier? DestinationAccessTier { get { throw null; } }
+        public bool WasAsyncOperation { get { throw null; } }
+    }
+    public partial class BlobChangeFeedEventUpdatedBlobProperty
+    {
+        internal BlobChangeFeedEventUpdatedBlobProperty() { }
+        public string NewValue { get { throw null; } }
+        public string PreviousValue { get { throw null; } }
+        public string PropertyName { get { throw null; } }
+    }
+    public partial class BlobChangeFeedEventUpdatedBlobTags
+    {
+        internal BlobChangeFeedEventUpdatedBlobTags() { }
+        public System.Collections.Generic.Dictionary<string, string> NewTags { get { throw null; } }
+        public System.Collections.Generic.Dictionary<string, string> PreviousTags { get { throw null; } }
+    }
+    public partial class ChangeFeedEventPreviousInfo
+    {
+        internal ChangeFeedEventPreviousInfo() { }
+        public string BlobVersion { get { throw null; } }
+        public string LastVersion { get { throw null; } }
+        public Azure.Storage.Blobs.Models.AccessTier? PreviousTier { get { throw null; } }
+        public string SoftDeleteSnapshot { get { throw null; } }
+        public bool WasBlobSoftDeleted { get { throw null; } }
+    }
+}

sdk/storage/Azure.Storage.Blobs.ChangeFeed/src/Models/BlobChangeFeedEventAsyncOperationInfo.cs

@@ -0,0 +1,30 @@
+// Copyright (c) Microsoft Corporation. All rights reserved.
+// Licensed under the MIT License.
+
+using Azure.Storage.Blobs.Models;
+
+namespace Azure.Storage.Blobs.ChangeFeed.Models
+{
+    /// <summary>
+    /// ChangeFeedEventAsyncOperationInfo.
+    /// </summary>
+    public class BlobChangeFeedEventAsyncOperationInfo
+    {
+        internal BlobChangeFeedEventAsyncOperationInfo() { }
+
+        /// <summary>
+        /// DestinationAccessTier.
+        /// </summary>
+        public AccessTier? DestinationAccessTier { get; internal set; }
+
+        /// <summary>
+        /// If the operation was async.
+        /// </summary>
+        public bool WasAsyncOperation { get; internal set; }
+
+        /// <summary>
+        /// Copy Id.
+        /// </summary>
+        public string CopyId { get; internal set; }
+    }
+}