stat

Documentation

Index

• Constants
• func ResetResourceNodeMap()
• type BaseStatNode
  • 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
  • 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
• type StatNodePrepareSlot
  • func (s *StatNodePrepareSlot) Prepare(ctx *base.EntryContext)
• type StatisticSlot
  • 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

Constants

const SlotName = "StatisticSlot"

Functions

func ResetResourceNodeMap

func ResetResourceNodeMap()

Types

type BaseStatNode

type BaseStatNode struct {
	// contains filtered or unexported fields
}

func NewBaseStatNode

func NewBaseStatNode(sampleCount uint32, intervalInMs uint32) *BaseStatNode

func (*BaseStatNode) AddMetric

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

func (*BaseStatNode) AvgRT

func (n *BaseStatNode) AvgRT() float64

func (*BaseStatNode) CurrentGoroutineNum

func (n *BaseStatNode) CurrentGoroutineNum() int32

func (*BaseStatNode) DecreaseGoroutineNum

func (n *BaseStatNode) DecreaseGoroutineNum()

func (*BaseStatNode) GetMaxAvg

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

func (*BaseStatNode) GetQPS

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

func (*BaseStatNode) GetSum

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

func (*BaseStatNode) IncreaseGoroutineNum

func (n *BaseStatNode) IncreaseGoroutineNum()

func (*BaseStatNode) MetricsOnCondition

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

func (*BaseStatNode) MinRT

func (n *BaseStatNode) MinRT() float64

func (*BaseStatNode) Reset

func (n *BaseStatNode) Reset()

type ResourceNode

type ResourceNode struct {
	BaseStatNode
	// contains filtered or unexported fields
}

func GetOrCreateResourceNode

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

func GetResourceNode

func GetResourceNode(resource string) *ResourceNode

func InboundNode

func InboundNode() *ResourceNode

InboundNode returns the global inbound statistic node.

func NewResourceNode

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

NewResourceNode creates a new resource node with given name and classification.

func ResourceNodeList

func ResourceNodeList() []*ResourceNode

ResourceNodeList returns the slice of all existing resource nodes.

func (*ResourceNode) GetOrCreateSlidingWindowMetric

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

func (*ResourceNode) GetSlidingWindowMetric

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

func (*ResourceNode) ResourceName

func (n *ResourceNode) ResourceName() string

func (*ResourceNode) ResourceType

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

type ResourceNodeMap

type ResourceNodeMap map[string]*ResourceNode

type StatNodePrepareSlot

type StatNodePrepareSlot struct {
}

func (*StatNodePrepareSlot) Prepare

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

type StatisticSlot

type StatisticSlot struct {
}

func (*StatisticSlot) OnCompleted

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

func (*StatisticSlot) OnEntryBlocked

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

func (*StatisticSlot) OnEntryPassed

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

func (*StatisticSlot) String

func (s *StatisticSlot) String() string