producer

package

Go to main page

Versions in this module

v0

v0.6.0-beta2

Jul 30, 2019

v0.6.0-beta1

Jul 19, 2019

v0.6.0-alpha1

Aug 22, 2018

v0.5.4

Apr 17, 2019

v0.5.3

Apr 23, 2018

v0.5.2

Mar 30, 2018

Changes in this version

+ type AwsCloudwatchLogs struct

+ AwsMultiClient components.AwsMultiClient

+ func (prod *AwsCloudwatchLogs) Configure(conf core.PluginConfigReader)

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

v0.5.1

Jan 24, 2018

v0.5.0

Dec 21, 2017

Changes in this version

+ type AwsFirehose struct

+ AwsMultiClient components.AwsMultiClient

+ func (prod *AwsFirehose) Configure(conf core.PluginConfigReader)

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

+ type AwsKinesis struct

+ AwsMultiClient components.AwsMultiClient

+ func (prod *AwsKinesis) Configure(conf core.PluginConfigReader)

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

+ type AwsS3 struct

+ AwsMultiClient components.AwsMultiClient

+ BatchConfig components.BatchedWriterConfig

+ Rotate components.RotateConfig

+ func (prod *AwsS3) Configure(conf core.PluginConfigReader)

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

type File

+ BatchConfig components.BatchedWriterConfig

+ Pruner file.Pruner

+ Rotate components.RotateConfig

type Spooling

+ func (prod *Spooling) Modulate(msg *core.Message) core.ModulateResult

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

+ type StatsdMetrics struct

+ func (prod *StatsdMetrics) Configure(conf core.PluginConfigReader)

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

v0.5.0-rc3.1

Aug 15, 2017

v0.5.0-rc3

Aug 15, 2017

v0.5.0-rc2

Aug 10, 2017

v0.5.0-rc1

Aug 7, 2017

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