influxdb

type Config struct {
	DBConfig        db.Config     `yaml:"DB" mapstructure:"DB"`
	ClientConfig    client.Config `yaml:"Client" mapstructure:"Client"`
	MonitorInterval util.Duration `yaml:"MonitorInterval" mapstructure:"MonitorInterval"`
}

type Service struct {
	Config Config
	DB     *db.DB

	ClientMap sync.Map
	MetricMap sync.Map

	Logger *zap.Logger

	Closing chan struct{}
	Closed  chan struct{}
	// contains filtered or unexported fields
}

type Statistics struct {
	LineParseError        uint64
	LineDistributeSuccess uint64
	LineDistributeFail    uint64
}