statsq

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Jul 12, 2017 License: Apache-2.0 Imports: 17 Imported by: 1

README

Benchmark

$ go test -bench=Bench .
BenchmarkOneBigTimer-4            	       1	1390692436 ns/op
BenchmarkLotsOfTimers-4           	       1	1528838842 ns/op
BenchmarkParseLineCounter-4       	 1000000	      1401 ns/op
BenchmarkParseLineGauge-4         	 1000000	      1303 ns/op
BenchmarkParseLineTimer-4         	 1000000	      1373 ns/op
BenchmarkParseLineSet-4           	 1000000	      1256 ns/op
BenchmarkPacketHandlerCounter-4   	10000000	       137 ns/op
BenchmarkPacketHandlerGauge-4     	10000000	       145 ns/op
BenchmarkPacketHandlerTimer-4     	10000000	       183 ns/op
BenchmarkPacketHandlerSet-4       	10000000	       197 ns/op
PASS
ok  	github.com/ChristianKniep/statsq/lib	17.375s

Testcases

$ go test -cover .
ok  	github.com/ChristianKniep/statsq/lib	0.011s	coverage: 67.2% of statements

Documentation

Index

Constants

View Source 
const (
	MAX_UNPROCESSED_PACKETS = 1000
	TCP_READ_SIZE           = 4096
)

Variables

This section is empty.

Functions

func GenID 

func GenID(s string) string

func NewStatsdPacketFromPacket 

func NewStatsdPacketFromPacket(p *Packet) *qtypes.StatsdPacket

Types

type BucketID 

type BucketID struct {
	ID         string
	BucketName string
	Dimensions qtypes.Dimensions
}

func NewBucketID 

func NewBucketID(name string, dims qtypes.Dimensions) BucketID

func (*BucketID) GenerateID 

func (bid *BucketID) GenerateID()

func (*BucketID) GetDims 

func (bid *BucketID) GetDims() map[string]string

type Float64Slice 

type Float64Slice []float64

func (Float64Slice) Len 

func (s Float64Slice) Len() int

func (Float64Slice) Less 

func (s Float64Slice) Less(i, j int) bool

func (Float64Slice) Swap 

func (s Float64Slice) Swap(i, j int)

type MsgParser 

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

func NewParser 

func NewParser(reader io.Reader, partialReads, debug bool, maxUdpPacketSize int, prefix, postfix string) *MsgParser

func (*MsgParser) Next 

func (mp *MsgParser) Next() (*qtypes.StatsdPacket, bool)

type Packet 

type Packet struct {
	Bucket   string
	ValFlt   float64
	ValStr   string
	Modifier string
	Sampling float32
	Args     string
}

type Percentile 

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

func (*Percentile) String 

func (p *Percentile) String() string

type Percentiles 

type Percentiles []*Percentile

func (*Percentiles) Set 

func (a *Percentiles) Set(s string) error

func (*Percentiles) String 

func (a *Percentiles) String() string

type StatsQ 

type StatsQ struct {
	Name            string
	Version         string
	Parser          MsgParser
	Signalchan      chan os.Signal
	Cfg             *config.Config
	In              chan *qtypes.StatsdPacket
	Counters        map[string]float64
	Gauges          map[string]float64
	Timers          map[string]Float64Slice
	CountInactivity map[string]int64
	Sets            map[string][]string
	ReceiveCounter  string
	QChan           qtypes.QChan
	Percentiles     Percentiles
	BucketMapping   map[string]BucketID
}

func NewNamedStatsQ 

func NewNamedStatsQ(name string, cfg *config.Config, qchan qtypes.QChan) StatsQ

func NewStatsQ 

func NewStatsQ(cfg *config.Config) StatsQ

func (*StatsQ) Bool 

func (sd *StatsQ) Bool(path string) bool

func (*StatsQ) BoolOr 

func (sd *StatsQ) BoolOr(path string, alt bool) bool

func (*StatsQ) FanOutCounters 

func (sd *StatsQ) FanOutCounters(now time.Time) int64

func (*StatsQ) FanOutGauges 

func (sd *StatsQ) FanOutGauges(now time.Time) int64

func (*StatsQ) FanOutMetrics 

func (sd *StatsQ) FanOutMetrics()

func (*StatsQ) FanOutSets 

func (sd *StatsQ) FanOutSets(now time.Time) int64

func (*StatsQ) FanOutTimers 

func (sd *StatsQ) FanOutTimers(now time.Time) int64

func (*StatsQ) HandlerStatsdPacket 

func (sd *StatsQ) HandlerStatsdPacket(sp *qtypes.StatsdPacket)

func (*StatsQ) Int 

func (sd *StatsQ) Int(path string) int

func (*StatsQ) IntOr 

func (sd *StatsQ) IntOr(path string, alt int) int

func (*StatsQ) Log 

func (sd *StatsQ) Log(logLevel, msg string)

func (*StatsQ) LoopChannel 

func (sd *StatsQ) LoopChannel()

func (*StatsQ) ParseLine 

func (sd *StatsQ) ParseLine(msg string) (err error)

func (*StatsQ) ParseTo 

func (sd *StatsQ) ParseTo(conn io.ReadCloser, partialReads bool)

func (*StatsQ) ProcessCounters 

func (sd *StatsQ) ProcessCounters(buffer *bytes.Buffer, now int64) int64

func (*StatsQ) ProcessGauges 

func (sd *StatsQ) ProcessGauges(buffer *bytes.Buffer, now int64) int64

func (*StatsQ) ProcessSets 

func (sd *StatsQ) ProcessSets(buffer *bytes.Buffer, now int64) int64

func (*StatsQ) ProcessTimers 

func (sd *StatsQ) ProcessTimers(buffer *bytes.Buffer, now int64) int64

func (*StatsQ) RelayMetrics 

func (sd *StatsQ) RelayMetrics()

RelayMetrics listens for metrics on the QChan.Data channel and sends the metrics to the backends

func (*StatsQ) Run 

func (sd *StatsQ) Run()

func (*StatsQ) String 

func (sd *StatsQ) String(path string) string

func (*StatsQ) StringOr 

func (sd *StatsQ) StringOr(path, alt string) string

type TimerResult 

type TimerResult struct {
	TestsGot map[string]string
	TestsExp map[string]float64
}

func NewTimerResult 

func NewTimerResult(exp map[string]float64) TimerResult

func (*TimerResult) Check 

func (tr *TimerResult) Check() bool

func (*TimerResult) Input 

func (tr *TimerResult) Input(name string, value float64)

func (*TimerResult) Result 

func (tr *TimerResult) Result() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.