server

type Config struct {
	Server ServerConfig  `yaml:"server"`
	Kafka  KafkaConfig   `yaml:"kafka"`
	Data   DataConfig    `yaml:"data"`
	Log    TLoggerConfig `yaml:"log"`
}

type DataConfig struct {
	DataDir string `yaml:"data_dir"` // cache data directory
}

type Direction int8

type FieldsSetter func(ctx context.Context) []zap.Field

type FileCache struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type GrpcConfig struct {
	Addr string `yaml:"addr"` // grpc server listening address,eg: 0.0.0.0:8000
}

type HttpConfig struct {
	Addr string `yaml:"addr"` // http server listening address,eg: 0.0.0.0:8000
}

type KafkaConfig struct {
	Broker       []string `yaml:"broker"`        // broker addresses
	PartitionCnt int      `yaml:"partition_cnt"` // topic partition count
	AckPolicy    int      `yaml:"ack_policy"`    // acknowledgement policy for writing msg successfully
	WriteTimeout int      `yaml:"write_timeout"` // write timeout, million second unit
}

type LogConfig struct {
	LogDir   string `yaml:"log_dir"`
	LogLevel string `yaml:"log_level"`
}

type ServerConfig struct {
	Http                 HttpConfig `yaml:"http"`
	Grpc                 GrpcConfig `yaml:"grpc"`
	ExtFields            []string   `yaml:"ext_fields"`      // ext fields to patch into kafka data
	TopicFile            string     `yaml:"topic_whitelist"` // topic whitelist file
	EnableTopicWhitelist bool
	TopicWhitelist       *goset.Set
}

type TLogger struct {
	*zap.Logger
	// contains filtered or unexported fields
}

type TLoggerConfig struct {
	// Dir is the directory where log files are stored
	Dir string `yaml:"dir"`
	// FileName is the log file name
	FileName string `yaml:"file_name"`
	// Level is the min log level recorded in log file
	Level string `yaml:"level"`
	// MaxSize is the maximum size in megabytes of the log file before it gets rotated.
	MaxSize int `yaml:"max_size"`
	// MaxAge is the maximum number of days to retain old log files based on the
	// timestamp encoded in their filename.  Note that a day is defined as 24
	// hours and may not exactly correspond to calendar days due to daylight
	// savings, leap seconds, etc. The default is not to remove old log files
	// based on age.
	MaxDays int `yaml:"max_days"`
	// MaxBackups is the maximum number of old log files to retain.  The default
	// is to retain all old log files (though MaxAge may still cause them to get
	// deleted.)
	MaxBackups int `yaml:"max_backups"`
	// Compress determines if the rotated log files should be compressed
	// using gzip. The default is not to perform compression.
	Compress bool `yaml:"compress"`
}