metric

Documentation

Index

• Constants
• func App(app string) zap.Field
• func Cid(cid string) zap.Field
• func FileId(fileId string) zap.Field
• func Identity(val string) zap.Field
• func Method(val string) zap.Field
• func ObjectId(val string) zap.Field
• func PeerId(val string) zap.Field
• func PeerVersion(val string) zap.Field
• func QueueDur(val time.Duration) zap.Field
• func Size(size int) zap.Field
• func SpaceId(val string) zap.Field
• func TotalDur(val time.Duration) zap.Field
• type Config
• type Metric
  • func New() Metric
• type StreamPoolMetric
• type SyncMetric
• type SyncMetricState
  • func (st *SyncMetricState) Append(other SyncMetricState)

Constants

const CName = "common.metric"

Functions

func App

func App(app string) zap.Field

func Cid

func Cid(cid string) zap.Field

func FileId

func FileId(fileId string) zap.Field

func Identity

func Identity(val string) zap.Field

func Method

func Method(val string) zap.Field

func ObjectId

func ObjectId(val string) zap.Field

func PeerId

func PeerId(val string) zap.Field

func PeerVersion

func PeerVersion(val string) zap.Field

func QueueDur

func QueueDur(val time.Duration) zap.Field

func Size

func Size(size int) zap.Field

func SpaceId

func SpaceId(val string) zap.Field

func TotalDur

func TotalDur(val time.Duration) zap.Field

Types

type Config

type Config struct {
	Addr string `yaml:"addr"`
}

type Metric

type Metric interface {
	Registry() *prometheus.Registry
	WrapDRPCHandler(h drpc.Handler) drpc.Handler
	RequestLog(ctx context.Context, rpc string, fields ...zap.Field)
	RegisterSyncMetric(spaceId string, syncMetric SyncMetric)
	UnregisterSyncMetric(spaceId string)
	RegisterStreamPoolSyncMetric(mtr StreamPoolMetric)
	UnregisterStreamPoolSyncMetric()
	app.ComponentRunnable
}

func New

func New() Metric

type StreamPoolMetric

type StreamPoolMetric interface {
	OutgoingMsg() (count uint32, size uint64)
}

type SyncMetric

type SyncMetric interface {
	SyncMetricState() SyncMetricState
}

type SyncMetricState

type SyncMetricState struct {
	IncomingMsgCount  uint32
	IncomingMsgSize   uint64
	OutgoingMsgCount  uint32
	OutgoingMsgSize   uint64
	IncomingReqCount  uint32
	IncomingReqSize   uint64
	OutgoingReqCount  uint32
	OutgoingReqSize   uint64
	ReceivedRespCount uint32
	ReceivedRespSize  uint64
	SentRespCount     uint32
	SentRespSize      uint64
	TotalSize         uint64
}

func (*SyncMetricState) Append

func (st *SyncMetricState) Append(other SyncMetricState)