uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 10:06:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

agents: add processor/reader id to stats/th events

Browse Source
This commit is contained in:
ionutboangiu
2025-11-04 13:52:49 +02:00
committed by Dan Christian Bogos
parent 682c080c73
commit 63e4856aff
5 changed files with 52 additions and 46 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
agents/libagents.go
View File

@@ -193,11 +193,12 @@ func processRequest(ctx *context.Context, reqProcessor *config.RequestProcessor,
Tenant: cgrEv.Tenant,
ID: utils.GenUUID(),
Event: map[string]any{
utils.ReplyState: replyState,
utils.StartTime: startTime,
utils.EndTime: endTime,
utils.ProcessingTime: endTime.Sub(startTime),
utils.Source: agentName,
utils.ReplyState: replyState,
utils.StartTime: startTime,
utils.EndTime: endTime,
utils.ProcessingTime: endTime.Sub(startTime),
utils.Source: agentName,
utils.RequestProcessorID: reqProcessor.ID,
},
APIOpts: map[string]any{
utils.MetaEventType: utils.ProcessTime,

11
agents/radagent.go
View File

@@ -471,11 +471,12 @@ func (ra *RadiusAgent) processRequest(req *radigo.Packet, reqProcessor *config.R
Tenant: cgrEv.Tenant,
ID: utils.GenUUID(),
Event: map[string]any{
utils.ReplyState: replyState,
utils.StartTime: startTime,
utils.EndTime: endTime,
utils.ProcessingTime: endTime.Sub(startTime),
utils.Source: utils.RadiusAgent,
utils.ReplyState: replyState,
utils.StartTime: startTime,
utils.EndTime: endTime,
utils.ProcessingTime: endTime.Sub(startTime),
utils.Source: utils.RadiusAgent,
utils.RequestProcessorID: reqProcessor.ID,
},
APIOpts: map[string]any{
utils.MetaEventType: utils.ProcessTime,

11
agents/sipagent.go
View File

@@ -469,11 +469,12 @@ func (sa *SIPAgent) processRequest(reqProcessor *config.RequestProcessor,
Tenant: cgrEv.Tenant,
ID: utils.GenUUID(),
Event: map[string]any{
utils.ReplyState: replyState,
utils.StartTime: startTime,
utils.EndTime: endTime,
utils.ProcessingTime: endTime.Sub(startTime),
utils.Source: utils.SIPAgent,
utils.ReplyState: replyState,
utils.StartTime: startTime,
utils.EndTime: endTime,
utils.ProcessingTime: endTime.Sub(startTime),
utils.Source: utils.SIPAgent,
utils.RequestProcessorID: reqProcessor.ID,
},
APIOpts: map[string]any{
utils.MetaEventType: utils.ProcessTime,

1
ers/ers.go
View File

@@ -216,6 +216,7 @@ func (erS *ERService) processEvent(cgrEv *utils.CGREvent,
utils.EndTime: endTime,
utils.ProcessingTime: endTime.Sub(startTime),
utils.Source: utils.ERs,
utils.EventReaderID: rdrCfg.ID,
},
APIOpts: map[string]any{
utils.MetaEventType: utils.ProcessTime,

64
utils/consts.go
View File

@@ -520,37 +520,39 @@ const (
User = "User"
Subscribers = "Subscribers"
//Destinations = "Destinations"
MetaSubscribers = "*subscribers"
MetaDataDB = "*datadb"
MetaStorDB = "*stordb"
MetaWeight = "*weight"
MetaLC = "*lc"
MetaHC = "*hc"
MetaQOS = "*qos"
MetaReas = "*reas"
MetaReds = "*reds"
Weight = "Weight"
Limit = "Limit"
UsageTTL = "UsageTTL"
Usages = "Usages"
TTLIdx = "TTLIdx"
AllocationMessage = "AllocationMessage"
AddressPool = "AddressPool"
Pools = "Pools"
Allocations = "Allocations"
TTLIndex = "TTLIndex"
Allocation = "Allocation"
Range = "Range"
Stored = "Stored"
RatingSubject = "RatingSubject"
Categories = "Categories"
Blocker = "Blocker"
Blockers = "Blockers"
Params = "Params"
StartTime = "StartTime"
EndTime = "EndTime"
ProcessingTime = "ProcessingTime"
ReplyState = "ReplyState"
MetaSubscribers = "*subscribers"
MetaDataDB = "*datadb"
MetaStorDB = "*stordb"
MetaWeight = "*weight"
MetaLC = "*lc"
MetaHC = "*hc"
MetaQOS = "*qos"
MetaReas = "*reas"
MetaReds = "*reds"
Weight = "Weight"
Limit = "Limit"
UsageTTL = "UsageTTL"
Usages = "Usages"
TTLIdx = "TTLIdx"
AllocationMessage = "AllocationMessage"
AddressPool = "AddressPool"
Pools = "Pools"
Allocations = "Allocations"
TTLIndex = "TTLIndex"
Allocation = "Allocation"
Range = "Range"
Stored = "Stored"
RatingSubject = "RatingSubject"
Categories = "Categories"
Blocker = "Blocker"
Blockers = "Blockers"
Params = "Params"
StartTime = "StartTime"
EndTime = "EndTime"
ProcessingTime = "ProcessingTime"
ReplyState = "ReplyState"
RequestProcessorID = "RequestProcessorID"
EventReaderID = "EventReaderID"
// ReplyState error constants
ErrReplyStateAuthorize = "ERR_AUTHORIZE"