Versions in this module Expand all Collapse all v0 v0.0.1 Dec 29, 2017 Changes in this version + var ProducerMessagePool = sync.Pool + func GetSaramaProducer(topic string, partition int32, value []byte) *sarama.ProducerMessage + type Config struct + Brokers []string + Buffered bool + ChannelBufferSize int + Compression string + CompressionLevel int + DistributionAlgorithm distribution.Algorithm + Encoding OutputEncoding + FlushFrequency time.Duration + Name string + Partition int32 + RequiredAcks sarama.RequiredAcks + RetryMax int + Servers []string + Shards int + TLS TLSConfig + Topic string + Type Transport + func (c *Config) FromParsed(cfg ConfigForFile) error + type ConfigForFile struct + Brokers []string + Buffered bool + ChannelBufferSize int + Compression string + CompressionLevel int + DistributionAlgorithm string + Encoding string + FlushFrequency time.Duration + Name string + Partition int32 + RequiredAcks sarama.RequiredAcks + RetryMax int + Servers []string + Shards int + TLS TLSConfig + Topic string + Type string + type OutputEncoding int + const GraphiteLineEncoding + const JsonEncoding + const ProtobufEncoding + func (e *OutputEncoding) FromString(s string) error + func (e *OutputEncoding) MarshalJSON() ([]byte, error) + func (e *OutputEncoding) UnmarshalJSON(data []byte) error + func (e *OutputEncoding) UnmarshalYAML(unmarshal func(interface{}) error) error + func (e OutputEncoding) String() string + type TLSConfig struct + Enabled bool + SkipInsecureCerts bool + type Transport int + const Kafka + const TCP + const UDP + func (e *Transport) FromString(s string) error + func (e *Transport) MarshalJSON() ([]byte, error) + func (e *Transport) UnmarshalJSON(data []byte) error + func (e *Transport) UnmarshalYAML(unmarshal func(interface{}) error) error + func (e Transport) String() string
Go to main page