stat

Documentation

Index

• 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) GetPreviousQPS(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) ResourceName() string
  • func (n *ResourceNode) ResourceType() base.ResourceType
• type ResourceNodeMap
• type ResourceNodePrepareSlot
  • func (s *ResourceNodePrepareSlot) Prepare(ctx *base.EntryContext)
• type Slot
  • func (s *Slot) OnCompleted(ctx *base.EntryContext)
  • func (s *Slot) OnEntryBlocked(ctx *base.EntryContext, blockError *base.BlockError)
  • func (s *Slot) OnEntryPassed(ctx *base.EntryContext)

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) GetPreviousQPS

func (n *BaseStatNode) GetPreviousQPS(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) ResourceName

func (n *ResourceNode) ResourceName() string

func (*ResourceNode) ResourceType

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

type ResourceNodeMap

type ResourceNodeMap map[string]*ResourceNode

type ResourceNodePrepareSlot

type ResourceNodePrepareSlot struct {
}

func (*ResourceNodePrepareSlot) Prepare

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

type Slot

type Slot struct {
}

func (*Slot) OnCompleted

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

func (*Slot) OnEntryBlocked

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

func (*Slot) OnEntryPassed

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