trigger

Documentation

Index

• type DaprSubTrigger
  • 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
• type TriggeredBy

Types

type DaprSubTrigger

type DaprSubTrigger struct {
	// contains filtered or unexported fields
}

func NewDaprSubTrigger

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

func (*DaprSubTrigger) Start

func (t *DaprSubTrigger) Start() error

func (*DaprSubTrigger) Stop

func (t *DaprSubTrigger) Stop() error

func (*DaprSubTrigger) WaitForTrigger

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

type Trigger

type Trigger interface {
	WaitForTrigger() <-chan TriggeredBy
	Start() error
	Stop() error
}

type TriggeredBy

type TriggeredBy string

var TriggeredByDaprSub TriggeredBy = "DaprSub"

var TriggeredByTicker TriggeredBy = "Ticker"