trigger

Documentation

Index

• func CreateTrigger(typeName string, param map[string]interface{}) (interface{}, error)
• type Cron
  • func (tgr *Cron) Run(ctx context.Context, sendParam func(map[string]interface{}))
• type HTTP
  • func (tgr *HTTP) Run(ctx context.Context, sendParam func(map[string]interface{}))
• type Tick
  • func (tgr *Tick) Run(ctx context.Context, sendParam func(map[string]interface{}))

Functions

func CreateTrigger

func CreateTrigger(typeName string, param map[string]interface{}) (interface{}, error)

CreateTrigger create a new trigger

Types

type Cron

type Cron struct {
	util.BaseLogger
	Spec        string
	WithSeconds bool
}

Cron is a trigger which will be active according to the spec

func (*Cron) Run

func (tgr *Cron) Run(ctx context.Context, sendParam func(map[string]interface{}))

Run the Cron trigger

type HTTP

type HTTP struct {
	util.HTTPServer
}

HTTP is a trigger which will listen to http request

func (*HTTP) Run

func (tgr *HTTP) Run(ctx context.Context, sendParam func(map[string]interface{}))

Run the HTTP trigger

type Tick

type Tick struct {
	Interval time.Duration
}

Tick is a trigger which will be active periodically

func (*Tick) Run

func (tgr *Tick) Run(ctx context.Context, sendParam func(map[string]interface{}))

Run the Tick trigger