channel

Nov 8, 2018

Changes in this version

+ func NewFactory(md *trigger.Metadata) trigger.Factory

+ type ChannelFactory struct

+ func (t *ChannelFactory) New(config *trigger.Config) trigger.Trigger

+ type ChannelListener struct

+ func (l *ChannelListener) OnMessage(msg interface{})

+ type ChannelTrigger struct

+ func (t *ChannelTrigger) Initialize(ctx trigger.InitContext) error

+ func (t *ChannelTrigger) Metadata() *trigger.Metadata

+ func (t *ChannelTrigger) Start() error

+ func (t *ChannelTrigger) Stop() error