stat

Dec 14, 2021

Changes in this version

+ const ResultBlock

+ const ResultPass

Jul 28, 2021

Changes in this version

type BaseStatNode

+ func (n *BaseStatNode) MaxConcurrency() int32

+ func (n *BaseStatNode) UpdateConcurrency(concurrency int32)

Nov 26, 2020

Changes in this version

+ const PrepareSlotName

+ const PrepareSlotOrder

+ const StatSlotName

+ const StatSlotOrder

+ var DefaultResourceNodePrepareSlot = &ResourceNodePrepareSlot

+ var DefaultSlot = &Slot

type BaseStatNode

+ func (n *BaseStatNode) AddCount(event base.MetricEvent, count int64)

+ func (n *BaseStatNode) CurrentConcurrency() int32

+ func (n *BaseStatNode) DecreaseConcurrency()

+ func (n *BaseStatNode) DefaultMetric() base.ReadStat

+ func (n *BaseStatNode) GenerateReadStat(sampleCount uint32, intervalInMs uint32) (base.ReadStat, error)

+ func (n *BaseStatNode) IncreaseConcurrency()

type ResourceNodePrepareSlot

+ func (s *ResourceNodePrepareSlot) Name() string

+ func (s *ResourceNodePrepareSlot) Order() uint32

type Slot

+ func (s *Slot) Name() string

+ func (s *Slot) Order() uint32

Sep 9, 2020

Changes in this version

+ type ResourceNodePrepareSlot struct

+ func (s *ResourceNodePrepareSlot) Prepare(ctx *base.EntryContext)

+ type Slot struct

+ func (s *Slot) OnCompleted(ctx *base.EntryContext)

+ func (s *Slot) OnEntryBlocked(ctx *base.EntryContext, blockError *base.BlockError)

+ func (s *Slot) OnEntryPassed(ctx *base.EntryContext)

Sep 2, 2020

Changes in this version

type BaseStatNode

+ func (n *BaseStatNode) GetPreviousQPS(event base.MetricEvent) float64

Mar 19, 2020

Changes in this version

+ const SlotName

+ func ResetResourceNodeMap()

+ type BaseStatNode struct

+ func NewBaseStatNode(sampleCount uint32, intervalInMs uint32) *BaseStatNode

+ func (n *BaseStatNode) AddMetric(event base.MetricEvent, count uint64)

+ func (n *BaseStatNode) AvgRT() float64

+ func (n *BaseStatNode) CurrentGoroutineNum() int32

+ func (n *BaseStatNode) DecreaseGoroutineNum()

+ func (n *BaseStatNode) GetMaxAvg(event base.MetricEvent) float64

+ func (n *BaseStatNode) GetQPS(event base.MetricEvent) float64

+ func (n *BaseStatNode) GetSum(event base.MetricEvent) int64

+ func (n *BaseStatNode) IncreaseGoroutineNum()

+ func (n *BaseStatNode) MetricsOnCondition(predicate base.TimePredicate) []*base.MetricItem

+ func (n *BaseStatNode) MinRT() float64

+ func (n *BaseStatNode) Reset()

+ type ResourceNode struct

+ func GetOrCreateResourceNode(resource string, resourceType base.ResourceType) *ResourceNode

+ func GetResourceNode(resource string) *ResourceNode

+ func InboundNode() *ResourceNode

+ func NewResourceNode(resourceName string, resourceType base.ResourceType) *ResourceNode

+ func ResourceNodeList() []*ResourceNode

+ func (n *ResourceNode) GetOrCreateSlidingWindowMetric(sampleCount, intervalInMs uint32) *sbase.SlidingWindowMetric

+ func (n *ResourceNode) GetSlidingWindowMetric(key string) *sbase.SlidingWindowMetric

+ func (n *ResourceNode) ResourceName() string

+ func (n *ResourceNode) ResourceType() base.ResourceType

+ type ResourceNodeMap map[string]*ResourceNode

+ type StatNodePrepareSlot struct

+ func (s *StatNodePrepareSlot) Prepare(ctx *base.EntryContext)

+ type StatisticSlot struct

+ func (s *StatisticSlot) OnCompleted(ctx *base.EntryContext)

+ func (s *StatisticSlot) OnEntryBlocked(ctx *base.EntryContext, blockError *base.BlockError)

+ func (s *StatisticSlot) OnEntryPassed(ctx *base.EntryContext)

+ func (s *StatisticSlot) String() string