Versions in this module Expand all Collapse all v1 v1.18.1 Apr 6, 2022 Changes in this version + type Broker struct + Broker broker.Broker + func (b *Broker) Publish(ctx context.Context, req *pb.PublishRequest, rsp *pb.Empty) error + func (b *Broker) Subscribe(ctx context.Context, req *pb.SubscribeRequest, ...) error
Go to main page