cdrstats_metrics and cdrstats_queueids console commands

This commit is contained in:
Radu Ioan Fericean
2014-08-01 18:47:20 +03:00
parent 8d1be00962
commit 6634751d7a
3 changed files with 120 additions and 0 deletions

View File

@@ -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)
}

View File

@@ -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 <http://www.gnu.org/licenses/>
*/
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{}
}

View File

@@ -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 <http://www.gnu.org/licenses/>
*/
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
}