From 75066c093c819ee7277639283a1fd18a1ff9c900 Mon Sep 17 00:00:00 2001 From: Christian Parpart Date: Fri, 8 Apr 2016 11:14:08 +0200 Subject: [PATCH] fixes statsd prefix --- tracker.go | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/tracker.go b/tracker.go index 1328ac4..f8cb226 100644 --- a/tracker.go +++ b/tracker.go @@ -10,18 +10,22 @@ import ( type Tracker struct { Name string SessionTTL time.Duration + StatsdPrefix string Debug bool buckets map[string]*time.Timer bucketMutex sync.Mutex sessionCount int64 currentBucket int statsdClient *UdpClient - statsdPrefix string statsdTicker *time.Ticker } func NewTracker(name string, sessionTTL time.Duration, statsdAddr string, statsdPrefix string, debug bool) (*Tracker, error) { - tracker := &Tracker{Name: name, SessionTTL: sessionTTL, Debug: debug} + tracker := &Tracker{Name: name, + SessionTTL: sessionTTL, + StatsdPrefix: statsdPrefix, + Debug: debug, + } if len(statsdAddr) > 0 { udpClient, err := NewUdpClient(statsdAddr) @@ -50,7 +54,7 @@ func (tracker *Tracker) flushReport() { count := tracker.GetCount() log.Printf("Tracking summary for %v sessions: %v\n", tracker.Name, count) if tracker.statsdClient != nil { - tracker.statsdClient.Sendf("%v.%v:%v|c", tracker.statsdPrefix, tracker.Name, count) + tracker.statsdClient.Sendf("%v.%v:%v|c", tracker.StatsdPrefix, tracker.Name, count) } }