statsd

Documentation

Index

• Variables
• func RegisterCountableForIngester(module string, countable stats.Countable, opts ...stats.Option) error
• type ApiCounter
  • func NewApiCounter() *ApiCounter
  • func (c *ApiCounter) Close()
  • func (c *ApiCounter) Closed() bool
  • func (c *ApiCounter) GetCounter() interface{}
  • func (c *ApiCounter) Write(ac *ApiStats)
• type ApiStats
• type ClickhouseCounter
• type Counter
  • func NewCounter() *Counter
  • func (c *Counter) Close()
  • func (c *Counter) Closed() bool
  • func (c *Counter) GetCounter() interface{}
  • func (c *Counter) WriteApi(qc *ClickhouseCounter)
  • func (c *Counter) WriteCk(qc *ClickhouseCounter)

Variables

var ApiCounters map[string]*ApiCounter

Functions

func RegisterCountableForIngester

func RegisterCountableForIngester(module string, countable stats.Countable, opts ...stats.Option) error

Types

type ApiCounter

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

func NewApiCounter

func NewApiCounter() *ApiCounter

func (*ApiCounter) Close

func (c *ApiCounter) Close()

func (*ApiCounter) Closed

func (c *ApiCounter) Closed() bool

func (*ApiCounter) GetCounter

func (c *ApiCounter) GetCounter() interface{}

func (*ApiCounter) Write

func (c *ApiCounter) Write(ac *ApiStats)

type ApiStats

type ApiStats struct {
	ApiTime    uint64
	ApiTimeSum uint64
	ApiTimeAvg uint64 `statsd:"api_time_avg"`
	ApiTimeMax uint64 `statsd:"api_time_max"`
	ApiCount   uint64 `statsd:"api_count"`
}

type ClickhouseCounter

type ClickhouseCounter struct {
	QueryCount   uint64 `statsd:"query_count"`
	ResponseSize uint64 `statsd:"response_size"`
	RowCount     uint64 `statsd:"row_count"`
	ColumnCount  uint64 `statsd:"column_count"`
	QueryTime    uint64
	QueryTimeSum uint64
	QueryTimeAvg uint64 `statsd:"query_time_avg"`
	QueryTimeMax uint64 `statsd:"query_time_max"`
	ApiTime      uint64
	ApiTimeSum   uint64
	ApiTimeAvg   uint64 `statsd:"api_time_avg"`
	ApiTimeMax   uint64 `statsd:"api_time_max"`
	ApiCount     uint64 `statsd:"api_count"`
}

type Counter

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

var QuerierCounter *Counter

func NewCounter

func NewCounter() *Counter

func (*Counter) Close

func (c *Counter) Close()

func (*Counter) Closed

func (c *Counter) Closed() bool

func (*Counter) GetCounter

func (c *Counter) GetCounter() interface{}

func (*Counter) WriteApi

func (c *Counter) WriteApi(qc *ClickhouseCounter)

func (*Counter) WriteCk

func (c *Counter) WriteCk(qc *ClickhouseCounter)