uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-14 20:59:53 +05:00
Code Issues Packages Projects Releases Wiki Activity

StatASR LoadMarshaled

Browse Source
This commit is contained in:
DanB
2017-09-10 19:25:26 +02:00
parent 05ecfbdf0d
commit 68809c63d1
2 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
engine/libstats.go
View File

@@ -121,7 +121,7 @@ func (ssq *StoredStatQueue) AsStatQueue(ms Marshaler) (sq *StatQueue, err error)
for metricID, marshaled := range ssq.SQMetrics {
if metric, err := NewStatMetric(metricID); err != nil {
return nil, err
} else if err := metric.LoadFromMarshaled(ms, marshaled); err != nil {
} else if err := metric.LoadMarshaled(ms, marshaled); err != nil {
return nil, err
} else {
sq.SQMetrics[metricID] = metric

11
engine/statmetrics.go
View File

@@ -47,7 +47,7 @@ type StatMetric interface {
AddEvent(ev StatEvent) error
RemEvent(evID string) error
Marshal(ms Marshaler) (marshaled []byte, err error)
LoadFromMarshaled(ms Marshaler, marshaled []byte) (err error)
LoadMarshaled(ms Marshaler, marshaled []byte) (err error)
}
func NewASR() (StatMetric, error) {
@@ -122,11 +122,14 @@ func (asr *StatASR) RemEvent(evID string) (err error) {
return
}
// Marshal is part of StatMetric interface
func (asr *StatASR) Marshal(ms Marshaler) (marshaled []byte, err error) {
return ms.Marshal(asr)
}
func (asr *StatASR) LoadFromMarshaled(ms Marshaler, marshaled []byte) (err error) {
return
// LoadMarshaled is part of StatMetric interface
func (asr *StatASR) LoadMarshaled(ms Marshaler, marshaled []byte) (err error) {
return ms.Unmarshal(marshaled, asr)
}
func NewACD() (StatMetric, error) {
@@ -162,6 +165,6 @@ func (acd *StatACD) RemEvent(evID string) (err error) {
func (acd *StatACD) Marshal(ms Marshaler) (marshaled []byte, err error) {
return
}
func (acd *StatACD) LoadFromMarshaled(ms Marshaler, marshaled []byte) (err error) {
func (acd *StatACD) LoadMarshaled(ms Marshaler, marshaled []byte) (err error) {
return
}