update publish interface.

Signed-off-by: morvencao <lcao@redhat.com>
cloudevents · Nov 10, 2023 · ca8841e · ca8841e
1 parent e7d6864
commit ca8841e
Show file tree

Hide file tree

Showing 7 changed files with 180 additions and 82 deletions.
diff --git a/binding/format/protobuf/v2/go.mod b/binding/format/protobuf/v2/go.mod
@@ -4,14 +4,14 @@ go 1.18
 
 require (
 	github.com/cloudevents/sdk-go/v2 v2.5.0
+	github.com/golang/protobuf v1.5.3
 	github.com/stretchr/testify v1.8.0
 	google.golang.org/grpc v1.59.0
 	google.golang.org/protobuf v1.31.0
 )
 
 require (
 	github.com/davecgh/go-spew v1.1.1 // indirect
-	github.com/golang/protobuf v1.5.3 // indirect
 	github.com/google/uuid v1.3.1 // indirect
 	github.com/json-iterator/go v1.1.10 // indirect
 	github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 // indirect

diff --git a/binding/format/protobuf/v2/pb/cloudevent.pb.go b/binding/format/protobuf/v2/pb/cloudevent.pb.go
diff --git a/binding/format/protobuf/v2/pb/cloudevent.proto b/binding/format/protobuf/v2/pb/cloudevent.proto
@@ -61,16 +61,23 @@ message CloudEventAttributeValue {
   }
 }
 
-message Subscription {
-  // Required. The subscription from which messages should be pulled.
+message PublishRequest {
+  // Required. The topic to which event should be published.
   // Format is `myhome/groundfloor/livingroom/temperature`.
-  string subscription = 1;
+  string topic = 1;
+  CloudEvent event = 2;
+}
+
+message SubscriptionRequest {
+  // Required. The topic from which event should be pulled.
+  // Format is `myhome/groundfloor/livingroom/temperature`.
+  string topic = 1;
 }
 
 service CloudEventService {
-  rpc Publish(CloudEvent) returns (google.protobuf.Empty) {
+  rpc Publish(PublishRequest) returns (google.protobuf.Empty) {
   }
 
-  rpc Subscribe(Subscription) returns (stream CloudEvent) {
+  rpc Subscribe(SubscriptionRequest) returns (stream CloudEvent) {
   }
 }