rpcrmq

README

go-rpc-rabbitmq is a rabbitmq based rpc system.

Reference

AMQP concepts

Documentation

Overview

Package rpcrmq is a generated protocol buffer package.

It is generated from these files:

error.proto

It has these top-level messages:

ErrorMessage

Index

• Constants
• func RegisterRPC(rpcName string, svc *RPCService) error
• func Request(con *amqp.Connection, method string, request []byte) ([]byte, error)
• func RequestWithTimeout(con *amqp.Connection, method string, request []byte, timeoutS int) ([]byte, error)
• func SetTimeoutGlobal(requestTimeoutS int)
• func StartRPCServer(endpoint string)
• type ErrorMessage
  • func (*ErrorMessage) Descriptor() ([]byte, []int)
  • func (*ErrorMessage) ProtoMessage()
  • func (m *ErrorMessage) Reset()
  • func (m *ErrorMessage) String() string
• type RPCService

Constants

const MessageTypeError = "Error"

const MessageTypeRequest = "Request"

const MessageTypeResponse = "Response"

Functions

func RegisterRPC

func RegisterRPC(rpcName string, svc *RPCService) error

func Request

func Request(con *amqp.Connection, method string, request []byte) ([]byte, error)

func RequestWithTimeout

func RequestWithTimeout(con *amqp.Connection, method string, request []byte, timeoutS int) ([]byte, error)

func SetTimeoutGlobal

func SetTimeoutGlobal(requestTimeoutS int)

func StartRPCServer

func StartRPCServer(endpoint string)

Types

type ErrorMessage

type ErrorMessage struct {
	Message string `protobuf:"bytes,1,opt,name=Message" json:"Message,omitempty"`
}

func (*ErrorMessage) Descriptor

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

func (*ErrorMessage) ProtoMessage

func (*ErrorMessage) ProtoMessage()

func (*ErrorMessage) Reset

func (m *ErrorMessage) Reset()

func (*ErrorMessage) String

func (m *ErrorMessage) String() string

type RPCService

type RPCService struct {
	Callback func([]byte) ([]byte, error)
}