triggers

Feb 5, 2024

Changes in this version

+ type EventEntityState struct

+ Attributes m.AttributeValue

+ EntityId common.EntityId

+ LastChanged *time.Time

+ LastUpdated *time.Time

+ Settings m.AttributeValue

+ State *events.EntityState

+ Value interface{}

+ type TriggerStateChangedMessage struct

+ DoNotSaveMetric bool

+ EntityId common.EntityId

+ NewState EventEntityState

+ OldState EventEntityState

+ PluginName string

+ StorageSave bool

Jan 8, 2024

Changes in this version

+ var F embed.FS

+ type SystemTriggerMessage struct

+ Event interface{}

+ EventName string

+ Topic string

Jun 23, 2023

Changes in this version

+ const Version

Feb 5, 2022

Changes in this version

type ITrigger

+ CallManual func()

type StateChangeTrigger

+ func (t *StateChangeTrigger) CallManual()

type SystemTrigger

+ func (t *SystemTrigger) CallManual()

type TimeTrigger

+ func (t *TimeTrigger) CallManual()

Nov 28, 2021

Changes in this version

+ const CronOptionTrigger

+ const EventStart

+ const EventStop

+ const Name

+ const StateChangeFunctionName

+ const StateChangeName

+ const StateChangeQueueSize

+ const SystemFunctionName

+ const SystemName

+ const SystemQueueSize

+ const TimeFunctionName

+ const TimeName

+ const TimeQueueSize

+ const TopicSystem

+ const TopicSystemStart

+ const TopicSystemStop

+ func New() plugins.Plugable

+ type IGetTrigger interface

+ GetTrigger func(string) (ITrigger, error)

+ type IRegistrar interface

+ RegisterTrigger func(ITrigger) error

+ TriggerList func() []string

+ UnregisterTrigger func(string) error

+ type ITrigger interface

+ AsyncAttach func(wg *sync.WaitGroup)

+ FunctionName func() string

+ Name func() string

+ Subscribe func(Subscriber) error

+ Unsubscribe func(Subscriber) error

+ func NewStateChangedTrigger(eventBus event_bus.EventBus) ITrigger

+ func NewSystemTrigger(eventBus event_bus.EventBus) ITrigger

+ func NewTimeTrigger(eventBus event_bus.EventBus) ITrigger

+ type StateChangeTrigger struct

+ func (b *StateChangeTrigger) FunctionName() string

+ func (b *StateChangeTrigger) Name() string

+ func (t *StateChangeTrigger) AsyncAttach(wg *sync.WaitGroup)

+ func (t *StateChangeTrigger) Subscribe(options Subscriber) error

+ func (t *StateChangeTrigger) Unsubscribe(options Subscriber) error

+ type Subscriber struct

+ EntityId *common.EntityId

+ Handler interface{}

+ Payload m.Attributes

+ type SystemTrigger struct

+ func (b *SystemTrigger) FunctionName() string

+ func (b *SystemTrigger) Name() string

+ func (t *SystemTrigger) AsyncAttach(wg *sync.WaitGroup)

+ func (t *SystemTrigger) Subscribe(options Subscriber) error

+ func (t *SystemTrigger) Unsubscribe(options Subscriber) error

+ type TimeTrigger struct

+ func (b *TimeTrigger) FunctionName() string

+ func (b *TimeTrigger) Name() string

+ func (t *TimeTrigger) AsyncAttach(wg *sync.WaitGroup)

+ func (t *TimeTrigger) Subscribe(options Subscriber) error

+ func (t *TimeTrigger) Unsubscribe(options Subscriber) error