Versions in this module Expand all Collapse all v2 v2.0.11 Apr 15, 2021 Changes in this version + type AMQPTrigger struct + func NewAMQPTrigger(rabbitURL string, routingKey string, numWorkers int) *AMQPTrigger + func (t *AMQPTrigger) RunFunc(f RunFunc) + func (t *AMQPTrigger) Start() + func (t *AMQPTrigger) Stop() + type HTTPTrigger struct + func NewHTTPTrigger(endpoint string, responseMimeType string) *HTTPTrigger + func (t *HTTPTrigger) RunFunc(f RunFunc) + func (t *HTTPTrigger) Start() + func (t *HTTPTrigger) Stop() + type RunFunc func(*string) (*string, error) + type SQSTrigger struct + func NewSQSTrigger(sqsClient *sqs.SQS, sqsURL string, sqsBatchSize int64) *SQSTrigger + func (t *SQSTrigger) RunFunc(f RunFunc) + func (t *SQSTrigger) Start() + func (t *SQSTrigger) Stop() + type TimerTrigger struct + func NewTimerTrigger(cronStr string) *TimerTrigger + func (t *TimerTrigger) RunFunc(f RunFunc) + func (t *TimerTrigger) Start() + func (t *TimerTrigger) Stop() + type Trigger interface + RunFunc func(RunFunc) + Start func() + Stop func()