config

Documentation

Index

• Variables
• func SplitHostPort(hostport string) (string, int32, error)
• type Config
  • func NewConfig() *Config
  • func (c *Config) InitBootstrapServers(bootstrapServersMapping []string) (err error)
  • func (c *Config) InitExternalServers(externalServersMapping []string) (err error)
  • func (c *Config) InitSASLCredentials() (err error)
  • func (c *Config) Validate() error
• type JaasCredentials
  • func NewJaasCredentialFromFile(filename string) (*JaasCredentials, error)
  • func NewJaasCredentials(s string) (*JaasCredentials, error)
• type ListenerConfig
• type NetAddressMappingFunc

Variables

var (
	// Version is the current version of the app, generated at build time
	Version = "unknown"
)

Functions

func SplitHostPort

func SplitHostPort(hostport string) (string, int32, error)

Types

type Config

type Config struct {
	Http struct {
		ListenAddress string
		MetricsPath   string
		HealthPath    string
		Disable       bool
	}
	Debug struct {
		ListenAddress string
		DebugPath     string
		Enabled       bool
	}
	Log struct {
		Format string
		Level  string
	}
	Proxy struct {
		DefaultListenerIP       string
		BootstrapServers        []ListenerConfig
		ExternalServers         []ListenerConfig
		DisableDynamicListeners bool
		RequestBufferSize       int
		ResponseBufferSize      int
		ListenerReadBufferSize  int // SO_RCVBUF
		ListenerWriteBufferSize int // SO_SNDBUF
		ListenerKeepAlive       time.Duration

		TLS struct {
			Enable              bool
			ListenerCertFile    string
			ListenerKeyFile     string
			ListenerKeyPassword string
			CAChainCertFile     string
		}
		Auth struct {
			Enable     bool
			Command    string
			Parameters []string
			LogLevel   string
		}
	}
	Kafka struct {
		ClientID string

		MaxOpenRequests int

		ForbiddenApiKeys []int

		DialTimeout               time.Duration // How long to wait for the initial connection.
		WriteTimeout              time.Duration // How long to wait for a request.
		ReadTimeout               time.Duration // How long to wait for a response.
		KeepAlive                 time.Duration
		ConnectionReadBufferSize  int // SO_RCVBUF
		ConnectionWriteBufferSize int // SO_SNDBUF

		TLS struct {
			Enable             bool
			InsecureSkipVerify bool
			ClientCertFile     string
			ClientKeyFile      string
			ClientKeyPassword  string
			CAChainCertFile    string
		}

		SASL struct {
			Enable         bool
			Username       string
			Password       string
			JaasConfigFile string
		}
	}
}

func NewConfig

func NewConfig() *Config

func (*Config) InitBootstrapServers

func (c *Config) InitBootstrapServers(bootstrapServersMapping []string) (err error)

func (*Config) InitExternalServers

func (c *Config) InitExternalServers(externalServersMapping []string) (err error)

func (*Config) InitSASLCredentials

func (c *Config) InitSASLCredentials() (err error)

func (*Config) Validate

func (c *Config) Validate() error

type JaasCredentials

type JaasCredentials struct {
	Username string
	Password string
}

func NewJaasCredentialFromFile

func NewJaasCredentialFromFile(filename string) (*JaasCredentials, error)

func NewJaasCredentials

func NewJaasCredentials(s string) (*JaasCredentials, error)

type ListenerConfig

type ListenerConfig struct {
	BrokerAddress   string
	ListenerAddress string
}

type NetAddressMappingFunc

type NetAddressMappingFunc func(brokerHost string, brokerPort int32) (listenerHost string, listenerPort int32, err error)