server

type ProducerClient interface {
	Publish(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Reply, error)
}

type ProducerServer interface {
	Publish(context.Context, *Request) (*Reply, error)
}

type Reply struct {
	Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
}

type Request struct {
	Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
}