Versions in this module Expand all Collapse all v0 v0.5.1 Feb 1, 2018 Changes in this version + func NewFactory(md *trigger.Metadata) trigger.Factory + type KafkaSubTrigger struct + func (t *KafkaSubTrigger) Init(runner action.Runner) + func (t *KafkaSubTrigger) Metadata() *trigger.Metadata + func (t *KafkaSubTrigger) Start() error + func (t *KafkaSubTrigger) Stop() error + type KafkasubFactory struct + func (t *KafkasubFactory) New(config *trigger.Config) trigger.Trigger