envflags

package

v0.0.0-...-c18252c Latest Latest Go to latest Published: Apr 19, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var (
	// WithSasl enables everything deemed necessary to work with SASL
	WithSasl = &withSaslOption{}
)

This section is empty.

type KafkaFlags struct {
	Logger *logging.Logger
	// contains filtered or unexported fields
}

KafkaFlags contains a set of flags for configuring Kafka.

func ForKafka(configMap kafka.ConfigMap, opts ...KafkaOption) *KafkaFlags

ForKafka creates a helper object, which allows to create flags connected to Kafka configuration. Uses passed in Kafka configuration as a baseline.

func (kf *KafkaFlags) String(key, usage string)

String creates String flag

func (kf *KafkaFlags) StringWithDefault(key, def, usage string)

StringWithDefault create String flag with default value

func (kf *KafkaFlags) ToConfigMap() *kafka.ConfigMap

ToConfigMap uses values from created flags and builds a Kafka configuration.

type KafkaOption interface {
	Apply(*KafkaFlags)
}

KafkaOption represents applying a set of options to flags