broker

Documentation

Overview

Package broker is a generated protocol buffer package.

It is generated from these files:

github.com/micro/go-plugins/broker/grpc/v2/proto/broker.proto

It has these top-level messages:

Message
Empty

Index

• func RegisterBrokerServer(s *grpc.Server, srv BrokerServer)
• type BrokerClient
  • func NewBrokerClient(cc *grpc.ClientConn) BrokerClient
• type BrokerServer
• type Empty
  • func (*Empty) Descriptor() ([]byte, []int)
  • func (*Empty) ProtoMessage()
  • func (m *Empty) Reset()
  • func (m *Empty) String() string
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (m *Message) GetBody() []byte
  • func (m *Message) GetHeader() map[string]string
  • func (m *Message) GetId() string
  • func (m *Message) GetTopic() string
  • func (*Message) ProtoMessage()
  • func (m *Message) Reset()
  • func (m *Message) String() string

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