go-metrics/counter.go

package metrics

import "sync/atomic"

// Counters hold an int64 value that can be incremented and decremented.
//
// This is an interface so as to encourage other structs to implement
// the Counter API as appropriate.
type Counter interface {
	Clear()
	Count() int64
	Dec(int64)
	Inc(int64)
}

// The standard implementation of a Counter uses the sync/atomic package
// to manage a single int64 value.  When the latest weeklies land in a
// release, atomic.LoadInt64 will be available and this code will become
// safe on 32-bit architectures.
type StandardCounter struct {
	count int64
}

// Create a new counter.
func NewCounter() Counter {
	return &StandardCounter{0}
}

// Clear the counter: set it to zero.
func (c *StandardCounter) Clear() {
	c.count = 0
}

// Return the current count.  This is the method that's currently unsafe
// on 32-bit architectures.
func (c *StandardCounter) Count() int64 {
	return c.count
}

// Decrement the counter by the given amount.
func (c *StandardCounter) Dec(i int64) {
	atomic.AddInt64(&c.count, -i)
}

// Increment the counter by the given amount.
func (c *StandardCounter) Inc(i int64) {
	atomic.AddInt64(&c.count, i)
}