broker

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