README
¶
Measure storage
This lib implements a simple in-memory measure storage which is optionally synced every N seconds with a persistent storage.
It's thread-safe and as simple as possible.
How to use
To initialize:
measures.Measures = measures.CreateMeasureStore(measures.NewRedisIncrementer("localhost", 6379),
time.Second*10)
By default, an in-memory measure storage is used.
To write:
measures.Measures.Inc("some_measure_1234234", 1.0)
To read:
val, err := measures.Measures.Get("some_measure_1234234")
if err != nil {
log.Fatal("error has occured", err)
}
It supports lazy loading, meaning that after restart, the measure will only be retrieved after it was first accessed.
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var Measures = CreateMeasureStore(NewMemIncrementer(nil), time.Second)
Functions ¶
This section is empty.
Types ¶
type FloatMeasure ¶
type FloatMeasure struct {
Key string
// contains filtered or unexported fields
}
func NewFloatMesure ¶
func NewFloatMesure(key string, inc Incrementer, syncperiod time.Duration) (fm *FloatMeasure, err error)
func (*FloatMeasure) Get ¶
func (m *FloatMeasure) Get() (ret float64)
func (*FloatMeasure) Inc ¶
func (m *FloatMeasure) Inc(v float64)
type Incrementer ¶
type MeasureStore ¶
type MeasureStore struct {
// contains filtered or unexported fields
}
func CreateMeasureStore ¶
func CreateMeasureStore(inc Incrementer, synctime time.Duration) *MeasureStore
type MemIncrementer ¶
type MemIncrementer struct {
// contains filtered or unexported fields
}
func NewMemIncrementer ¶
func NewMemIncrementer(startwith map[string]float64) (fi *MemIncrementer)
type RedisIncrementer ¶
type RedisIncrementer struct {
// contains filtered or unexported fields
}
func NewRedisIncrementer ¶
func NewRedisIncrementer(host string, port int) (fi *RedisIncrementer)
Source Files
Click to show internal directories.
Click to hide internal directories.