counter

Documentation

Index

• Constants
• func SendGoCounter()
• func SendServiceCounter()
• func Start()
• type Handler
• type Metering
  • func NewMetering(create func() interface{}, clear func(interface{})) *Metering
  • func (m *Metering) GetCurrentBucket() interface{}
  • func (m *Metering) SearchOnHandler(period int, handler func(interface{})) int
• type ServiceBucket
• type ServiceCounter
• type ServiceMetering
  • func GetServiceMeter() *ServiceMetering
  • func (g *ServiceMetering) Add(elapsed int, err bool)
  • func (g *ServiceMetering) GetAllCounter(period int) *ServiceCounter
• type ValueBucket
• type ValueMetering
  • func NewValueMeter() *ValueMetering
  • func (g *ValueMetering) Add(value float64)
  • func (g *ValueMetering) GetAllCounter(period int) *ValueMetric
• type ValueMetric

Constants

const ACTIVE_SERVICE = "GoActiveService"

const ACTIVE_SPEED = "ActiveSpeed"

const ELAPSED_TIME = "GoElapsedTime"

const ERROR_RATE = "GoErrorRate"

const GO_CGO_CALL = "GoCgoCall"

const GO_GC_COUNT = "GoGcCount"

const GO_GC_PAUSE = "GoGcPause"

const GO_GOROUTINE = "Goroutine"

const GO_HEAP_USED = "GoHeapUsed"

const TPS = "GoTPS"

Functions

func SendGoCounter

func SendGoCounter()

func SendServiceCounter

func SendServiceCounter()

func Start

func Start()

Types

type Handler

type Handler interface {
	// contains filtered or unexported methods
}

type Metering

type Metering struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewMetering

func NewMetering(create func() interface{}, clear func(interface{})) *Metering

func (*Metering) GetCurrentBucket

func (m *Metering) GetCurrentBucket() interface{}

func (*Metering) SearchOnHandler

func (m *Metering) SearchOnHandler(period int, handler func(interface{})) int

type ServiceBucket

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

type ServiceCounter

type ServiceCounter struct {
	Tps       float32
	Elapsed   int
	ErrorRate float32
}

type ServiceMetering

type ServiceMetering struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func GetServiceMeter

func GetServiceMeter() *ServiceMetering

func (*ServiceMetering) Add

func (g *ServiceMetering) Add(elapsed int, err bool)

func (*ServiceMetering) GetAllCounter

func (g *ServiceMetering) GetAllCounter(period int) *ServiceCounter

type ValueBucket

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

type ValueMetering

type ValueMetering struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewValueMeter

func NewValueMeter() *ValueMetering

func (*ValueMetering) Add

func (g *ValueMetering) Add(value float64)

func (*ValueMetering) GetAllCounter

func (g *ValueMetering) GetAllCounter(period int) *ValueMetric

type ValueMetric

type ValueMetric struct {
	Sum float64
	Avg float64
}