config

Documentation

Index

• Constants
• func GetLoggerLevel(condition bool, trueValFunc func() string, defaultVal string) string
• type KafkaServerConfGenerator
  • func (k *KafkaServerConfGenerator) DataDir() string
  • func (k *KafkaServerConfGenerator) FileName() string
  • func (k *KafkaServerConfGenerator) Generate() (string, error)
• type Log4jConfGenerator
  • func (g *Log4jConfGenerator) Config() *Log4jConfig
  • func (g *Log4jConfGenerator) FileName() string
  • func (g *Log4jConfGenerator) Generate() (string, error)
• type Log4jConfig
• type SecurityConfGenerator
  • func (g *SecurityConfGenerator) FileName() string
  • func (g *SecurityConfGenerator) Generate() (string, error)

Constants

const ConsoleConversionPattern = "[%d] %p %m (%c)%n"

const VECTOR_AGGREGATOR_CM_ENTRY: &str = "ADDRESS"; const CONSOLE_CONVERSION_PATTERN: &str = "[%d] %p %m (%c)%n";

const DefalutLoggerLevel = "INFO"

const KafkaLogFile = "kafka.log4j.xml"

const MaxKafkaLogFilesSizeInMiB int32 = 10 // 10 MiB

Functions

func GetLoggerLevel

func GetLoggerLevel(condition bool, trueValFunc func() string, defaultVal string) string

Types

type KafkaServerConfGenerator

type KafkaServerConfGenerator struct {
	KafkaTlsSecurity *security.KafkaTlsSecurity
}

KafkaServerConfGenerator kafka config generator

func (*KafkaServerConfGenerator) DataDir

func (k *KafkaServerConfGenerator) DataDir() string

DataDir data dir

func (*KafkaServerConfGenerator) FileName

func (k *KafkaServerConfGenerator) FileName() string

func (*KafkaServerConfGenerator) Generate

func (k *KafkaServerConfGenerator) Generate() (string, error)

type Log4jConfGenerator

type Log4jConfGenerator struct {
	LoggingSpec *kafkav1alpha1.LoggingConfigSpec
	Container   string
}

Log4jConfGenerator kafka log4j conf generator

func (*Log4jConfGenerator) Config

func (g *Log4jConfGenerator) Config() *Log4jConfig

create log4j config

func (*Log4jConfGenerator) FileName

func (g *Log4jConfGenerator) FileName() string

func (*Log4jConfGenerator) Generate

func (g *Log4jConfGenerator) Generate() (string, error)

type Log4jConfig

type Log4jConfig struct {
	RootLogLevel             string
	ConsoleLogLevel          string
	ConsoleConversionPattern string
	FileLogLevel             string
	LogDir                   string
	LogFile                  string
	MaxLogFileSizeInMiB      int
	NumberOfArchivedLogFiles int
	Loggers                  string
}

type SecurityConfGenerator

type SecurityConfGenerator struct {
}

SecurityConfGenerator kafka security conf generator

func (*SecurityConfGenerator) FileName

func (g *SecurityConfGenerator) FileName() string

func (*SecurityConfGenerator) Generate

func (g *SecurityConfGenerator) Generate() (string, error)