Documentation
¶
Index ¶
- Variables
- func AddGPIDReceiveCounter(count uint64)
- func AddGPIDSendCounter(count uint64)
- func AddGrpcCostStatsd(apiType ApiType, cost int)
- func Start()
- type ApiType
- type Counter
- type GCounter
- type GPIDCounter
- type GetPrometheusLabelIDsCounter
- type GrpcCounter
- type PrometheusLabelIDsCounter
- type VTapCounter
- type VTapNameCounter
- type VTapWeightCounter
Constants ¶
This section is empty.
Variables ¶
View Source
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 ¶
Types ¶
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 ¶
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 (*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)
Click to show internal directories.
Click to hide internal directories.