Versions in this module Expand all Collapse all v0 v0.17.1 Jan 23, 2019 v0.17.0 Dec 10, 2018 Changes in this version + func RegisterBrokerServer(s *grpc.Server, srv BrokerServer) + type BrokerClient interface + Publish func(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Empty, error) + func NewBrokerClient(cc *grpc.ClientConn) BrokerClient + type BrokerServer interface + Publish func(context.Context, *Message) (*Empty, error) + type Empty struct + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (m *Empty) Reset() + func (m *Empty) String() string + type Message struct + Body []byte + Header map[string]string + Id string + Topic string + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (m *Message) GetBody() []byte + func (m *Message) GetHeader() map[string]string + func (m *Message) GetId() string + func (m *Message) GetTopic() string + func (m *Message) Reset() + func (m *Message) String() string
Go to main page