handler

Documentation

Index

• type MessageHandler
  • func NewMessageHandler() *MessageHandler
  • func (h *MessageHandler) AddHandler(msgType string, handlerFunc MessageHandlerFunc)
  • func (h *MessageHandler) Handle(ctx context.Context, msgType string, payload []byte) error
• type MessageHandlerFunc

Types

type MessageHandler

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

A MessageHandler is responsible for routing messages of a set of types to their associated handler functions.

func NewMessageHandler

func NewMessageHandler() *MessageHandler

NewMessageHandler initializes and returns a pointer to a new MessageHandler.

func (*MessageHandler) AddHandler

func (h *MessageHandler) AddHandler(msgType string, handlerFunc MessageHandlerFunc)

AddHandler is used to register a MessageHandlerFunc for a given message type. This currently on supports a single handler for each message type. Subsequent calls to AddHandler will replace the current handler for a given message type. Last write wins.

func (*MessageHandler) Handle

func (h *MessageHandler) Handle(ctx context.Context, msgType string, payload []byte) error

Handle is used to dispatch a message of msgType type with a byte-array payload. This will return an error if the handler function returns an error or if there is no handler for a given message type.

type MessageHandlerFunc

type MessageHandlerFunc func(ctx context.Context, payload []byte) error

MessageHandlerFunc is a function accepting a byte array message payload that returns an optional error.