Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Mercury ¶
type Mercury struct { Namespace string `json:"namespace"` MetricName string `json:"metricName"` Endpoint string `json:"endpoint"` Timestamp int64 `json:"timestamp"` DoubleValue float64 `json:"doubleValue"` MercuryMeta }
func (Mercury) MarshalEasyJSON ¶
MarshalEasyJSON supports easyjson.Marshaler interface
func (Mercury) MarshalJSON ¶
MarshalJSON supports json.Marshaler interface
func (*Mercury) UnmarshalEasyJSON ¶
UnmarshalEasyJSON supports easyjson.Unmarshaler interface
func (*Mercury) UnmarshalJSON ¶
UnmarshalJSON supports json.Unmarshaler interface
type MercuryMeta ¶
type MercuryMeta struct { Duration int `json:"duration"` CounterType string `json:"counterType"` EndpointType string `json:"endpointType"` }
func (MercuryMeta) MarshalEasyJSON ¶
func (v MercuryMeta) MarshalEasyJSON(w *jwriter.Writer)
MarshalEasyJSON supports easyjson.Marshaler interface
func (MercuryMeta) MarshalJSON ¶
func (v MercuryMeta) MarshalJSON() ([]byte, error)
MarshalJSON supports json.Marshaler interface
func (*MercuryMeta) UnmarshalEasyJSON ¶
func (v *MercuryMeta) UnmarshalEasyJSON(l *jlexer.Lexer)
UnmarshalEasyJSON supports easyjson.Unmarshaler interface
func (*MercuryMeta) UnmarshalJSON ¶
func (v *MercuryMeta) UnmarshalJSON(data []byte) error
UnmarshalJSON supports json.Unmarshaler interface
type MetricsLastReport ¶
type MetricsLastReport struct { KsWriteRespTps float64 KsWriteReqLogTps float64 KsWriteReqMsgErrMaxSize float64 KsWriteReqMsgErrOther float64 KsWriteReqSrvErrNoLeader float64 KsReadLogTps float64 KsConnCount float64 KsConnOnlineConnection float64 //logstore LogstoreReadCount float64 LogstoreWriteCount float64 SegmentReadCount float64 SegmentCutTotalCount float64 SegmentCutCount float64 // raft, string is raft group name RaftLatencyPerEntryMap map[string]float64 // contains filtered or unexported fields }
type MetricsLogFile ¶
type MetricsLogFile struct {
// contains filtered or unexported fields
}
type MetricsServer ¶
type MetricsServer struct {
// contains filtered or unexported fields
}
func NewMetricsServer ¶
func NewMetricsServer(conf *MetricsServerConfig) *MetricsServer
func (*MetricsServer) Start ¶
func (ms *MetricsServer) Start()
func (*MetricsServer) Stop ¶
func (ms *MetricsServer) Stop()
type MetricsServerConfig ¶
Click to show internal directories.
Click to hide internal directories.