feat: Introduce the event publishing using JSON representation of Clo…

…udEvents Clients can now use either the Protobuf or the JSON CloudEvents representation when interacting with Eventarc Publishing API. This change benefits both Channel and ChannelConnection consumers. PiperOrigin-RevId: 486208303 Source-Link: googleapis/googleapis@079ef84 Source-Link: googleapis/googleapis-gen@dd62dfc Copy-Tag: eyJwIjoiYXBpcy9Hb29nbGUuQ2xvdWQuRXZlbnRhcmMuUHVibGlzaGluZy5WMS8uT3dsQm90LnlhbWwiLCJoIjoiZGQ2MmRmYzE3NGFiYjI1YmYyZTUwYTJhNTQ2NTFkYTcwZGFlZDc4MSJ9
googleapis · Nov 7, 2022 · 9e59b13 · 9e59b13
1 parent e832ba9
commit 9e59b13
Show file tree

Hide file tree

Showing 8 changed files with 119 additions and 27 deletions.
diff --git a/...atedSnippets/PublisherClient.PublishChannelConnectionEventsRequestObjectAsyncSnippet.g.cs b/...atedSnippets/PublisherClient.PublishChannelConnectionEventsRequestObjectAsyncSnippet.g.cs
@@ -37,6 +37,7 @@ public async Task PublishChannelConnectionEventsRequestObjectAsync()
             {
                 ChannelConnection = "",
                 Events = { new Any(), },
+                TextEvents = { "", },
             };
             // Make the request
             PublishChannelConnectionEventsResponse response = await publisherClient.PublishChannelConnectionEventsAsync(request);

diff --git a/...GeneratedSnippets/PublisherClient.PublishChannelConnectionEventsRequestObjectSnippet.g.cs b/...GeneratedSnippets/PublisherClient.PublishChannelConnectionEventsRequestObjectSnippet.g.cs
@@ -36,6 +36,7 @@ public void PublishChannelConnectionEventsRequestObject()
             {
                 ChannelConnection = "",
                 Events = { new Any(), },
+                TextEvents = { "", },
             };
             // Make the request
             PublishChannelConnectionEventsResponse response = publisherClient.PublishChannelConnectionEvents(request);

diff --git a/...blishing.V1.GeneratedSnippets/PublisherClient.PublishEventsRequestObjectAsyncSnippet.g.cs b/...blishing.V1.GeneratedSnippets/PublisherClient.PublishEventsRequestObjectAsyncSnippet.g.cs
@@ -37,6 +37,7 @@ public async Task PublishEventsRequestObjectAsync()
             {
                 Channel = "",
                 Events = { new Any(), },
+                TextEvents = { "", },
             };
             // Make the request
             PublishEventsResponse response = await publisherClient.PublishEventsAsync(request);

diff --git a/...rc.Publishing.V1.GeneratedSnippets/PublisherClient.PublishEventsRequestObjectSnippet.g.cs b/...rc.Publishing.V1.GeneratedSnippets/PublisherClient.PublishEventsRequestObjectSnippet.g.cs
@@ -36,6 +36,7 @@ public void PublishEventsRequestObject()
             {
                 Channel = "",
                 Events = { new Any(), },
+                TextEvents = { "", },
             };
             // Make the request
             PublishEventsResponse response = publisherClient.PublishEvents(request);

diff --git a/...c.Publishing.V1/Google.Cloud.Eventarc.Publishing.V1.Snippets/PublisherClientSnippets.g.cs b/...c.Publishing.V1/Google.Cloud.Eventarc.Publishing.V1.Snippets/PublisherClientSnippets.g.cs
@@ -33,6 +33,7 @@ public void PublishChannelConnectionEventsRequestObject()
             {
                 ChannelConnection = "",
                 Events = { new Any(), },
+                TextEvents = { "", },
             };
             // Make the request
             PublishChannelConnectionEventsResponse response = publisherClient.PublishChannelConnectionEvents(request);
@@ -51,6 +52,7 @@ public async Task PublishChannelConnectionEventsRequestObjectAsync()
             {
                 ChannelConnection = "",
                 Events = { new Any(), },
+                TextEvents = { "", },
             };
             // Make the request
             PublishChannelConnectionEventsResponse response = await publisherClient.PublishChannelConnectionEventsAsync(request);
@@ -68,6 +70,7 @@ public void PublishEventsRequestObject()
             {
                 Channel = "",
                 Events = { new Any(), },
+                TextEvents = { "", },
             };
             // Make the request
             PublishEventsResponse response = publisherClient.PublishEvents(request);
@@ -86,6 +89,7 @@ public async Task PublishEventsRequestObjectAsync()
             {
                 Channel = "",
                 Events = { new Any(), },
+                TextEvents = { "", },
             };
             // Make the request
             PublishEventsResponse response = await publisherClient.PublishEventsAsync(request);

diff --git a/...Eventarc.Publishing.V1/Google.Cloud.Eventarc.Publishing.V1.Tests/PublisherClientTest.g.cs b/...Eventarc.Publishing.V1/Google.Cloud.Eventarc.Publishing.V1.Tests/PublisherClientTest.g.cs
@@ -36,6 +36,10 @@ public void PublishChannelConnectionEventsRequestObject()
             {
                 ChannelConnection = "channel_connection1ad4645e",
                 Events = { new wkt::Any(), },
+                TextEvents =
+                {
+                    "text_events2754ee7c",
+                },
             };
             PublishChannelConnectionEventsResponse expectedResponse = new PublishChannelConnectionEventsResponse { };
             mockGrpcClient.Setup(x => x.PublishChannelConnectionEvents(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
@@ -53,6 +57,10 @@ public void PublishChannelConnectionEventsRequestObject()
             {
                 ChannelConnection = "channel_connection1ad4645e",
                 Events = { new wkt::Any(), },
+                TextEvents =
+                {
+                    "text_events2754ee7c",
+                },
             };
             PublishChannelConnectionEventsResponse expectedResponse = new PublishChannelConnectionEventsResponse { };
             mockGrpcClient.Setup(x => x.PublishChannelConnectionEventsAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<PublishChannelConnectionEventsResponse>(stt::Task.FromResult(expectedResponse), null, null, null, null));
@@ -72,6 +80,10 @@ public void PublishEventsRequestObject()
             {
                 Channel = "channeledd285c4",
                 Events = { new wkt::Any(), },
+                TextEvents =
+                {
+                    "text_events2754ee7c",
+                },
             };
             PublishEventsResponse expectedResponse = new PublishEventsResponse { };
             mockGrpcClient.Setup(x => x.PublishEvents(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
@@ -89,6 +101,10 @@ public void PublishEventsRequestObject()
             {
                 Channel = "channeledd285c4",
                 Events = { new wkt::Any(), },
+                TextEvents =
+                {
+                    "text_events2754ee7c",
+                },
             };
             PublishEventsResponse expectedResponse = new PublishEventsResponse { };
             mockGrpcClient.Setup(x => x.PublishEventsAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<PublishEventsResponse>(stt::Task.FromResult(expectedResponse), null, null, null, null));