Versions in this module Expand all Collapse all v1 v1.0.2 Jun 1, 2026 v1.0.1 May 29, 2026 Changes in this version + type Alarm struct + Days []time.Weekday + Hour int + Minute int + func NewAlarm(id string, timeOfDay string, days []string) (*Alarm, error) + func (a *Alarm) Close() error + func (a *Alarm) Setup(_ context.Context) error + func (a *Alarm) Wait(ctx context.Context) (engine.Event, error) + type Delay struct + Duration time.Duration + func NewDelay(id string, d time.Duration) *Delay + func (d *Delay) Close() error + func (d *Delay) Setup(_ context.Context) error + func (d *Delay) Wait(ctx context.Context) (engine.Event, error) + type Direction string + const DirBoth + const DirFalling + const DirRising + type Edge string + const EdgeBoth + const EdgeFalling + const EdgeRising + type OnMqttMessage struct + func NewOnMqttMessage(id string, ch *channel.MQTT, topic string, dataType workflow.DataType, ...) (*OnMqttMessage, error) + func (*OnMqttMessage) Close() error + func (t *OnMqttMessage) Outputs() map[string]workflow.DataType + func (t *OnMqttMessage) Wait(ctx context.Context) (engine.Event, error) + type OnPinEdge struct + func NewOnPinEdge(id string, gpioin *channel.GPIOInput, edge Edge) *OnPinEdge + func (p *OnPinEdge) Close() error + func (p *OnPinEdge) Wait(ctx context.Context) (engine.Event, error) + type OnSerialReceive struct + func NewOnSerialReceive(id string, uart *channel.UART, binding workflow.OutputBinding) *OnSerialReceive + func (t *OnSerialReceive) Close() error + func (t *OnSerialReceive) Outputs() map[string]workflow.DataType + func (t *OnSerialReceive) Wait(ctx context.Context) (engine.Event, error) + type OnThreshold struct + func NewOnThreshold(id string, variable workflow.Reference, threshold float64, direction Direction, ...) *OnThreshold + func (t *OnThreshold) Close() error + func (t *OnThreshold) Outputs() map[string]workflow.DataType + func (t *OnThreshold) Wait(ctx context.Context) (engine.Event, error) + type Ticker struct + Interval time.Duration + func NewTicker(id string, interval time.Duration) *Ticker + func (t *Ticker) Close() error + func (t *Ticker) Setup(_ context.Context) error + func (t *Ticker) Wait(ctx context.Context) (engine.Event, error)
Go to main page