add publishes custom event

client/client.go

@@ -48,6 +48,9 @@ type Client interface {
 	// InvokeMethodWithCustomContent invokes app with custom content (struct + content type).
 	InvokeMethodWithCustomContent(ctx context.Context, appID, methodName, verb string, contentType string, content interface{}) (out []byte, err error)
 
+	// PublishEvent publishes custom event.
+	Publish(ctx context.Context, in *PublishEventRequest) error
+
 	// PublishEvent publishes data onto topic in specific pubsub component.
 	PublishEvent(ctx context.Context, pubsubName, topicName string, data []byte) error
 

client/pubsub.go

@@ -3,11 +3,51 @@ package client
 import (
 	"context"
 	"encoding/json"
-
 	pb "github.com/dapr/go-sdk/dapr/proto/runtime/v1"
 	"github.com/pkg/errors"
 )
 
+type PublishEventRequest struct {
+	// The name of the pubsub component
+	PubsubName string
+	// The pubsub topic
+	Topic string
+	// The data which will be published to topic.
+	Data []byte
+	// The content type for the data (optional).
+	DataContentType string
+	// The metadata passing to pub components
+	//
+	// metadata property:
+	// - key : the key of the message.
+	Metadata map[string]string
+}
+
+// Publish publishes custom event.
+func (c *GRPCClient) Publish(ctx context.Context, in *PublishEventRequest) error {
+	if in.PubsubName == "" {
+		return errors.New("PublishEventRequest.PubsubName required")
+	}
+	if in.Topic == "" {
+		return errors.New("PublishEventRequest.Topic required")
+	}
+
+	envelop := &pb.PublishEventRequest{
+		PubsubName:      in.PubsubName,
+		Topic:           in.Topic,
+		Data:            in.Data,
+		DataContentType: in.DataContentType,
+		Metadata:        in.Metadata,
+	}
+
+	_, err := c.protoClient.PublishEvent(c.withAuthToken(ctx), envelop)
+	if err != nil {
+		return errors.Wrapf(err, "error publishing event unto %s topic", in.Topic)
+	}
+
+	return nil
+}
+
 // PublishEvent publishes data onto specific pubsub topic.
 func (c *GRPCClient) PublishEvent(ctx context.Context, pubsubName, topicName string, data []byte) error {
 	if pubsubName == "" {