Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

config

package

Go to main page

Versions in this module

v1

v1.1.10

Dec 19, 2019

Changes in this version

+ type PProf struct

+ Enabled bool

+ Port int

v1.1.9

Dec 4, 2019

v1.1.8

Dec 2, 2019

Changes in this version

type Consumer

+ WorkerDelayMs int

+ func (c Consumer) MessageLoopDelay() time.Duration

v1.1.7

Nov 22, 2019

Changes in this version

type Jaeger

+ AgentHost string

+ AgentPort int

+ func (j Jaeger) AgentHostPort() string

v1.1.6

Nov 13, 2019

Changes in this version

+ type ProtoParser struct

+ Enabled bool

+ FilePath string

+ MessageName string

+ TimestampIndex int

v1.1.5

Sep 25, 2019

v1.1.4

Sep 19, 2019

Changes in this version

+ type Jaeger struct

+ Disabled bool

+ ReporterLogSpans bool

+ SamplerParam float64

+ SamplerType string

+ ServiceName string

type LibrdConfigs

+ Enabled bool

v1.1.3

Sep 19, 2019

Changes in this version

type Producer

+ ClusterName string

v1.1.2

Sep 16, 2019

Changes in this version

type Statsd

+ Deployment string

+ PodName string

v1.1.1

Sep 13, 2019

Changes in this version

+ const ConsumerQueuedMinMessages

+ const LibrdStatisticsIntervalMs

+ const ProduceRequestRequiredAcks

+ const ProducerBatchNumMessages

+ const ProducerQueueBufferingMaxMessages

type Consumer

+ LibrdConfigs LibrdConfigs

+ type LibrdConfigs struct

+ BatchNumMessages int

+ QueueBufferingMaxMessage int

+ QueuedMinMessages int

+ RequestRequiredAcks int

+ StatisticsIntervalMs int

type Producer

+ Acks int

+ Librdconfigs LibrdConfigs

+ type Statsd struct

+ Enabled bool

+ Host string

+ Port int

+ Tags []string

v1.1.0

Sep 11, 2019

Changes in this version

type Prometheus

+ Deployment string

+ PodName string

v1.0.0

Sep 6, 2019

Changes in this version

+ const ConsumerGroupIDKey

+ const ConsumerOffsetResetKey

+ const EnableAutoCommit

+ const KafkaBootstrapServerKey

+ const SSLCALocation

+ const SSLCertLocation

+ const SSLCertificateLocation

+ const SSLKeyLocation

+ const SSLKeyPassword

+ const SecurityProtocol

+ func Load() error

+ type Application struct

+ func App() Application

+ func (a Application) DevEnvironment() bool

+ func (a Application) LogLevel() string

+ func (a Application) RunDuration() time.Duration

+ type Config struct

+ DurationMs int64

+ Environment string

+ type Consumer struct

+ Concurrency int

+ EnableAutoCommit bool

+ Enabled bool

+ GroupID string

+ KafkaBrokers string

+ OffsetReset string

+ PollTimeoutMs int64

+ SecurityProtocol string

+ Topic string

+ func (c Consumer) KafkaConfig() *kafka.ConfigMap

+ func (c Consumer) PollTimeout() time.Duration

+ type Producer struct

+ Concurrency int

+ DelayMs int

+ Enabled bool

+ FlushTimeoutMs int

+ KafkaBrokers string

+ SecurityProtocol string

+ Topic string

+ TotalMessages uint64

+ WorkerDelayMs int

+ func (p Producer) KafkaConfig() *kafka.ConfigMap

+ type Prometheus struct

+ Enabled bool

+ Port int

+ func (p Prometheus) BindPort() string

+ type Reporter struct

+ type SSL struct

+ CALocation string

+ CertificateLocation string

+ KeyLocation string

+ KeyPassword string

+ type Store struct

+ RedisHost string

+ RunID string

+ Type string