trigger

Documentation

Index

• type AMQPTrigger
  • 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
  • func NewHTTPTrigger(endpoint string, responseMimeType string) *HTTPTrigger
  • func (t *HTTPTrigger) RunFunc(f RunFunc)
  • func (t *HTTPTrigger) Start()
  • func (t *HTTPTrigger) Stop()
• type RunFunc
• type SQSTrigger
  • 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
  • func NewTimerTrigger(cronStr string) *TimerTrigger
  • func (t *TimerTrigger) RunFunc(f RunFunc)
  • func (t *TimerTrigger) Start()
  • func (t *TimerTrigger) Stop()
• type Trigger

Types

type AMQPTrigger

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

func NewAMQPTrigger

func NewAMQPTrigger(rabbitURL string, routingKey string, numWorkers int) *AMQPTrigger

NewSQSTrigger attaches to a SQS queue and executes Func for every message. If Func returns error != nil, message is not deleted after processing.

func (*AMQPTrigger) RunFunc

func (t *AMQPTrigger) RunFunc(f RunFunc)

func (*AMQPTrigger) Start

func (t *AMQPTrigger) Start()

func (*AMQPTrigger) Stop

func (t *AMQPTrigger) Stop()

type HTTPTrigger

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

func NewHTTPTrigger

func NewHTTPTrigger(endpoint string, responseMimeType string) *HTTPTrigger

NewHTTPTrigger registers an endpoint to call Fn If Rn returns err, Trigger will respond with HTTP 400 Bad Request Trigger will send Fn return string as response

func (*HTTPTrigger) RunFunc

func (t *HTTPTrigger) RunFunc(f RunFunc)

func (*HTTPTrigger) Start

func (t *HTTPTrigger) Start()

func (*HTTPTrigger) Stop

func (t *HTTPTrigger) Stop()

type RunFunc

type RunFunc func(*string) (*string, error)

type SQSTrigger

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

func NewSQSTrigger

func NewSQSTrigger(sqsClient *sqs.SQS, sqsURL string, sqsBatchSize int64) *SQSTrigger

NewSQSTrigger attaches to a SQS queue and executes Func for every message. If Func returns error != nil, message is not deleted after processing.

func (*SQSTrigger) RunFunc

func (t *SQSTrigger) RunFunc(f RunFunc)

func (*SQSTrigger) Start

func (t *SQSTrigger) Start()

func (*SQSTrigger) Stop

func (t *SQSTrigger) Stop()

type TimerTrigger

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

func NewTimerTrigger

func NewTimerTrigger(cronStr string) *TimerTrigger

NewTimerTrigger registers a new function to be executed at the specified time interface cron is a crontab style string, refer to https://godoc.org/github.com/robfig/cron

func (*TimerTrigger) RunFunc

func (t *TimerTrigger) RunFunc(f RunFunc)

func (*TimerTrigger) Start

func (t *TimerTrigger) Start()

func (*TimerTrigger) Stop

func (t *TimerTrigger) Stop()

type Trigger

type Trigger interface {
	RunFunc(RunFunc)
	Start()
	Stop()
}