trigger

Aug 31, 2022

Changes in this version

+ type DaprSubTrigger struct

+ func NewDaprSubTrigger(cfg config.Config) (*DaprSubTrigger, error)

+ func (t *DaprSubTrigger) Start() error

+ func (t *DaprSubTrigger) Stop() error

+ func (t *DaprSubTrigger) WaitForTrigger() <-chan TriggeredBy

+ type Trigger interface

+ Start func() error

+ Stop func() error

+ WaitForTrigger func() <-chan TriggeredBy

+ type TriggeredBy string

+ var TriggeredByDaprSub TriggeredBy = "DaprSub"

+ var TriggeredByTicker TriggeredBy = "Ticker"