messagebroker

package

Go to main page

Versions in this module

v0

v0.6.0

Nov 20, 2020

Changes in this version

+ var File_message_broker_proto protoreflect.FileDescriptor

+ type KafkaMessage struct

+ Message *Message

+ Target *KafkaTarget

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

+ func (*KafkaMessage) ProtoMessage()

+ func (x *KafkaMessage) GetMessage() *Message

+ func (x *KafkaMessage) GetTarget() *KafkaTarget

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

+ func (x *KafkaMessage) Reset()

+ func (x *KafkaMessage) String() string

+ type KafkaTarget struct

+ Brokers []string

+ Topic string

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

+ func (*KafkaTarget) ProtoMessage()

+ func (x *KafkaTarget) GetBrokers() []string

+ func (x *KafkaTarget) GetTopic() string

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

+ func (x *KafkaTarget) Reset()

+ func (x *KafkaTarget) String() string

type Message

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

type MessageBrokerClient

+ SendKafkaMessage func(ctx context.Context, in *KafkaMessage, opts ...grpc.CallOption) (*Response, error)

type MessageBrokerServer

+ SendKafkaMessage func(context.Context, *KafkaMessage) (*Response, error)

type RabbitMQMessage

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

type RabbitMQTarget

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

type Response

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

type UnimplementedMessageBrokerServer

+ func (UnimplementedMessageBrokerServer) SendKafkaMessage(context.Context, *KafkaMessage) (*Response, error)

+ type UnsafeMessageBrokerServer interface

v0.5.0

Oct 19, 2020

v0.4.0

Jul 15, 2020

v0.3.2

Mar 12, 2020

v0.3.1

Mar 12, 2020

v0.3.0

Mar 12, 2020

v0.2.0

Feb 15, 2020

v0.1.0

Feb 11, 2020

Changes in this version

+ func RegisterMessageBrokerServer(s *grpc.Server, srv MessageBrokerServer)

+ type Message struct

+ Data []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Message) ProtoMessage()

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

+ 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 MessageBrokerClient interface

+ SendRabbitMQMessage func(ctx context.Context, in *RabbitMQMessage, opts ...grpc.CallOption) (*Response, error)

+ func NewMessageBrokerClient(cc *grpc.ClientConn) MessageBrokerClient

+ type MessageBrokerServer interface

+ SendRabbitMQMessage func(context.Context, *RabbitMQMessage) (*Response, error)

+ type RabbitMQMessage struct

+ Message *Message

+ Target *RabbitMQTarget

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RabbitMQMessage) ProtoMessage()

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

+ func (m *RabbitMQMessage) GetTarget() *RabbitMQTarget

+ func (m *RabbitMQMessage) Reset()

+ func (m *RabbitMQMessage) String() string

+ func (m *RabbitMQMessage) XXX_DiscardUnknown()

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

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

+ func (m *RabbitMQMessage) XXX_Size() int

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

+ type RabbitMQTarget struct

+ Exchange string

+ RouteKey string

+ Server string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*RabbitMQTarget) ProtoMessage()

+ func (m *RabbitMQTarget) GetExchange() string

+ func (m *RabbitMQTarget) GetRouteKey() string

+ func (m *RabbitMQTarget) GetServer() string

+ func (m *RabbitMQTarget) Reset()

+ func (m *RabbitMQTarget) String() string

+ func (m *RabbitMQTarget) XXX_DiscardUnknown()

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

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

+ func (m *RabbitMQTarget) XXX_Size() int

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

+ type Response struct

+ ErrorMessage string

+ ErrorNo int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*Response) ProtoMessage()

+ func (m *Response) GetErrorMessage() string

+ func (m *Response) GetErrorNo() int32

+ func (m *Response) Reset()

+ func (m *Response) String() string

+ func (m *Response) XXX_DiscardUnknown()

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

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

+ func (m *Response) XXX_Size() int

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

+ type UnimplementedMessageBrokerServer struct

+ func (*UnimplementedMessageBrokerServer) SendRabbitMQMessage(ctx context.Context, req *RabbitMQMessage) (*Response, error)

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