broker

package
v1.5.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 18, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package broker is a generated protocol buffer package.

It is generated from these files:

github.com/micro/go-plugins/broker/grpc/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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL