config

Jul 9, 2021

Changes in this version

type App

+ Logging []LoggerCfg

+ type LoggerCfg struct

+ Name string

+ Params map[string]string

+ Severity string

+ func (lc *LoggerCfg) Level() log.Level

Jul 22, 2019

Changes in this version

type App

+ func (a *App) GRPCSecurityOpts() ([]grpc.ServerOption, error)

+ type TLS struct

+ CertPath string

+ KeyPath string

Nov 23, 2018

Changes in this version

+ type PartitionerConstructor string

+ func (pc PartitionerConstructor) ToPartitionerConstructor() (sarama.PartitionerConstructor, error)

type Proxy

+ Net struct{ ... }

Sep 11, 2017

Changes in this version

+ type Compression sarama.CompressionCodec

+ func (c *Compression) UnmarshalText(text []byte) error

+ type KafkaVersion struct

+ func (kv *KafkaVersion) IsAtLeast(v sarama.KafkaVersion) bool

+ func (kv *KafkaVersion) Set(v sarama.KafkaVersion)

+ func (kv *KafkaVersion) UnmarshalText(text []byte) error

type Proxy

+ func (p *Proxy) SaramaClientCfg() *sarama.Config

+ func (p *Proxy) SaramaProducerCfg() *sarama.Config

+ type RequiredAcks sarama.RequiredAcks

+ func (ra *RequiredAcks) UnmarshalText(text []byte) error

Mar 23, 2017

Changes in this version

type App

+ DefaultCluster string

type Proxy

+ func (p *Proxy) KazooCfg() *kazoo.Config

+ func (p *Proxy) SaramaProdCfg() *sarama.Config

Feb 22, 2017

Changes in this version

+ type App struct

+ DefaultProxy string

+ GRPCAddr string

+ Proxies map[string]*Proxy

+ TCPAddr string

+ UnixAddr string

+ func DefaultApp(alias string) *App

+ func FromYAML(data []byte) (*App, error)

+ func FromYAMLFile(filename string) (*App, error)

+ type Proxy struct

+ ClientID string

+ Consumer struct{ ... }

+ Kafka struct{ ... }

+ Producer struct{ ... }

+ ZooKeeper struct{ ... }

+ func DefaultProxy() *Proxy

Dec 1, 2015

Changes in this version

+ type T struct

+ ChannelBufferSize int

+ ClientID string

+ Consumer struct{ ... }

+ Kafka struct{ ... }

+ Producer struct{ ... }

+ TCPAddr string

+ UnixAddr string

+ ZooKeeper struct{ ... }

+ func Default() *T

+ func (c *T) KazooConfig() *kazoo.Config

+ func (c *T) SaramaConfig() *sarama.Config