messaging

Documentation

Index

• type AMQManager
  • func NewAMQManager(amqpURL string, amqpQueue string, messageHandler *MessageHandler) *AMQManager
  • func (manager *AMQManager) Connect() (err error)
  • func (manager *AMQManager) Disconnect() (err error)
  • func (manager *AMQManager) WaitForMessages() (err error)
• type MessageHandler
  • func NewMessageHandler(dataStore *models.DogMongoStore) *MessageHandler
  • func (messageHandler *MessageHandler) CreateDog(rpcIn *RPCMessage) (rpcOut *RPCMessage, err error)
  • func (messageHandler *MessageHandler) DeleteDog(rpcIn *RPCMessage) (rpcOut *RPCMessage, err error)
  • func (messageHandler *MessageHandler) ReadAllDogs(rpcIn *RPCMessage) (rpcOut *RPCMessage, err error)
  • func (messageHandler *MessageHandler) ReadDog(rpcIn *RPCMessage) (rpcOut *RPCMessage, err error)
  • func (messageHandler *MessageHandler) RouteMessage(message []byte) (rpcOut *RPCMessage)
  • func (messageHandler *MessageHandler) UpdateDog(rpcIn *RPCMessage) (rpcOut *RPCMessage, err error)
• type RPCMessage
• type RPCMessageType

Types

type AMQManager

type AMQManager struct {
	// contains filtered or unexported fields
}

func NewAMQManager

func NewAMQManager(amqpURL string, amqpQueue string, messageHandler *MessageHandler) *AMQManager

func (*AMQManager) Connect

func (manager *AMQManager) Connect() (err error)

func (*AMQManager) Disconnect

func (manager *AMQManager) Disconnect() (err error)

func (*AMQManager) WaitForMessages

func (manager *AMQManager) WaitForMessages() (err error)

type MessageHandler

type MessageHandler struct {
	// contains filtered or unexported fields
}

func NewMessageHandler

func NewMessageHandler(dataStore *models.DogMongoStore) *MessageHandler

func (*MessageHandler) CreateDog

func (messageHandler *MessageHandler) CreateDog(rpcIn *RPCMessage) (rpcOut *RPCMessage, err error)

func (*MessageHandler) DeleteDog

func (messageHandler *MessageHandler) DeleteDog(rpcIn *RPCMessage) (rpcOut *RPCMessage, err error)

func (*MessageHandler) ReadAllDogs

func (messageHandler *MessageHandler) ReadAllDogs(rpcIn *RPCMessage) (rpcOut *RPCMessage, err error)

func (*MessageHandler) ReadDog

func (messageHandler *MessageHandler) ReadDog(rpcIn *RPCMessage) (rpcOut *RPCMessage, err error)

func (*MessageHandler) RouteMessage

func (messageHandler *MessageHandler) RouteMessage(message []byte) (rpcOut *RPCMessage)

RouteMessage routes message to appropriate message handler. When errors occur returns an ErrorMessage

func (*MessageHandler) UpdateDog

func (messageHandler *MessageHandler) UpdateDog(rpcIn *RPCMessage) (rpcOut *RPCMessage, err error)

type RPCMessage

type RPCMessage struct {
	Type RPCMessageType
	Data []byte
}

type RPCMessageType

type RPCMessageType int

const (
	ReadAllMessage RPCMessageType = iota
	CreateMessage
	ReadMessage
	UpdateMessage
	DeleteMessage
	ErrorMessage
	UnknownMessage
)