Versions in this module Expand all Collapse all v0 v0.3.2 Jun 22, 2015 Changes in this version + type Console struct + func (prod *Console) Configure(conf core.PluginConfig) error + func (prod *Console) Produce(workers *sync.WaitGroup) + type ElasticSearch struct + func (prod *ElasticSearch) Configure(conf core.PluginConfig) error + func (prod *ElasticSearch) Produce(workers *sync.WaitGroup) + type File struct + func (prod *File) Configure(conf core.PluginConfig) error + func (prod *File) Produce(workers *sync.WaitGroup) + type HttpReq struct + func (prod *HttpReq) Configure(conf core.PluginConfig) error + func (prod HttpReq) Produce(workers *sync.WaitGroup) + type Kafka struct + func (prod *Kafka) Configure(conf core.PluginConfig) error + func (prod *Kafka) Produce(workers *sync.WaitGroup) + type Null struct + func (prod *Null) Configure(conf core.PluginConfig) error + func (prod *Null) Control() chan<- core.PluginControl + func (prod *Null) Enqueue(msg core.Message) + func (prod *Null) Produce(threads *sync.WaitGroup) + func (prod *Null) Streams() []core.MessageStreamID + type Proxy struct + func (prod *Proxy) Configure(conf core.PluginConfig) error + func (prod *Proxy) Produce(workers *sync.WaitGroup) + type Redis struct + func (prod *Redis) Configure(conf core.PluginConfig) error + func (prod *Redis) Produce(workers *sync.WaitGroup) + type Scribe struct + func (prod *Scribe) Configure(conf core.PluginConfig) error + func (prod *Scribe) Produce(workers *sync.WaitGroup) + type Socket struct + func (prod *Socket) Configure(conf core.PluginConfig) error + func (prod *Socket) Produce(workers *sync.WaitGroup) + type Websocket struct + func (prod *Websocket) Configure(conf core.PluginConfig) error + func (prod *Websocket) Produce(workers *sync.WaitGroup)
Go to main page