config

Documentation

Index

• type ClickHouseConfig
• type KafkaConfig
• type KafkaSaslConfig
• type SampledConfig
  • func LoadConfig(filePath string) (*SampledConfig, error)
• type StoreConfig
• type TuningConfig

Types

type ClickHouseConfig

type ClickHouseConfig struct {
	Hosts    []string `yaml:"hosts"`
	Username string   `yaml:"username"`
	Password string   `yaml:"password"`
	Database string   `yaml:"database"`
}

type KafkaConfig

type KafkaConfig struct {
	GroupId          string           `yaml:"groupId"`
	ResetPosition    string           `yaml:"resetPosition"`
	SecurityProtocol string           `yaml:"securityProtocol"`
	BootstrapServers []string         `yaml:"bootstrapServers"`
	Topics           []string         `yaml:"topics"`
	Sasl             *KafkaSaslConfig `yaml:"sasl,omitempty"`
}

type KafkaSaslConfig

type KafkaSaslConfig struct {
	Username  string `yaml:"username"`
	Password  string `yaml:"password"`
	Mechanism string `yaml:"mechanism"`
}

type SampledConfig

type SampledConfig struct {
	Store  StoreConfig  `yaml:"store"`
	Kafka  KafkaConfig  `yaml:"kafka"`
	Tuning TuningConfig `yaml:"tuning"`
}

func LoadConfig

func LoadConfig(filePath string) (*SampledConfig, error)

type StoreConfig

type StoreConfig struct {
	ClickHouse ClickHouseConfig `yaml:"clickhouse"`
}

type TuningConfig

type TuningConfig struct {
	FlushInterval    time.Duration `yaml:"flushInterval"`
	SampleBufferSize int64         `yaml:"sampleBufferSize"`
}