statsd

Documentation

Index

• Variables
• func AddGPIDReceiveCounter(count uint64)
• func AddGPIDSendCounter(count uint64)
• func AddGrpcCostStatsd(apiType ApiType, cost int)
• func Start()
• type ApiType
• type Counter
  • func (c *Counter) AddCostTime(cost uint64)
• type GCounter
  • func (c *GCounter) AddReceiveCount(count uint64)
  • func (c *GCounter) AddSendCount(count uint64)
• type GPIDCounter
  • func NewGPIDCounter() *GPIDCounter
  • func (g *GPIDCounter) Closed() bool
  • func (g *GPIDCounter) GetCounter() interface{}
• type GetPrometheusLabelIDsCounter
  • func GetPrometheusLabelIDsCounterSingleton() *GetPrometheusLabelIDsCounter
  • func NewGetPrometheusLabelIDsCounter() *GetPrometheusLabelIDsCounter
  • func (g *GetPrometheusLabelIDsCounter) Closed() bool
  • func (g *GetPrometheusLabelIDsCounter) GetCounter() interface{}
• type GrpcCounter
  • func NewGrpcCounter() *GrpcCounter
  • func (g *GrpcCounter) Closed() bool
  • func (g *GrpcCounter) GetCounter() interface{}
• type PrometheusLabelIDsCounter
  • func NewPrometheusLabelIDsCounter() *PrometheusLabelIDsCounter
  • func (c *PrometheusLabelIDsCounter) Fill(pc *PrometheusLabelIDsCounter)
• type VTapCounter
  • func GetVTapCounter() *VTapCounter
  • func (c *VTapCounter) GetVtapNameCounter(orgID int) VTapNameCounter
  • func (c *VTapCounter) SetCounter(db *mysql.DB, teamID int, vtapName string, weight float64, isChanged uint64)
  • func (c *VTapCounter) SetNull(orgID int, vtapName string)
• type VTapNameCounter
• type VTapWeightCounter
  • func NewVTapWeightCounter() *VTapWeightCounter
  • func (v *VTapWeightCounter) SendStats(vtapName string)

Variables

var ApiTypeToName = map[ApiType]string{
	Sync:                   "Sync",
	AnalyzerSync:           "AnalyzerSync",
	Upgrade:                "Upgrade",
	Query:                  "Query",
	GetKubernetesClusterID: "GetKubernetesClusterID",
	GenesisSync:            "GenesisSync",
	KubernetesAPISync:      "KubernetesAPISync",
	PrometheusAPISync:      "PrometheusAPISync",
	GetPrometheusLabelIDs:  "GetPrometheusLabelIDs",
	GetPrometheusTargets:   "GetPrometheusTargets",
	GPIDSync:               "GPIDSync",
}

Functions

func AddGPIDReceiveCounter

func AddGPIDReceiveCounter(count uint64)

func AddGPIDSendCounter

func AddGPIDSendCounter(count uint64)

func AddGrpcCostStatsd

func AddGrpcCostStatsd(apiType ApiType, cost int)

func Start

func Start()

Types

type ApiType

type ApiType int

const (
	Sync ApiType = iota
	AnalyzerSync
	Upgrade
	Query
	GetKubernetesClusterID
	GenesisSync
	KubernetesAPISync
	PrometheusAPISync
	GPIDSync
	GetPrometheusLabelIDs
	GetPrometheusTargets
	MaxApiType
)

type Counter

type Counter struct {
	ReqCount uint64 `statsd:"req_count"`
	AvgDelay uint64 `statsd:"avg_delay"`
	MaxDelay uint64 `statsd:"max_delay"`
	SumDelay uint64
}

func (*Counter) AddCostTime

func (c *Counter) AddCostTime(cost uint64)

type GCounter

type GCounter struct {
	Receive uint64 `statsd:"receive_count"`
	Send    uint64 `statsd:"send_count"`
}

func (*GCounter) AddReceiveCount

func (c *GCounter) AddReceiveCount(count uint64)

func (*GCounter) AddSendCount

func (c *GCounter) AddSendCount(count uint64)

type GPIDCounter

type GPIDCounter struct {
	*GCounter
}

func NewGPIDCounter

func NewGPIDCounter() *GPIDCounter

func (*GPIDCounter) Closed

func (g *GPIDCounter) Closed() bool

func (*GPIDCounter) GetCounter

func (g *GPIDCounter) GetCounter() interface{}

type GetPrometheusLabelIDsCounter

type GetPrometheusLabelIDsCounter struct {
	*PrometheusLabelIDsCounter
}

func GetPrometheusLabelIDsCounterSingleton

func GetPrometheusLabelIDsCounterSingleton() *GetPrometheusLabelIDsCounter

func NewGetPrometheusLabelIDsCounter

func NewGetPrometheusLabelIDsCounter() *GetPrometheusLabelIDsCounter

func (*GetPrometheusLabelIDsCounter) Closed

func (g *GetPrometheusLabelIDsCounter) Closed() bool

func (*GetPrometheusLabelIDsCounter) GetCounter

func (g *GetPrometheusLabelIDsCounter) GetCounter() interface{}

type GrpcCounter

type GrpcCounter struct {
	*Counter
}

func NewGrpcCounter

func NewGrpcCounter() *GrpcCounter

func (*GrpcCounter) Closed

func (g *GrpcCounter) Closed() bool

func (*GrpcCounter) GetCounter

func (g *GrpcCounter) GetCounter() interface{}

type PrometheusLabelIDsCounter

type PrometheusLabelIDsCounter struct {
	ReceiveMetricCount uint64 `statsd:"receive_metric_count"`
	ReceiveLabelCount  uint64 `statsd:"receive_label_count"`
	ReceiveTargetCount uint64 `statsd:"receive_target_count"`
	SendMetricCount    uint64 `statsd:"send_metric_count"`
	SendLabelCount     uint64 `statsd:"send_label_count"`
	SendTargetCount    uint64 `statsd:"send_target_count"`
}

func NewPrometheusLabelIDsCounter

func NewPrometheusLabelIDsCounter() *PrometheusLabelIDsCounter

func (*PrometheusLabelIDsCounter) Fill

func (c *PrometheusLabelIDsCounter) Fill(pc *PrometheusLabelIDsCounter)

type VTapCounter

type VTapCounter struct {
	ORGIDToVTapNameCounter map[int]VTapNameCounter
	// contains filtered or unexported fields
}

func GetVTapCounter

func GetVTapCounter() *VTapCounter

func (*VTapCounter) GetVtapNameCounter

func (c *VTapCounter) GetVtapNameCounter(orgID int) VTapNameCounter

func (*VTapCounter) SetCounter

func (c *VTapCounter) SetCounter(db *mysql.DB, teamID int, vtapName string, weight float64, isChanged uint64)

func (*VTapCounter) SetNull

func (c *VTapCounter) SetNull(orgID int, vtapName string)

type VTapNameCounter

type VTapNameCounter map[string]*VTapWeightCounter

type VTapWeightCounter

type VTapWeightCounter struct {
	ORGID             uint16
	TeamID            uint16
	Name              string
	Weight            float64
	IsAnalyzerChanged uint64
}

func NewVTapWeightCounter

func NewVTapWeightCounter() *VTapWeightCounter

func (*VTapWeightCounter) SendStats

func (v *VTapWeightCounter) SendStats(vtapName string)