message

Documentation

Index

• func DecodeMsgToDebug(deviceID string, resp *pool.Message, tag string)
• func GetErrorResponse(ctx context.Context, messagePool *pool.Pool, code codes.Code, ...) (*pool.Message, func())
• func GetResourceInterface(msg *mux.Message) string
• func GetResponse(ctx context.Context, messagePool *pool.Pool, code codes.Code, ...) (*pool.Message, func())
• func LogAndGetErrorResponse(ctx context.Context, messagePool *pool.Pool, code codes.Code, ...) (*pool.Message, func())
• func URIToDeviceIDHref(msg *mux.Message) (deviceID, href string, err error)

Functions

func DecodeMsgToDebug

func DecodeMsgToDebug(deviceID string, resp *pool.Message, tag string)

func GetErrorResponse

func GetErrorResponse(ctx context.Context, messagePool *pool.Pool, code codes.Code, token message.Token, err error) (*pool.Message, func())

func GetResourceInterface

func GetResourceInterface(msg *mux.Message) string

Get resource interface from request query.

func GetResponse

func GetResponse(ctx context.Context, messagePool *pool.Pool, code codes.Code, token message.Token, contentFormat message.MediaType, payload []byte) (*pool.Message, func())

func LogAndGetErrorResponse

func LogAndGetErrorResponse(ctx context.Context, messagePool *pool.Pool, code codes.Code, token message.Token, err error) (*pool.Message, func())

func URIToDeviceIDHref

func URIToDeviceIDHref(msg *mux.Message) (deviceID, href string, err error)

URIToDeviceIDHref convert uri to deviceID and href. Expected input "/api/v1/devices/{deviceID}/{Href}".