Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

tally

package

Go to main page

Versions in this module

v1

v1.3.0

Mar 20, 2015

Changes in this version

+ const MAX_LINE_LEN

v1.2.0

Nov 24, 2014

Changes in this version

+ const STATGRAM_MAXSIZE

+ const STRING_COUNT_CAPACITY

+ const TIMINGS_INITIAL_CAPACITY

+ func Aggregate(conn io.Reader, numReceivers int) (snapchan chan *Snapshot)

+ func LogTo(out io.Writer)

+ func LogToSyslog()

+ func ParseFloat(b []byte) (f float64, e error)

+ func RunReceiver(id string, conn io.Reader, notifiers ...chan Statgram) (controlChannel chan *Snapshot)

+ func ServeStatus(server *Server) error

+ type CountBucket struct

+ func (b *CountBucket) String() string

+ type CountLevel struct

+ Current float64

+ func (lvl *CountLevel) Count(value float64)

+ func (lvl *CountLevel) Duration() time.Duration

+ func (lvl *CountLevel) NewBucket()

+ func (lvl *CountLevel) RatePer(unit time.Duration) float64

+ func (lvl *CountLevel) Reset()

+ type FlagFile struct

+ func NewFlagFile(path string) (ff *FlagFile, err error)

+ func (ff *FlagFile) ReadFlags(reader io.Reader) error

+ type FrequencyCount struct

+ type FrequencyCountSlice []FrequencyCount

+ func (fcs FrequencyCountSlice) Len() int

+ func (fcs FrequencyCountSlice) Less(i, j int) bool

+ func (fcs FrequencyCountSlice) Swap(i, j int)

+ type FrequencyCounter struct

+ func NewFrequencyCounter(capacity int, intervals ...time.Duration) *FrequencyCounter

+ func (fcr *FrequencyCounter) Aggregate(child *FrequencyCounter)

+ func (fcr *FrequencyCounter) Count(key string, count float64)

+ func (fcr *FrequencyCounter) SortedItems() FrequencyCountSlice

+ func (fcr *FrequencyCounter) Trim()

+ type Graphite struct

+ func NewGraphite(address string, options ...interface{}) (client *Graphite, err error)

+ func (graphite *Graphite) Dial(addr *net.TCPAddr) (io.WriteCloser, error)

+ func (graphite *Graphite) SendReport(snapshot *Snapshot) (err error)

+ type GraphiteDialer interface

+ Dial func(*net.TCPAddr) (io.WriteCloser, error)

+ type Harold struct

+ func NewHarold(address string, secret string, options ...interface{}) (harold *Harold, err error)

+ func (harold *Harold) HeartMonitor(tag string) (intervals chan time.Duration)

+ func (harold *Harold) Heartbeat(tag string, interval time.Duration) (*http.Response, error)

+ func (harold *Harold) Post(path []string, data map[string]string) (*http.Response, error)

+ type HaroldPoster interface

+ Post func(path []string, data map[string]string) (*http.Response, error)

+ type LineReader interface

+ ReadLine func() ([]byte, bool, error)

+ type MultilevelCount []CountLevel

+ func NewMultilevelCount(intervals ...time.Duration) *MultilevelCount

+ func (mc MultilevelCount) Count(value float64)

+ func (mc MultilevelCount) Reset()

+ func (mc MultilevelCount) Rollup()

+ func (mc MultilevelCount) Total() float64

+ type Receiver struct

+ func NewReceiver() *Receiver

+ func (receiver *Receiver) ReadOnce() (s Statgram, err error)

+ func (receiver *Receiver) ReceiveStatgrams() (statgrams chan Statgram)

+ type ReportedValue struct

+ type Sample struct

+ func ParseSample(key string, part []byte) (sample Sample, err error)

+ type SampleType int

+ const COUNTER

+ const STRING

+ const TIMER

+ type Server struct

+ func NewServer(host string, port int, numWorkers int, flushInterval time.Duration, ...) *Server

+ func (server *Server) Loop() error

+ type Snapshot struct

+ func NewSnapshot() *Snapshot

+ func (snapshot *Snapshot) Aggregate(child *Snapshot)

+ func (snapshot *Snapshot) Count(key string, value float64)

+ func (snapshot *Snapshot) CountString(key, value string, count float64)

+ func (snapshot *Snapshot) Flush()

+ func (snapshot *Snapshot) GraphiteReport() (report []string)

+ func (snapshot *Snapshot) NumStats() int

+ func (snapshot *Snapshot) ProcessStatgram(statgram Statgram)

+ func (snapshot *Snapshot) Report(key string, value float64, ts ...time.Time)

+ func (snapshot *Snapshot) Time(key string, value float64)

+ type Statgram []Sample

+ type StatgramParser struct

+ Length int

+ func NewStatgramParser() *StatgramParser

+ func (parser *StatgramParser) ParseStatgram(datagram []byte) Statgram

+ func (parser *StatgramParser) ParseStatgramLine(line []byte) (s Statgram, err error)

+ type StatusRequest struct

+ type SyntaxError struct

+ func (e *SyntaxError) Error() string

v1.1.5

Oct 29, 2014

v1.1.4

Dec 9, 2013

v1.1.3

May 8, 2013

v1.1.2

Apr 13, 2013

v1.1.1

Apr 13, 2013

v1.1.0

Apr 10, 2013

v1.0.0

Mar 25, 2013