messagebroker

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMessageBrokerServer 

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

Types

type Message 

type Message struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Message) Descriptor 

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

func (*Message) GetData 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

type MessageBrokerClient 

type MessageBrokerClient interface {
	SendRabbitMQMessage(ctx context.Context, in *RabbitMQMessage, opts ...grpc.CallOption) (*Response, error)
}

MessageBrokerClient is the client API for MessageBroker service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMessageBrokerClient 

func NewMessageBrokerClient(cc *grpc.ClientConn) MessageBrokerClient

type MessageBrokerServer 

type MessageBrokerServer interface {
	SendRabbitMQMessage(context.Context, *RabbitMQMessage) (*Response, error)
}

MessageBrokerServer is the server API for MessageBroker service.

type RabbitMQMessage 

type RabbitMQMessage struct {
	Target               *RabbitMQTarget `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	Message              *Message        `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*RabbitMQMessage) Descriptor 

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

func (*RabbitMQMessage) GetMessage 

func (m *RabbitMQMessage) GetMessage() *Message

func (*RabbitMQMessage) GetTarget 

func (m *RabbitMQMessage) GetTarget() *RabbitMQTarget

func (*RabbitMQMessage) ProtoMessage 

func (*RabbitMQMessage) ProtoMessage()

func (*RabbitMQMessage) Reset 

func (m *RabbitMQMessage) Reset()

func (*RabbitMQMessage) String 

func (m *RabbitMQMessage) String() string

func (*RabbitMQMessage) XXX_DiscardUnknown 

func (m *RabbitMQMessage) XXX_DiscardUnknown()

func (*RabbitMQMessage) XXX_Marshal 

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

func (*RabbitMQMessage) XXX_Merge 

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

func (*RabbitMQMessage) XXX_Size 

func (m *RabbitMQMessage) XXX_Size() int

func (*RabbitMQMessage) XXX_Unmarshal 

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

type RabbitMQTarget 

type RabbitMQTarget struct {
	Server               string   `protobuf:"bytes,1,opt,name=server,proto3" json:"server,omitempty"`
	Exchange             string   `protobuf:"bytes,2,opt,name=exchange,proto3" json:"exchange,omitempty"`
	RouteKey             string   `protobuf:"bytes,3,opt,name=route_key,json=routeKey,proto3" json:"route_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RabbitMQTarget) Descriptor 

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

func (*RabbitMQTarget) GetExchange 

func (m *RabbitMQTarget) GetExchange() string

func (*RabbitMQTarget) GetRouteKey 

func (m *RabbitMQTarget) GetRouteKey() string

func (*RabbitMQTarget) GetServer 

func (m *RabbitMQTarget) GetServer() string

func (*RabbitMQTarget) ProtoMessage 

func (*RabbitMQTarget) ProtoMessage()

func (*RabbitMQTarget) Reset 

func (m *RabbitMQTarget) Reset()

func (*RabbitMQTarget) String 

func (m *RabbitMQTarget) String() string

func (*RabbitMQTarget) XXX_DiscardUnknown 

func (m *RabbitMQTarget) XXX_DiscardUnknown()

func (*RabbitMQTarget) XXX_Marshal 

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

func (*RabbitMQTarget) XXX_Merge 

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

func (*RabbitMQTarget) XXX_Size 

func (m *RabbitMQTarget) XXX_Size() int

func (*RabbitMQTarget) XXX_Unmarshal 

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

type Response 

type Response struct {
	ErrorNo              int32    `protobuf:"varint,1,opt,name=error_no,json=errorNo,proto3" json:"error_no,omitempty"`
	ErrorMessage         string   `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Response) Descriptor 

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

func (*Response) GetErrorMessage 

func (m *Response) GetErrorMessage() string

func (*Response) GetErrorNo 

func (m *Response) GetErrorNo() int32

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) String 

func (m *Response) String() string

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type UnimplementedMessageBrokerServer 

type UnimplementedMessageBrokerServer struct {
}

UnimplementedMessageBrokerServer can be embedded to have forward compatible implementations.

func (*UnimplementedMessageBrokerServer) SendRabbitMQMessage 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.