collector

Documentation

Index

• Constants
• Variables
• type Collector
  • func NewCollector(metricPath string, errLogPath string, historyFile string, ...) *Collector
  • func (c *Collector) Close()
  • func (c *Collector) ListenFiles() error
• type HTTPClient
• type JobType
• type NodeCollector
  • func NewNodeCollector(logger *logger.Logger, conf *config.MonitorMain) *NodeCollector
  • func (nc *NodeCollector) Close()
  • func (nc *NodeCollector) Start()
• type QueryMetric
  • func NewQueryMetric(logger *logger.Logger, conf *config.MonitorQuery) *QueryMetric
  • func (q *QueryMetric) Close()
  • func (q *QueryMetric) Start()
• type ReportJob
  • func NewReportJob(logger *logger.Logger, c *config.TSMonitor, gzipped bool, errLogHistory string) *ReportJob
  • func (rb *ReportJob) Close()
  • func (rb *ReportJob) CreateDatabase() error
  • func (rb *ReportJob) ReportMetric(filename string) error
  • func (rb *ReportJob) StartErrLogJob(filename, errLogPath string, jobType JobType) error
  • func (rb *ReportJob) WriteData(buf string) error
• type ReportStat
  • func NewReportStat() *ReportStat
  • func (s *ReportStat) Delete(key string)
  • func (s *ReportStat) TryAgain(key string) bool

Constants

const (
	DuIndex = "du -al --max-depth=1 %s/data/*/*/*/index | grep index$"
)

const (
	ErrLogFormat = "error.log"
)

const (
	ErrLogMst = "err_log"
)

const (
	HttpTimeout = 10 * time.Second
)

Variables

var (
	ReportQueryFrequency = time.Minute

	ClusterMetric = "cluster_metric"
	MstMetric     = "measurement_metric"

	ShowDatabases         = "SHOW DATABASES"
	ShowMeasurements      = "SHOW MEASUREMENTS"
	ShowSeriesCardinality = "SHOW SERIES CARDINALITY FROM \"%s\""
)

var (
	MinBatchSize       = 100
	ReportFrequency    = 5 * time.Second
	ReportLogFrequency = 10 * time.Second
	WaitRotationEnd    = 10 * time.Second
	MaxRetryTimes      = 20
)

Easy to test modify

Types

type Collector

type Collector struct {
	Reporter *ReportJob
	// contains filtered or unexported fields
}

func NewCollector

func NewCollector(metricPath string, errLogPath string, historyFile string, logger *logger.Logger) *Collector

func (*Collector) Close

func (c *Collector) Close()

func (*Collector) ListenFiles

func (c *Collector) ListenFiles() error

type HTTPClient

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

HTTPClient interface

type JobType

type JobType int

const (
	ErrLogHistoryType JobType = iota
	ErrLogCurrentType
)

type NodeCollector

type NodeCollector struct {
	Reporter *ReportJob
	// contains filtered or unexported fields
}

func NewNodeCollector

func NewNodeCollector(logger *logger.Logger, conf *config.MonitorMain) *NodeCollector

func (*NodeCollector) Close

func (nc *NodeCollector) Close()

func (*NodeCollector) Start

func (nc *NodeCollector) Start()

type QueryMetric

type QueryMetric struct {
	Client   HTTPClient
	Reporter *ReportJob
	// contains filtered or unexported fields
}

func NewQueryMetric

func NewQueryMetric(logger *logger.Logger, conf *config.MonitorQuery) *QueryMetric

func (*QueryMetric) Close

func (q *QueryMetric) Close()

func (*QueryMetric) Start

func (q *QueryMetric) Start()

type ReportJob

type ReportJob struct {
	Client HTTPClient

	Hook func()
	// contains filtered or unexported fields
}

func NewReportJob

func NewReportJob(logger *logger.Logger, c *config.TSMonitor, gzipped bool, errLogHistory string) *ReportJob

func (*ReportJob) Close

func (rb *ReportJob) Close()

func (*ReportJob) CreateDatabase

func (rb *ReportJob) CreateDatabase() error

func (*ReportJob) ReportMetric

func (rb *ReportJob) ReportMetric(filename string) error

func (*ReportJob) StartErrLogJob

func (rb *ReportJob) StartErrLogJob(filename, errLogPath string, jobType JobType) error

func (*ReportJob) WriteData

func (rb *ReportJob) WriteData(buf string) error

type ReportStat

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

func NewReportStat

func NewReportStat() *ReportStat

func (*ReportStat) Delete

func (s *ReportStat) Delete(key string)

func (*ReportStat) TryAgain

func (s *ReportStat) TryAgain(key string) bool