update publish interface.

Signed-off-by: morvencao <[email protected]>

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

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) {
   }
 }