diff --git a/cmd/cgr-engine/cgr-engine.go b/cmd/cgr-engine/cgr-engine.go index 8d3e86f1a..2736bbbb2 100644 --- a/cmd/cgr-engine/cgr-engine.go +++ b/cmd/cgr-engine/cgr-engine.go @@ -464,6 +464,11 @@ func main() { if cfg.CDRStatsEnabled { cdrStats = &engine.Stats{} + if css, err := accountDb.GetAllCdrStats(); err == nil { + cdrStats.UpdateQueues(css, nil) + } else { + engine.Logger.Err(fmt.Sprintf("Cannot load cdr stats: %v", err)) + } server.RpcRegister(cdrStats) } diff --git a/engine/stats.go b/engine/stats.go index 71b1f23a8..093d6f952 100644 --- a/engine/stats.go +++ b/engine/stats.go @@ -101,13 +101,17 @@ func NewProxyStats(addr string) (*ProxyStats, error) { } func (ps *ProxyStats) AddQueue(sq *StatsQueue, out *int) error { - return ps.Client.Call("Scribe.AddQueue", sq, out) + return ps.Client.Call("Stats.AddQueue", sq, out) } func (ps *ProxyStats) GetValues(sqID string, values *map[string]float64) error { - return ps.Client.Call("Scribe.GetValues", sqID, values) + return ps.Client.Call("Stats.GetValues", sqID, values) } func (ps *ProxyStats) AppendCDR(cdr *utils.StoredCdr, out *int) error { - return ps.Client.Call("Scribe.AppendCDR", cdr, out) + return ps.Client.Call("Stats.AppendCDR", cdr, out) } + +/*func (ps *ProxyStats) UpdateQueues(css []*CdrStats, out *int) error { + return ps.Client.Call("Stats.UpdateQueues", css, out) +}*/