Documentation

Overview

    Package broker is a generated protocol buffer package.

    It is generated from these files:

    e.coding.net/nimrc/micro/go-plugins/broker/grpc/v2/proto/broker.proto
    

    It has these top-level messages:

    Message
    Empty
    

    Index

    Constants

    This section is empty.

    Variables

    This section is empty.

    Functions

    func RegisterBrokerServer

    func RegisterBrokerServer(s *grpc.Server, srv BrokerServer)

    Types

    type BrokerClient

    type BrokerClient interface {
    	Publish(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Empty, error)
    }

    func NewBrokerClient

    func NewBrokerClient(cc *grpc.ClientConn) BrokerClient

    type BrokerServer

    type BrokerServer interface {
    	Publish(context.Context, *Message) (*Empty, error)
    }

    type Empty

    type Empty struct {
    }

    func (*Empty) Descriptor

    func (*Empty) Descriptor() ([]byte, []int)

    func (*Empty) ProtoMessage

    func (*Empty) ProtoMessage()

    func (*Empty) Reset

    func (m *Empty) Reset()

    func (*Empty) String

    func (m *Empty) String() string

    type Message

    type Message struct {
    	Topic  string            `protobuf:"bytes,1,opt,name=topic" json:"topic,omitempty"`
    	Id     string            `protobuf:"bytes,2,opt,name=id" json:"id,omitempty"`
    	Header map[string]string `` /* 132-byte string literal not displayed */
    	Body   []byte            `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
    }

    func (*Message) Descriptor

    func (*Message) Descriptor() ([]byte, []int)

    func (*Message) GetBody

    func (m *Message) GetBody() []byte

    func (*Message) GetHeader

    func (m *Message) GetHeader() map[string]string

    func (*Message) GetId

    func (m *Message) GetId() string

    func (*Message) GetTopic

    func (m *Message) GetTopic() string

    func (*Message) ProtoMessage

    func (*Message) ProtoMessage()

    func (*Message) Reset

    func (m *Message) Reset()

    func (*Message) String

    func (m *Message) String() string

    Source Files