metric

type CurRecorder struct{ Recorder }

type FailRateRecorder struct{ Recorder }

type HitRateRecorder struct{ Recorder }

type Key struct {
	Keys    []string
	Checked bool
	// contains filtered or unexported fields
}

type Line struct {
	Ks *ks.Ks `json:"-"`

	K1  string `json:"k1,omitempty"`
	K2  string `json:"k2,omitempty"`
	K3  string `json:"k3,omitempty"`
	K4  string `json:"k4,omitempty"`
	K5  string `json:"k5,omitempty"`
	K6  string `json:"k6,omitempty"`
	K7  string `json:"k7,omitempty"`
	K8  string `json:"k8,omitempty"`
	K9  string `json:"k9,omitempty"`
	K10 string `json:"k10,omitempty"`
	K11 string `json:"k11,omitempty"`
	K12 string `json:"k12,omitempty"`
	K13 string `json:"k13,omitempty"`
	K14 string `json:"k14,omitempty"`
	K15 string `json:"k15,omitempty"`
	K16 string `json:"k16,omitempty"`
	K17 string `json:"k17,omitempty"`
	K18 string `json:"k18,omitempty"`
	K19 string `json:"k19,omitempty"`
	K20 string `json:"k20,omitempty"`

	Key      string  `json:"key"` // {{k1}}#{{k2}}#{{k3}}
	LogType  LogType `json:"logtype"`
	Time     string  `json:"time"` // yyyyMMddHHmmssSSS
	Hostname string  `json:"hostname"`

	Keys []string `json:"-"`
	Min  float64  `json:"min"` // 累计最小值
	Max  float64  `json:"max"` // 累计最大值

	V1 float64 `json:"v1"` // 小数
	V2 float64 `json:"v2"` // 只有比率类型的时候，才用到v2
	V3 float64 `json:"v3"` // RT 当 [300-400) ms 时 v3 = 1
	V4 float64 `json:"v4"` // RT 当 [400-500) ms 时 v4 = 1
	V5 float64 `json:"v5"` // RT 当 [500-600) ms 时 v5 = 1
	V6 float64 `json:"v6"` // RT 当 [600-700) ms 时 v6 = 1
	V7 float64 `json:"v7"` // RT 当 [700-800) ms 时 v7 = 1
	V8 float64 `json:"v8"` // RT 当 [800-900) ms 时 v8 = 1
	V9 float64 `json:"v9"` // RT 当 [900-∞) ms 时 v9 = 1
}

type LogType string

type Option struct {
	AppName         string        `env:"APP_NAME"`                            // 应用名称，默认使用当前进程的PID
	LogPath         string        `default:"/tmp/log/metrics" env:"LOG_PATH"` // 日志路径
	MetricsInterval time.Duration `default:"1s" env:"METRICS_INTERVAL"`       // 每隔多少时间记录一次日志
	HBInterval      time.Duration `default:"20s" env:"HB_INTERVAL"`           // 每隔多少时间记录一次心跳日志
	ChanCap         int           `default:"1000" env:"CHAN_CAP"`             // 指标通道容量，当指标大量发送容量堆满时，自动扔弃
	MaxBackups      int           `default:"7" env:"MAX_BACKUPS"`             // 最大保留天数
	AutoDrop        bool          `env:"AUTO_DROP"`                           // 在指标来不及处理时，是否自动扔弃
	Debug           bool          `env:"DEBUG"`                               // 开启测试模式
}

type OptionFn func(o *Option)

type QPSRecorder struct{ Recorder }

type RTRecorder struct {
	Start time.Time
	Recorder
}

type Recorder struct {
	Runner  *Runner
	LogType LogType
	Key
}

type Runner struct {
	MetricsLogfile io.Writer
	HBLogfile      io.Writer

	C chan *Line

	AppName string

	MetricsInterval time.Duration
	HBInterval      time.Duration
	// contains filtered or unexported fields
}

type SuccessRateRecorder struct{ Recorder }