stats

package
v0.0.0-...-4b497b0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 30, 2014 License: BSD-3-Clause Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const RUSAGE_CHILDREN = -1
View Source
const RUSAGE_SELF = 0

TODO should be in syscall package.

Variables

This section is empty.

Functions

func CountStatsWriteHttp

func CountStatsWriteHttp(w http.ResponseWriter, names []string, counts []int)

func CpuStatsWriteHttp

func CpuStatsWriteHttp(w http.ResponseWriter, stats []CpuStat, disk []DiskStat)

func TimevalToDuration

func TimevalToDuration(tv syscall.Timeval) time.Duration

Types

type CpuStat

type CpuStat struct {
	SelfCpu  time.Duration
	SelfSys  time.Duration
	ChildCpu time.Duration
	ChildSys time.Duration
}

func TotalCpuStat

func TotalCpuStat() *CpuStat

func (*CpuStat) Add

func (me *CpuStat) Add(x CpuStat) CpuStat

func (*CpuStat) CopySample

func (me *CpuStat) CopySample() Sample

func (*CpuStat) DiffSample

func (me *CpuStat) DiffSample(x CpuStat) CpuStat

func (*CpuStat) Percent

func (me *CpuStat) Percent() string

func (*CpuStat) String

func (me *CpuStat) String() string

func (*CpuStat) SubtractSample

func (me *CpuStat) SubtractSample(x Sample)

func (*CpuStat) TableHeader

func (me *CpuStat) TableHeader() string

func (*CpuStat) TableRow

func (me *CpuStat) TableRow() string

func (*CpuStat) Total

func (me *CpuStat) Total() time.Duration

type CpuStatSampler

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

func NewCpuStatSampler

func NewCpuStatSampler() *CpuStatSampler

func (*CpuStatSampler) CpuStats

func (me *CpuStatSampler) CpuStats() (out []CpuStat)

type DiskStat

type DiskStat struct {
	Name                 string
	MajorDev             int
	MinorDev             int
	ReadsCompleted       uint
	MergedReadsCompleted uint
	SectorsRead          uint
	MsSpentReading       uint
	WritesCompleted      uint

	SectorsWritten uint
	MsSpentWriting uint
	IOsInProgress  uint
	MsDoingIO      uint
	MsWeightedIO   uint
	// contains filtered or unexported fields
}

See http://www.kernel.org/doc/Documentation/iostats.txt

func AllDiskStats

func AllDiskStats() (result []*DiskStat, err error)

func TotalDiskStats

func TotalDiskStats() (result DiskStat, err error)

func (*DiskStat) Add

func (d *DiskStat) Add(other *DiskStat)

func (*DiskStat) String

func (d *DiskStat) String() string

func (*DiskStat) Sub

func (d *DiskStat) Sub(other *DiskStat)

type DiskStatSampler

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

func NewDiskStatSampler

func NewDiskStatSampler() *DiskStatSampler

func (*DiskStatSampler) DiskStats

func (s *DiskStatSampler) DiskStats() (out []DiskStat)

type MemCounter

type MemCounter uint64

func (MemCounter) String

func (mc MemCounter) String() string

type MemStat

type MemStat struct {
	HeapIdle  MemCounter
	HeapInuse MemCounter
}

func GetMemStat

func GetMemStat() *MemStat

func (*MemStat) Total

func (m *MemStat) Total() uint64

type PeriodicSampler

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

func NewPeriodicSampler

func NewPeriodicSampler(period time.Duration, samples int, measure func() Sample) *PeriodicSampler

func (*PeriodicSampler) Diffs

func (me *PeriodicSampler) Diffs() (out []Sample)

func (*PeriodicSampler) Stop

func (me *PeriodicSampler) Stop()

func (*PeriodicSampler) Values

func (me *PeriodicSampler) Values() []Sample

type RpcTiming

type RpcTiming struct {
	N int64
	time.Duration
}

func (*RpcTiming) String

func (me *RpcTiming) String() string

type Sample

type Sample interface {
	SubtractSample(Sample)
	CopySample() Sample
	TableHeader() string
	TableRow() string
}

type ServerStats

type ServerStats struct {
	*CpuStatSampler
	*DiskStatSampler
	PhaseOrder []string
	// contains filtered or unexported fields
}

func NewServerStats

func NewServerStats() *ServerStats

func (*ServerStats) Enter

func (me *ServerStats) Enter(phase string)

func (*ServerStats) Exit

func (me *ServerStats) Exit(phase string)

func (*ServerStats) PhaseCounts

func (me *ServerStats) PhaseCounts() (r []int)

func (*ServerStats) WriteHttp

func (me *ServerStats) WriteHttp(w http.ResponseWriter)

type TimerStats

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

func NewTimerStats

func NewTimerStats() *TimerStats

func (*TimerStats) Log

func (me *TimerStats) Log(name string, dt time.Duration)

func (*TimerStats) LogN

func (me *TimerStats) LogN(name string, n int64, dt time.Duration)

func (*TimerStats) TimingMessages

func (me *TimerStats) TimingMessages() []string

func (*TimerStats) Timings

func (me *TimerStats) Timings() map[string]*RpcTiming

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL