Versions in this module Expand all Collapse all v1 v1.7.0 Sep 19, 2018 Changes in this version + const ConfigPrefix + const DefaultBroker + const DefaultEncoding + const DefaultGroupID + const DefaultParallelism + const DefaultTopic + const EncodingJSON + const EncodingProto + const SuffixBrokers + const SuffixEncoding + const SuffixGroupID + const SuffixParallelism + const SuffixTopic + func AddFlags(flagSet *flag.FlagSet) + type Options struct + Encoding string + Parallelism int + func (o *Options) InitFromViper(v *viper.Viper)
Go to main page