ionutboangiu
652d1e68cf
Remove cls fields from service structs
...
now retrieved through registry.Lookup
2025-01-24 12:02:24 +01:00
armirveliaj
7db65ca62c
Clean up DispatcherS
2025-01-17 17:29:46 +01:00
ionutboangiu
e7152dacf8
Implement ConnManager service
...
Use it to register internal rpc conns instead of ServManager
DispatcherS now waits for AttributeS to start (only when enabled)
2025-01-14 19:00:37 +01:00
ionutboangiu
bf3d9a3281
Export funcs that wait for service state
2025-01-14 19:00:37 +01:00
ionutboangiu
089dfc00ae
Use SyncedChan to handle shutdown
2025-01-14 19:00:37 +01:00
ionutboangiu
c49e67b2ed
Handle SERVICE_UP/DOWN states on ServManager layer
2025-01-14 19:00:37 +01:00
ionutboangiu
dab152f976
Integrate StateServiceDOWN + registry related refactor
...
Removed redundant IsRunning service method
Removed registry from constructors
Pass registry to Start/Reload/Shutdown service methods
2025-01-14 19:00:37 +01:00
ionutboangiu
396227d639
Refactor ServiceIndexer implementation
...
Renamed to ServiceRegistry
Improved comments
2025-01-10 20:18:08 +01:00
ionutboangiu
20ee079e12
Use the waitForServicesToReachState helper
2025-01-10 20:18:08 +01:00
ionutboangiu
17405af987
Revise service manager logs
...
Logging is now done as ServiceManager level. Removed any other logs.
2025-01-10 20:18:08 +01:00
ionutboangiu
c8a3ebe5e8
Use channel instead of context to handle shutdown
2025-01-10 20:18:08 +01:00
ionutboangiu
da2052e7b3
Implement FilterService
...
And use ServiceIndexer to sync with it
2024-12-12 11:55:14 +01:00
ionutboangiu
db301f7901
Remove StorDB service param from service constructors
...
Use ServiceIndexer instead.
Remove CDRs ListenAndServe method.
Pass the storDB connection directly to constructors instead of the
channel.
2024-12-12 11:55:14 +01:00
ionutboangiu
10dfcc5e48
Remove dmS parameter from service constructors
...
Use ServiceIndexer instead
2024-12-12 11:55:14 +01:00
ionutboangiu
55ecdf45e4
Remove clsChan in favor of using the service indexer
2024-12-12 11:55:14 +01:00
ionutboangiu
77af4f95b3
Remove anzCh in favor of using the service indexer
2024-12-10 18:53:13 +01:00
ionutboangiu
0783984bfe
Remove srvDep from services that don't use it
2024-12-05 20:12:08 +01:00
ionutboangiu
79e461e7c5
Remove redundant internal channels
...
only from services that have dedicated files
2024-12-04 19:28:50 +01:00
ionutboangiu
cfdb3e80ca
Integrate state deps across services for SERVICE_UP
2024-12-04 19:28:50 +01:00
DanB
476f5ba877
Services with IntRPCConn method
2024-11-30 19:13:19 +01:00
DanB
6b241ee35b
Adding serviceIndexer and StateDependencies
2024-11-28 14:56:03 +01:00
ionutboangiu
1453234293
Use channel instead of wait func (AnalyzerS)
2024-11-14 17:48:09 +01:00
ionutboangiu
59f8b1379e
Use channel instead of wait func (CLS)
2024-11-14 17:48:09 +01:00
ionutboangiu
21409fc92e
Add new CommonListenerService
2024-11-14 17:48:09 +01:00
ionutboangiu
0d9358cf30
Ensure services wait for AnalyzerS to be initiated
...
Same logic as waiting for FilterS/DataDBService.
The difference will be that services will only wait when AnalyzerS
is enabled.
2024-11-14 17:48:09 +01:00
ionutboangiu
5bf8f1756c
Extract cores.Server into new commonlisteners package
...
Functionality is the same.
Server has been renamed to CommonListenerS.
2024-11-04 21:23:15 +01:00
gezimbll
27c4242c52
renamed newservice2 function to newservicewithping
2024-06-07 17:18:23 +02:00
gezimbll
18fa884ea1
revise integration tests
2024-06-07 17:18:23 +02:00
ionutboangiu
8ee919319b
Register the CDRServer from cdrs instead of the one from services
...
Also renamed services.CDRServer to CDRService to prevent such mistakes from
happening in the future.
2023-12-13 12:47:02 +01:00
ionutboangiu
00a94d092f
Use birpc service constructor and ensure error is handled
2023-12-12 10:09:18 +01:00
ionutboangiu
d29f84169c
Move cdrs to its own package
...
Moved engine/cdr.go to utils/cdr.go.
Moved engine/cdrs.go and engine/cdrs_test.go to cdrs package.
Moved api functions from cdrs/cdrs.go to cdrs/apis.go. Same for the
tests.
Deleted CDRsV1 type and its methods.
2023-12-12 10:09:18 +01:00
ionutboangiu
e5ab21def5
Implement AdminSv1 Get/RemoveCDRs APIs for CDRs
...
Addition of storDB to AdminSv1 was required.
2023-11-09 20:50:36 +01:00
ionutboangiu
df1dc5e838
Add StorDB service
...
Add StorDB to config and services.
Put back the store_cdrs option under cdrs and update the CDRs
service to depend on StorDB.
Define the StorDB interface and add a constructor for it.
Add a constructor for postgres storage.
Add a config sanity check to validate SSL modes for postgres.
Update cgr-engine to consider StorDB on startup.
2023-05-03 10:05:28 +02:00
andronache98
ecdf5e54ea
Changed headers
2022-03-09 14:14:30 +01:00
andronache98
9ec56f5155
Changed headers
2022-03-09 14:14:30 +01:00
andronache98
03793c0082
Removed storDB from config
2022-03-09 14:14:30 +01:00
Trial97
904a6817e4
Updated internal connections
2021-11-17 18:36:40 +01:00
Trial97
a4ebbfe67b
Updated services
2021-11-17 18:36:40 +01:00
Trial97
0ed0b0e7a6
Updated more services
2021-09-13 16:08:39 +02:00
Trial97
87ce843810
Updated services
2021-09-13 16:08:39 +02:00
DanB
58f7d02ab7
Re-enabling CDRs with RateS processing
2021-09-05 11:42:14 +02:00
Trial97
c04c0a5adb
Added ConfigDB and option to read config from DB
2021-04-16 17:53:36 +02:00
Trial97
cfbe6e709d
Added AdminSv1 service
2021-04-13 13:35:03 +02:00
Trial97
3406d3c7c9
Updated based on new rpc library
2021-04-13 13:35:03 +02:00
Trial97
222363f433
Added service dependency map to control the shutdown order. Fixes #2472
2020-12-08 12:59:44 +01:00
Trial97
a81fce8341
Updated services shutdown
2020-11-16 10:11:46 +01:00
Trial97
568df81745
Added cores package and tests for caps
2020-11-05 17:07:50 +01:00
Trial97
f26a26296d
Added AnalyzerSv1.StringQuery API to search over the recorded RPC calls
2020-10-29 17:55:26 +01:00
Trial97
81a4cdd3a1
Added tests for analyzers
2020-10-29 17:55:26 +01:00
Trial97
c2c39336c4
Added runtime.Gosched for context switching
2020-09-29 13:27:04 +02:00
