message

Documentation

Index

• 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 IsTempError(err error) bool
• func URIToDeviceIDHref(msg *mux.Message) (deviceID, href string, err error)
• type JsonCoapMessage
  • func ToJson(m *pool.Message, withBody, withToken bool) JsonCoapMessage
  • func (c JsonCoapMessage) IsEmpty() bool

Functions

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 IsTempError

func IsTempError(err error) bool

IsTempError returns true if error is temporary. Only certain errors are not considered as temporary errors.

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}".

Types

type JsonCoapMessage

type JsonCoapMessage struct {
	Code          string      `json:"code,omitempty"`
	Path          string      `json:"href,omitempty"`
	Token         string      `json:"token,omitempty"`
	Queries       []string    `json:"queries,omitempty"`
	Observe       *uint32     `json:"observe,omitempty"`
	ContentFormat string      `json:"contentFormat,omitempty"`
	Body          interface{} `json:"body,omitempty"`
}

func ToJson

func ToJson(m *pool.Message, withBody, withToken bool) JsonCoapMessage

func (JsonCoapMessage) IsEmpty

func (c JsonCoapMessage) IsEmpty() bool