broker

Jun 1, 2021

Changes in this version

type Empty

+ func (m *Empty) XSize() (n int)

type Message

+ func (m *Message) XSize() (n int)

type PublishRequest

+ func (m *PublishRequest) XSize() (n int)

type SubscribeRequest

+ func (m *SubscribeRequest) XSize() (n int)

Jan 30, 2021

Changes in this version

+ var ErrIntOverflowBroker = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthBroker = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupBroker = fmt.Errorf("proto: unexpected end of group")

+ func NewBrokerEndpoints() []*api.Endpoint

+ func NewBrokerOpenAPI() *registry.OpenAPI

+ 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

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

+ func (*Empty) ProtoMessage()

+ func (m *Empty) Marshal() (dAtA []byte, err error)

+ func (m *Empty) MarshalTo(dAtA []byte) (int, error)

+ func (m *Empty) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Empty) Reset()

+ func (m *Empty) Size() (n int)

+ func (m *Empty) String() string

+ func (m *Empty) Unmarshal(dAtA []byte) error

+ 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

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

+ func (*Message) ProtoMessage()

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

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

+ func (m *Message) Marshal() (dAtA []byte, err error)

+ func (m *Message) MarshalTo(dAtA []byte) (int, error)

+ func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Message) Reset()

+ func (m *Message) Size() (n int)

+ func (m *Message) String() string

+ func (m *Message) Unmarshal(dAtA []byte) error

+ 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

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

+ func (*PublishRequest) ProtoMessage()

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

+ func (m *PublishRequest) GetTopic() string

+ func (m *PublishRequest) Marshal() (dAtA []byte, err error)

+ func (m *PublishRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PublishRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PublishRequest) Reset()

+ func (m *PublishRequest) Size() (n int)

+ func (m *PublishRequest) String() string

+ func (m *PublishRequest) Unmarshal(dAtA []byte) error

+ 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

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

+ func (*SubscribeRequest) ProtoMessage()

+ func (m *SubscribeRequest) GetQueue() string

+ func (m *SubscribeRequest) GetTopic() string

+ func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)

+ func (m *SubscribeRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SubscribeRequest) Reset()

+ func (m *SubscribeRequest) Size() (n int)

+ func (m *SubscribeRequest) String() string

+ func (m *SubscribeRequest) Unmarshal(dAtA []byte) error

+ 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