config

type Batcher struct {
	Timeout time.Duration `koanf:"timeout"`
}

type Buffer struct {
	StartTime time.Time
	Interval  time.Duration     `koanf:"interval"`
	Offset    time.Duration     `koanf:"offset"`
	Validator *validator.Config `koanf:"validator"`
}

type Config struct {
	Batcher     *Batcher       `koanf:"batcher"`
	Pool        *Pool          `koanf:"pool"`
	Destination *Destination   `koanf:"destination"`
	MQTT        *MQTT          `koanf:"mqtt"`
	Log         *logger.Config `koanf:"log"`
}

type Destination struct {
	Type     string           `koanf:"type"`
	Buffer   *Buffer          `koanf:"buffer"`
	Database *bqclient.Config `koanf:"database"`
}

type MQTT struct {
	Host     string `koanf:"host"`
	Port     int    `koanf:"port"`
	Username string `koanf:"username"`
	Password string `koanf:"password"`
	QoS      int    `koanf:"qos"`
	Topic    string `koanf:"topic"`
}

type Pool struct {
	NumWorkers int `koanf:"num_workers"`
	Capacity   int `koanf:"capacity"`
}