application

Documentation

Index

• Variables
• type App
  • func New(msgCtx messaging.MsgContext, tc things.Client, s storage.Storage) (App, error)
• type CipFunctionHandler

Variables

var DigitalInputMessageFilter = func(m messaging.Message) bool {
	return strings.HasPrefix(m.ContentType(), "application/vnd.diwise.digitalinput")
}

var DistanceMessageFilter = func(m messaging.Message) bool {
	return strings.HasPrefix(m.ContentType(), "application/vnd.oma.lwm2m.ext.3330")
}

var ErrNoRelatedThingFound = fmt.Errorf("no related thing found")

var LevelMessageFilter = func(m messaging.Message) bool {
	return strings.HasPrefix(m.ContentType(), "application/vnd.diwise.level")
}

var StopwatchMessageFilter = func(m messaging.Message) bool {
	return strings.HasPrefix(m.ContentType(), "application/vnd.diwise.stopwatch")
}

var TemperatureMessageFilter = func(m messaging.Message) bool {
	return strings.HasPrefix(m.ContentType(), "application/vnd.oma.lwm2m.ext.3303")
}

Types

type App

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

func New

func New(msgCtx messaging.MsgContext, tc things.Client, s storage.Storage) (App, error)

type CipFunctionHandler

type CipFunctionHandler interface {
	messaging.TopicMessage
	Handle(ctx context.Context, itm messaging.IncomingTopicMessage, tc things.Client) (bool, error)
}