messaging

type CommandHandler ¶

type CommandHandler func(CommandMessageWrapper) error

CommandHandler is a callback type to be used for dispatching incoming commands

func NewPingCommandHandler(ctx Context) CommandHandler

type CommandMessage ¶

type CommandMessage interface {
	ContentType() string
}

CommandMessage is an interface used when sending commands

func NewPingCommand() CommandMessage

func NewPongResponse(ping PingCommand) CommandMessage

type CommandMessageWrapper ¶

type CommandMessageWrapper interface {
	Body() []byte
	RespondWith(CommandMessage) error
}

CommandMessageWrapper is used to wrap an incoming command message

type Config ¶

type Config struct {
	ServiceName string
	Host        string
	User        string
	Password    string
}

Config is an encapsulating context that wraps configuration information used by the initialization methods of the messaging library

func LoadConfiguration(serviceName string) Config

type Context ¶

type Context interface {
	NoteToSelf(command CommandMessage) error
	SendCommandTo(command CommandMessage, key string) error
	SendResponseTo(response CommandMessage, key string) error
	PublishOnTopic(message TopicMessage) error
	Close()
	RegisterCommandHandler(contentType string, handler CommandHandler) error
	RegisterTopicMessageHandler(routingKey string, handler TopicMessageHandler)
}

Context encapsulates the underlying messaging primitives, as well as their associated configuration

func Initialize(cfg Config) (Context, error)

type Error ¶

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

Error encapsulates a lower level error together with an error message provided by the caller that experienced the error

func (err *Error) Error() string

type IoTHubMessage ¶

type IoTHubMessage struct {
	Origin    IoTHubMessageOrigin `json:"origin"`
	Timestamp string              `json:"timestamp"`
}

type IoTHubMessageOrigin ¶

type IoTHubMessageOrigin struct {
	Device    string  `json:"device"`
	Latitude  float64 `json:"latitude"`
	Longitude float64 `json:"longitude"`
}

type PingCommand ¶

type PingCommand struct {
	Cmd       string    `json:"cmd"`
	Timestamp time.Time `json:"timestamp"`
}

PingCommand is a utility command to check the messenger connection

func (cmd PingCommand) ContentType() string

type PongResponse ¶

type PongResponse struct {
	Cmd       string `json:"cmd"`
	PingSent  time.Time
	Timestamp time.Time `json:"timestamp"`
}

PongResponse is a utility response to check the messenger connection

func (cmd PongResponse) ContentType() string

type TopicMessage ¶

type TopicMessage interface {
	ContentType() string
	TopicName() string
}

TopicMessage is an interface used when sending messages to make sure that messages are sent to the correct topic with correct content type

type TopicMessageHandler ¶

type TopicMessageHandler func(amqp.Delivery)

TopicMessageHandler is a callback type that should be passed to RegisterTopicMessageHandler to receive messages from topics.