Versions in this module Expand all Collapse all v0 v0.1.1 Oct 7, 2017 v0.1.0 Jul 17, 2017 Changes in this version + type Payload struct + Data map[string]interface{} + Topic string + type Plugin struct + func New(qChan qtypes.QChan, cfg *config.Config, name string) (Plugin, error) + func (p *Plugin) Connect() + func (p *Plugin) PushToKafka(e interface{}) (err error) + func (p *Plugin) Run() + func (p *Plugin) ToPayload(e interface{}) (payloads []Payload, err error)
Go to main page