cron_trigger

README

CRON Trigger

This CRON trigger is based on github.com/robfig/cron. It differs from the default CRON because it includes seconds, much like the Quartz CRON commonly used in Java.

The CRON Trigger by default will be triggered in the machines local time.

Documentation

Index

• type Config
• type Trigger
  • func NewTrigger() *Trigger
  • func (t *Trigger) Close() error
  • func (t *Trigger) Init(stub domain.Stub, config []byte) error
  • func (t *Trigger) NextMessage() (tag string, message map[string]interface{}, err error)
  • func (t *Trigger) Respond(tag string, response map[string]interface{}, err error) error

Types

type Config

type Config struct {
	Specification string `toml:"specification"`
}

type Trigger

type Trigger struct {
	RequestChannel chan *domain.Request
	// contains filtered or unexported fields
}

func NewTrigger

func NewTrigger() *Trigger

func (*Trigger) Close

func (t *Trigger) Close() error

func (*Trigger) Init

func (t *Trigger) Init(stub domain.Stub, config []byte) error

func (*Trigger) NextMessage

func (t *Trigger) NextMessage() (tag string, message map[string]interface{}, err error)

func (*Trigger) Respond

func (t *Trigger) Respond(tag string, response map[string]interface{}, err error) error