functions

Documentation

Index

• func NewFunctionUpdatedMessage(f *fnct) messaging.TopicMessage
• func Transform(ctx context.Context, msgctx messaging.MsgContext, ...) error
• type Function
• type LogValue
• type Registry
  • func NewRegistry(ctx context.Context, input io.Reader, storage database.Storage) (Registry, error)
• type RegistryMatcherFunc
  • func MatchAll() RegistryMatcherFunc
  • func MatchSensor(sensorId string) RegistryMatcherFunc

Functions

func NewFunctionUpdatedMessage

func NewFunctionUpdatedMessage(f *fnct) messaging.TopicMessage

func Transform

func Transform(ctx context.Context, msgctx messaging.MsgContext, msg messaging.IncomingTopicMessage) error

Types

type Function

type Function interface {
	ID() string
	Name() string

	Handle(context.Context, *events.MessageAccepted, messaging.MsgContext) error
	History(context.Context, string, int) ([]LogValue, error)
}

type LogValue

type LogValue struct {
	Value     float64   `json:"v"`
	Timestamp time.Time `json:"ts"`
}

type Registry

type Registry interface {
	Find(ctx context.Context, matchers ...RegistryMatcherFunc) ([]Function, error)
	Get(ctx context.Context, functionID string) (Function, error)
}

func NewRegistry

func NewRegistry(ctx context.Context, input io.Reader, storage database.Storage) (Registry, error)

type RegistryMatcherFunc

type RegistryMatcherFunc func(r *reg) []Function

func MatchAll

func MatchAll() RegistryMatcherFunc

func MatchSensor

func MatchSensor(sensorId string) RegistryMatcherFunc