global

package
v5.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 14, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	RequestTimeout           = "REQUESTTIMEOUT"
	Brokers                  = "BROKERS"
	TLSEnabled               = "TLS_ENABLED"
	TLSCa                    = "TLS_CA"
	TLSCert                  = "TLS_CERT"
	TLSCertKey               = "TLS_CERTKEY"
	TLSInsecure              = "TLS_INSECURE"
	SaslEnabled              = "SASL_ENABLED"
	SaslUsername             = "SASL_USERNAME"
	SaslPassword             = "SASL_PASSWORD"
	SaslMechanism            = "SASL_MECHANISM"
	SaslTokenProviderPlugin  = "SASL_TOKENPROVIDER_PLUGIN"
	SaslTokenProviderOptions = "SASL_TOKENPROVIDER_OPTIONS"
	ClientID                 = "CLIENTID"
	KafkaVersion             = "KAFKAVERSION"
	AvroSchemaRegistry       = "AVRO_SCHEMAREGISTRY"
	AvroJSONCodec            = "AVRO_JSONCODEC"
	ProtobufProtoSetFiles    = "PROTOBUF_PROTOSETFILES"
	ProtobufImportPaths      = "PROTOBUF_IMPORTPATHS"
	ProtobufProtoFiles       = "PROTOBUF_PROTOFILES"
	ProducerPartitioner      = "PRODUCER_PARTITIONER"
	ProducerRequiredAcks     = "PRODUCER_REQUIREDACKS"
	ProducerMaxMessageBytes  = "PRODUCER_MAXMESSAGEBYTES"
)
View Source 
const GoContextKey = "global-config"

Variables

View Source 
var EnvVariables = []string{
	RequestTimeout,
	Brokers,
	TLSEnabled,
	TLSCa,
	TLSCert,
	TLSCertKey,
	TLSInsecure,
	SaslEnabled,
	SaslUsername,
	SaslPassword,
	SaslMechanism,
	SaslTokenProviderPlugin,
	SaslTokenProviderOptions,
	ClientID,
	KafkaVersion,
	AvroSchemaRegistry,
	AvroJSONCodec,
	ProtobufProtoSetFiles,
	ProtobufImportPaths,
	ProtobufProtoFiles,
	ProducerPartitioner,
	ProducerRequiredAcks,
	ProducerMaxMessageBytes,
}

Functions

func GetCurrentContext 

func GetCurrentContext() string

func SetCurrentContext 

func SetCurrentContext(contextName string) error

Types

type Config 

type Config interface {
	Flags() *Flags
	DefaultPaths() []string
	Init()
	// contains filtered or unexported methods
}

func NewConfig 

func NewConfig() Config

type Flags 

type Flags struct {
	ConfigFile string
	Verbose    bool
}

func GetFlags 

func GetFlags() Flags

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.