go_micro_broker

package

Go to main page

Versions in this module

v2

v2.9.5

May 2, 2021

v2.9.4

Feb 18, 2021

v2.9.3

Dec 25, 2020

Changes in this version

+ var File_broker_service_proto_broker_proto protoreflect.FileDescriptor

type Empty

+ func (x *Empty) ProtoReflect() protoreflect.Message

type Message

+ func (x *Message) ProtoReflect() protoreflect.Message

type PublishRequest

+ func (x *PublishRequest) ProtoReflect() protoreflect.Message

type SubscribeRequest

+ func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

v2.9.2

Nov 14, 2020

Changes in this version

+ func NewBrokerEndpoints() []*api.Endpoint

+ func RegisterBrokerHandler(s server.Server, hdlr BrokerHandler, opts ...server.HandlerOption) error

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

+ type BrokerClient interface

+ Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*Empty, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Broker_SubscribeClient, error)

+ func NewBrokerClient(cc *grpc.ClientConn) BrokerClient

+ type BrokerHandler interface

+ Publish func(context.Context, *PublishRequest, *Empty) error

+ Subscribe func(context.Context, *SubscribeRequest, Broker_SubscribeStream) error

+ type BrokerServer interface

+ Publish func(context.Context, *PublishRequest) (*Empty, error)

+ Subscribe func(*SubscribeRequest, Broker_SubscribeServer) error

+ type BrokerService interface

+ Publish func(ctx context.Context, in *PublishRequest, opts ...client.CallOption) (*Empty, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...client.CallOption) (Broker_SubscribeService, error)

+ func NewBrokerService(name string, c client.Client) BrokerService

+ type Broker_SubscribeClient interface

+ Recv func() (*Message, error)

+ type Broker_SubscribeServer interface

+ Send func(*Message) error

+ type Broker_SubscribeService interface

+ Close func() error

+ Context func() context.Context

+ Recv func() (*Message, error)

+ RecvMsg func(interface{}) error

+ SendMsg func(interface{}) error

+ type Broker_SubscribeStream interface

+ Close func() error

+ Context func() context.Context

+ RecvMsg func(interface{}) error

+ Send func(*Message) error

+ SendMsg func(interface{}) error

+ type Empty struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Empty) ProtoMessage()

+ func (m *Empty) Reset()

+ func (m *Empty) String() string

+ func (m *Empty) XXX_DiscardUnknown()

+ func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Empty) XXX_Merge(src proto.Message)

+ func (m *Empty) XXX_Size() int

+ func (m *Empty) XXX_Unmarshal(b []byte) error

+ type Message struct

+ Body []byte

+ Header map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Message) ProtoMessage()

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

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

+ func (m *Message) Reset()

+ func (m *Message) String() string

+ func (m *Message) XXX_DiscardUnknown()

+ func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Message) XXX_Merge(src proto.Message)

+ func (m *Message) XXX_Size() int

+ func (m *Message) XXX_Unmarshal(b []byte) error

+ type PublishRequest struct

+ Message *Message

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PublishRequest) Descriptor() ([]byte, []int)

+ func (*PublishRequest) ProtoMessage()

+ func (m *PublishRequest) GetMessage() *Message

+ func (m *PublishRequest) GetTopic() string

+ func (m *PublishRequest) Reset()

+ func (m *PublishRequest) String() string

+ func (m *PublishRequest) XXX_DiscardUnknown()

+ func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PublishRequest) XXX_Merge(src proto.Message)

+ func (m *PublishRequest) XXX_Size() int

+ func (m *PublishRequest) XXX_Unmarshal(b []byte) error

+ type SubscribeRequest struct

+ Queue string

+ Topic string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SubscribeRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeRequest) ProtoMessage()

+ func (m *SubscribeRequest) GetQueue() string

+ func (m *SubscribeRequest) GetTopic() string

+ func (m *SubscribeRequest) Reset()

+ func (m *SubscribeRequest) String() string

+ func (m *SubscribeRequest) XXX_DiscardUnknown()

+ func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SubscribeRequest) XXX_Merge(src proto.Message)

+ func (m *SubscribeRequest) XXX_Size() int

+ func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error

+ type UnimplementedBrokerServer struct

+ func (*UnimplementedBrokerServer) Publish(ctx context.Context, req *PublishRequest) (*Empty, error)

+ func (*UnimplementedBrokerServer) Subscribe(req *SubscribeRequest, srv Broker_SubscribeServer) error

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