producer

package

Go to main page

Versions in this module

v0

v0.4.5

Apr 3, 2017

Changes in this version

+ func NewMurmur2HashPartitioner(topic string) kafka.Partitioner

+ type Murmur2HashPartitioner struct

+ func (p *Murmur2HashPartitioner) Partition(message *kafka.ProducerMessage, numPartitions int32) (int32, error)

+ func (p *Murmur2HashPartitioner) RequiresConsistency() bool

+ type S3 struct

+ func (prod *S3) Configure(conf core.PluginConfig) error

+ func (prod *S3) Produce(workers *sync.WaitGroup)

+ type Statsd struct

+ func (prod *Statsd) Configure(conf core.PluginConfig) error

+ func (prod *Statsd) Produce(workers *sync.WaitGroup)

v0.4.4

Aug 16, 2016

Changes in this version

+ type Firehose struct

+ func (prod *Firehose) Configure(conf core.PluginConfig) error

+ func (prod *Firehose) Produce(workers *sync.WaitGroup)

type Spooling

+ func (prod *Spooling) Drop(msg core.Message)

v0.4.3

Apr 29, 2016

Changes in this version

+ type Benchmark struct

+ func (prod *Benchmark) Configure(conf core.PluginConfig) error

+ func (prod *Benchmark) Produce(workers *sync.WaitGroup)

v0.4.2

Feb 16, 2016

Changes in this version

+ type Kinesis struct

+ func (prod *Kinesis) Configure(conf core.PluginConfig) error

+ func (prod *Kinesis) Produce(workers *sync.WaitGroup)

type Spooling

+ RespoolDuration time.Duration

v0.4.1

Nov 10, 2015

v0.4.0

Aug 28, 2015

Changes in this version

+ type HTTPRequest struct

+ func (prod *HTTPRequest) Configure(conf core.PluginConfig) error

+ func (prod *HTTPRequest) Produce(workers *sync.WaitGroup)

+ type InfluxDB struct

+ func (prod *InfluxDB) Configure(conf core.PluginConfig) error

+ func (prod *InfluxDB) Produce(workers *sync.WaitGroup)

type Null

+ func (prod *Null) AddDependency(dep core.Producer)

+ func (prod *Null) DependsOn(dep core.Producer) bool

+ func (prod *Null) GetDropStreamID() core.MessageStreamID

+ func (prod *Null) GetState() core.PluginState

+ func (prod *Null) IsActive() bool

+ func (prod *Null) IsBlocked() bool

+ type Spooling struct

+ func (prod *Spooling) Configure(conf core.PluginConfig) error

+ func (prod *Spooling) Produce(workers *sync.WaitGroup)

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)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL