Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AsyncProducerConfig ¶
type AsyncProducerConfig struct { Partitioner *string `description:"One of random, hashing, roundrobin, manual."` Compression *string `description:"One of gzip, lz4, none."` CompressionLevel *int `description:"Compression specific level setting."` RequiredAcks *string `description:"One of none, local, all."` AckTimeout *time.Duration `description:"Max time to wait for RequiredAcks."` MaxMessageBytes *int `description:"Max size of a message in bytes."` ReturnSuccesses *bool `description:"Enable the success channel."` ReturnErrors *bool `description:"Enable the error channel."` }
AsyncProducerConfig contains settings for a sarama.AsyncProducer
type AsyncProducerFactory ¶
AsyncProducerFactory creates sarama.AsyncProducers.
func (*AsyncProducerFactory) Config ¶
func (f *AsyncProducerFactory) Config(context.Context) *AsyncProducerConfig
Config generates the default configuration.
func (*AsyncProducerFactory) Make ¶
func (f *AsyncProducerFactory) Make(ctx context.Context, conf *AsyncProducerConfig) (sarama.AsyncProducer, error)
Make produces a sarama.AsyncProducer.
type ConsumerGroupConfig ¶
type ConsumerGroupConfig struct { SessionTimeout *time.Duration HeartbeatInterval *time.Duration RebalanceStrategy *string RebalanceTimeout *time.Duration ReturnErrors *bool GroupName string }
ConsumerGroupConfig contains settings for a sarama.ConsumerGroup
type ConsumerGroupFactory ¶
ConsumerGroupFactory creates sarama.ConsumerGroup.
func (*ConsumerGroupFactory) Config ¶
func (f *ConsumerGroupFactory) Config(context.Context) *ConsumerGroupConfig
Config generates the default configuration.
func (*ConsumerGroupFactory) Make ¶
func (f *ConsumerGroupFactory) Make(ctx context.Context, conf *ConsumerGroupConfig) (sarama.ConsumerGroup, error)
Make produces a sarama.ConsumerGroup.
type NetConfig ¶
type NetConfig struct { MaxOpenRequests *int `description:"Number of requests before blocking happens."` DialTimeout *time.Duration `description:"How long to wait for the initial connection."` ReadTimeout *time.Duration `description:"How long to wait for a response."` WriteTimeout *time.Duration `description:"How long to wait for a transmit."` KeepAlive *time.Duration `description:"How long to allow for idle."` TLSEnabled *bool }
NetConfig contains settings for the underlying network connections.
type SharedConfig ¶
type SharedConfig struct {}
SharedConfig contains the settings used by all Sarama components.
type SyncProducerConfig ¶
type SyncProducerConfig struct { Partitioner *string `description:"One of random, hashing, roundrobin, manual."` Compression *string `description:"One of gzip, lz4, none."` CompressionLevel *int `description:"Compression specific level setting."` RequiredAcks *string `description:"One of none, local, all."` AckTimeout *time.Duration `description:"Max time to wait for RequiredAcks."` MaxMessageBytes *int `description:"Max size of a message in bytes."` }
SyncProducerConfig contains settings for a sarama.SyncProducer
type SyncProducerFactory ¶
SyncProducerFactory creates sarama.SyncProducers.
func (*SyncProducerFactory) Config ¶
func (f *SyncProducerFactory) Config(context.Context) *SyncProducerConfig
Config generates the default configuration.
func (*SyncProducerFactory) Make ¶
func (f *SyncProducerFactory) Make(ctx context.Context, conf *SyncProducerConfig) (sarama.SyncProducer, error)
Make produces a sarama.SyncProducer.