From 721f634735f1fc0e82b2d913822eff30bd2b8bca Mon Sep 17 00:00:00 2001 From: DanB Date: Thu, 3 Aug 2017 16:43:40 +0200 Subject: [PATCH] StatS as alpha implementation --- stats/service.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/stats/service.go b/stats/service.go index 01e5ecbf7..5f5bc0739 100644 --- a/stats/service.go +++ b/stats/service.go @@ -173,6 +173,7 @@ func (ss *StatService) V1ProcessEvent(ev engine.StatsEvent, reply *string) (err return } +// V1GetQueueIDs returns list of queue IDs configured in the service func (ss *StatService) V1GetQueueIDs(ignored struct{}, reply *[]string) (err error) { if len(ss.queuesCache) == 0 { return utils.ErrNotFound @@ -183,6 +184,7 @@ func (ss *StatService) V1GetQueueIDs(ignored struct{}, reply *[]string) (err err return } +// V1GetStatMetrics returns the metrics as string values func (ss *StatService) V1GetStatMetrics(queueID string, reply *map[string]string) (err error) { sq, has := ss.queuesCache[queueID] if !has { @@ -196,12 +198,13 @@ func (ss *StatService) V1GetStatMetrics(queueID string, reply *map[string]string return } +// ArgsLoadQueues are the arguments passed to V1LoadQueues type ArgsLoadQueues struct { QueueIDs *[]string } // V1LoadQueues loads the queues specified by qIDs into the service -// loads all if qIDs is nil +// loads all if args.QueueIDs is nil func (ss *StatService) V1LoadQueues(args ArgsLoadQueues, reply *string) (err error) { qIDs := args.QueueIDs if qIDs == nil {