Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Alarm ¶
type Alarm struct {
engine.TriggerNode
Hour int
Minute int
Days []time.Weekday // empty → daily
// contains filtered or unexported fields
}
Alarm fires at a specific local time of day, optionally restricted to a set of weekdays. Empty Days means every day.
type Delay ¶
type Delay struct {
engine.TriggerNode
Duration time.Duration
// contains filtered or unexported fields
}
Delay fires exactly once after its configured duration, measured from Setup. Subsequent Wait calls block on ctx indefinitely — the single-shot semantics mirror the codegen pattern (Ticker::OneShot at startup).
type Direction ¶
type Direction string
Direction selects which side of a crossing fires the trigger.
type OnMqttMessage ¶
type OnMqttMessage struct {
engine.TriggerNode
// contains filtered or unexported fields
}
OnMqttMessage fires whenever a message matching the configured topic filter arrives on the bound MQTT channel. The payload is parsed as bare JSON into a value of the declared dataType; mismatches are logged and dropped so a single bad message can't crash the trigger goroutine.
func NewOnMqttMessage ¶
func NewOnMqttMessage(id string, ch *channel.MQTT, topic string, dataType workflow.DataType, binding workflow.OutputBinding, qos byte) (*OnMqttMessage, error)
NewOnMqttMessage creates a new OnMqttMessage trigger.
func (*OnMqttMessage) Close ¶
func (*OnMqttMessage) Close() error
type OnPinEdge ¶
type OnPinEdge struct {
engine.TriggerNode
// contains filtered or unexported fields
}
OnPinEdge fires when a digital pin sees the configured edge transition.
func NewOnPinEdge ¶
NewOnPinEdge subscribes to the channel's edge stream and returns the trigger.
type OnSerialReceive ¶
type OnSerialReceive struct {
engine.TriggerNode
// contains filtered or unexported fields
}
OnSerialReceive fires whenever a line is received on the configured UART channel, emitting the line (terminator stripped) to its output binding.
func NewOnSerialReceive ¶
func NewOnSerialReceive(id string, uart *channel.UART, binding workflow.OutputBinding) *OnSerialReceive
NewOnSerialReceive creates a new OnSerialReceive trigger.
func (*OnSerialReceive) Close ¶
func (t *OnSerialReceive) Close() error
type OnThreshold ¶
type OnThreshold struct {
engine.TriggerNode
// contains filtered or unexported fields
}
OnThreshold fires when a watched numeric variable crosses a threshold.
func NewOnThreshold ¶
func (*OnThreshold) Close ¶
func (t *OnThreshold) Close() error
Source Files