diff --git a/apier/cdrstatsv1.go b/apier/cdrstatsv1.go index 928480b4e..9e5c9c999 100644 --- a/apier/cdrstatsv1.go +++ b/apier/cdrstatsv1.go @@ -40,3 +40,7 @@ func (sts *CDRStatsV1) GetMetrics(attr AttrGetMetrics, reply *map[string]float64 } return sts.CdrStats.GetValues(attr.StatsQueueId, reply) } + +func (sts *CDRStatsV1) GetQueueIds(empty string, reply *[]string) error { + return sts.CdrStats.GetQueueIds(0, reply) +} diff --git a/console/cdrstats_metrics.go b/console/cdrstats_metrics.go new file mode 100644 index 000000000..07f39d190 --- /dev/null +++ b/console/cdrstats_metrics.go @@ -0,0 +1,57 @@ +/* +Rating system designed to be used in VoIP Carriers World +Copyright (C) 2013 ITsysCOM + +This program is free software: you can redistribute it and/or modify +it under the terms of the GNU General Public License as published by +the Free Software Foundation, either version 3 of the License, or +(at your option) any later version. + +This program is distributed in the hope that it will be useful, +but WITHOUT ANY WARRANTY; without even the implied warranty of +MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +GNU General Public License for more details. + +You should have received a copy of the GNU General Public License +along with this program. If not, see +*/ + +package console + +import "github.com/cgrates/cgrates/apier" + +func init() { + c := &CmdCdrStatsMetrics{ + name: "cdrstats_metrics", + rpcMethod: "CDRStatsV1.GetMetrics", + } + commands[c.Name()] = c + c.CommandExecuter = &CommandExecuter{c} +} + +// Commander implementation +type CmdCdrStatsMetrics struct { + name string + rpcMethod string + rpcParams *apier.AttrGetMetrics + *CommandExecuter +} + +func (self *CmdCdrStatsMetrics) Name() string { + return self.name +} + +func (self *CmdCdrStatsMetrics) RpcMethod() string { + return self.rpcMethod +} + +func (self *CmdCdrStatsMetrics) RpcParams() interface{} { + if self.rpcParams == nil { + self.rpcParams = &apier.AttrGetMetrics{} + } + return self.rpcParams +} + +func (self *CmdCdrStatsMetrics) RpcResult() interface{} { + return &map[string]float64{} +} diff --git a/console/cdrstats_queueids.go b/console/cdrstats_queueids.go new file mode 100644 index 000000000..c44335aed --- /dev/null +++ b/console/cdrstats_queueids.go @@ -0,0 +1,59 @@ +/* +Rating system designed to be used in VoIP Carriers World +Copyright (C) 2013 ITsysCOM + +This program is free software: you can redistribute it and/or modify +it under the terms of the GNU General Public License as published by +the Free Software Foundation, either version 3 of the License, or +(at your option) any later version. + +This program is distributed in the hope that it will be useful, +but WITHOUT ANY WARRANTY; without even the implied warranty of +MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +GNU General Public License for more details. + +You should have received a copy of the GNU General Public License +along with this program. If not, see +*/ + +package console + +func init() { + c := &CmdCdrStatsQueueIds{ + name: "cdrstats_queueids", + rpcMethod: "CDRStatsV1.GetQueueIds", + } + commands[c.Name()] = c + c.CommandExecuter = &CommandExecuter{c} +} + +type CmdCdrStatsQueueIds struct { + name string + rpcMethod string + rpcParams *StringWrapper + *CommandExecuter +} + +func (self *CmdCdrStatsQueueIds) Name() string { + return self.name +} + +func (self *CmdCdrStatsQueueIds) RpcMethod() string { + return self.rpcMethod +} + +func (self *CmdCdrStatsQueueIds) RpcParams() interface{} { + if self.rpcParams == nil { + self.rpcParams = &StringWrapper{} + } + return self.rpcParams +} + +func (self *CmdCdrStatsQueueIds) RpcResult() interface{} { + var s []string + return &s +} + +func (self *CmdCdrStatsQueueIds) ClientArgs() (args []string) { + return +}