monitor

type BigKeyConfS struct {
	Enable           bool
	KeyMaxBytes      int
	ValueMaxBytes    int
	LruSize          int
	EnableCache      bool
	MaxCacheLifeTime int
	sync.RWMutex
}

type BigKeyDataS struct {
	// contains filtered or unexported fields
}

type BigKeyExporter struct {
	// contains filtered or unexported fields
}

type BigKeyExporterConf struct {
	RecordLimit int      `mapstructure:"record_limit"`
	Include     []string `mapstructure:"include_metrics"`
}

type BigKeyMonitorDataS struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type BigKeyPair struct {
	// contains filtered or unexported fields
}

type BigKeyStatistics struct {
	// contains filtered or unexported fields
}

type ExporterConf struct {
	Enable              bool                  `mapstructure:"enable"`
	Host                string                `mapstructure:"host"`
	Address             string                `mapstructure:"address"`
	HotKeyExporterConf  HotKeyExporterConf    `mapstructure:"hotkey_exporter"`
	BigKeyExporterConf  BigKeyExporterConf    `mapstructure:"bigkey_exporter"`
	SlowQueryConf       SlowQueryExporterConf `mapstructure:"slowquery_exporter"`
	RunTimeExporterConf RunTimeExporterConf   `mapstructure:"runtime_exporter"`
}

type Fields struct {
	NumCPU       int64 `json:"cpu.count"`
	NumGoroutine int64 `json:"cpu.goroutines"`

	Alloc      int64 `json:"mem.alloc"`
	TotalAlloc int64 `json:"mem.total"`
	Sys        int64 `json:"mem.sys"`
	Lookups    int64 `json:"mem.lookups"`
	Mallocs    int64 `json:"mem.malloc"`
	Frees      int64 `json:"mem.frees"`

	HeapAlloc    int64 `json:"mem.heap.alloc"`
	HeapSys      int64 `json:"mem.heap.sys"`
	HeapIdle     int64 `json:"mem.heap.idle"`
	HeapInuse    int64 `json:"mem.heap.inuse"`
	HeapReleased int64 `json:"mem.heap.released"`
	HeapObjects  int64 `json:"mem.heap.objects"`

	StackInuse  int64 `json:"mem.stack.inuse"`
	StackSys    int64 `json:"mem.stack.sys"`
	MSpanInuse  int64 `json:"mem.stack.mspan_inuse"`
	MSpanSys    int64 `json:"mem.stack.mspan_sys"`
	MCacheInuse int64 `json:"mem.stack.mcache_inuse"`
	MCacheSys   int64 `json:"mem.stack.mcache_sys"`

	OtherSys int64 `json:"mem.othersys"`

	GCSys         int64   `json:"mem.gc.sys"`
	NextGC        int64   `json:"mem.gc.next"`
	LastGC        int64   `json:"mem.gc.last"`
	PauseTotalNs  int64   `json:"mem.gc.pause_total"`
	PauseNs       int64   `json:"mem.gc.pause"`
	NumGC         int64   `json:"mem.gc.count"`
	GCCPUFraction float64 `json:"mem.gc.cpu_fraction"`
}

type FieldsFunc func(Fields)

type HotKeyConfS struct {
	Enable                  bool
	MonitorJobInterval      int
	MonitorJobLifeTime      int
	SecondHotThreshold      int
	SecondIncreaseThreshold int
	LruSize                 int

	EnableCache      bool
	MaxCacheLifeTime int
	sync.RWMutex
}

type HotKeyCountDataS map[string]uint64

type HotKeyDataS struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type HotKeyExporter struct {
	// contains filtered or unexported fields
}

type HotKeyExporterConf struct {
	RecordLimit int      `mapstructure:"record_limit"`
	Include     []string `mapstructure:"include_metrics"`
}

type HotKeyMonitorDataS struct {
	HotKeyData HotKeyCountDataS
	TimeRange  *TimePair

	sync.RWMutex
}

type HotKeyPair struct {
	// contains filtered or unexported fields
}

type HotKeyStatistics struct {
	// contains filtered or unexported fields
}

type KeyMonitor struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Monitor struct {
	Cache                *cache.Cache
	KeyMonitor           *KeyMonitor
	HotKeyConf           *HotKeyConfS
	HotKeyMonitorData    *HotKeyMonitorDataS
	BigKeyConf           *BigKeyConfS
	BigKeyMonitorData    *BigKeyMonitorDataS
	SlowQueryConf        *SlowQueryConfS
	SlowQueryMonitorData *SlowQueryMonitorDataS
	ConnectionGauge      prometheus.Gauge
	sync.RWMutex
}

type NetStatCallback func(stat *NetworkStat, err error)

type NetworkExporter struct {
	// contains filtered or unexported fields
}

type NetworkStat struct {
	RxBytes uint64
	TxBytes uint64
}

type RunTimeExporterConf struct {
	Enable    bool `mapstructure:"enable"`
	EnableCPU bool `mapstructure:"enable_cpu"`
	EnableMem bool `mapstructure:"enable_mem"`
	EnableGC  bool `mapstructure:"enable_gc"`
}

type RuntimeExporter struct {
	// contains filtered or unexported fields
}

type SlowQueryConfS struct {
	Enable                 bool
	SlowQueryTimeThreshold int
	MaxListSize            int
	sync.RWMutex
}

type SlowQueryDataS struct {
	Resp      []interface{}
	StartTime time.Time
	EndTime   time.Time
}

type SlowQueryExporter struct {
	// contains filtered or unexported fields
}

type SlowQueryExporterConf struct {
	RecordLimit int `mapstructure:"record_limit"`
}

type SlowQueryMonitorDataS struct {
	SlowQueryDataList []*SlowQueryDataS
	Index             int32
	sync.RWMutex
}

type SlowQueryPair struct {
	// contains filtered or unexported fields
}

type SlowQueryStatistics struct {
	// contains filtered or unexported fields
}

type TimePair struct {
	Start time.Time
	End   time.Time
}