services

package
v0.10.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 9, 2023 License: GPL-3.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewAnalyzerService 

func NewAnalyzerService(cfg *config.CGRConfig, server *utils.Server, exitChan chan bool,
	internalAnalyzerSChan chan birpc.ClientConnector) servmanager.Service

NewAnalyzerService returns the Analyzer Service

func NewAsteriskAgent 

func NewAsteriskAgent(cfg *config.CGRConfig,
	exitChan chan bool, connMgr *engine.ConnManager) servmanager.Service

NewAsteriskAgent returns the Asterisk Agent

func NewAttributeService 

func NewAttributeService(cfg *config.CGRConfig, dm *DataDBService,
	cacheS *engine.CacheS, filterSChan chan *engine.FilterS,
	server *utils.Server, internalChan chan birpc.ClientConnector) servmanager.Service

NewAttributeService returns the Attribute Service

func NewCDRServer 

func NewCDRServer(cfg *config.CGRConfig, dm *DataDBService,
	storDB *StorDBService, filterSChan chan *engine.FilterS,
	server *utils.Server, internalCDRServerChan chan birpc.ClientConnector,
	connMgr *engine.ConnManager) servmanager.Service

NewCDRServer returns the CDR Server

func NewChargerService 

func NewChargerService(cfg *config.CGRConfig, dm *DataDBService,
	cacheS *engine.CacheS, filterSChan chan *engine.FilterS, server *utils.Server,
	internalChargerSChan chan birpc.ClientConnector, connMgr *engine.ConnManager) servmanager.Service

NewChargerService returns the Charger Service

func NewDNSAgent 

func NewDNSAgent(cfg *config.CGRConfig, filterSChan chan *engine.FilterS,
	exitChan chan bool, connMgr *engine.ConnManager) servmanager.Service

NewDNSAgent returns the DNS Agent

func NewDiameterAgent 

func NewDiameterAgent(cfg *config.CGRConfig, filterSChan chan *engine.FilterS,
	exitChan chan bool, connMgr *engine.ConnManager) servmanager.Service

NewDiameterAgent returns the Diameter Agent

func NewDispatcherService 

func NewDispatcherService(cfg *config.CGRConfig, dm *DataDBService,
	cacheS *engine.CacheS, filterSChan chan *engine.FilterS,
	server *utils.Server, internalChan chan birpc.ClientConnector, connMgr *engine.ConnManager) servmanager.Service

NewDispatcherService returns the Dispatcher Service

func NewEventReaderService 

func NewEventReaderService(cfg *config.CGRConfig, filterSChan chan *engine.FilterS,
	exitChan chan bool, connMgr *engine.ConnManager) servmanager.Service

NewEventReaderService returns the EventReader Service

func NewFreeswitchAgent 

func NewFreeswitchAgent(cfg *config.CGRConfig,
	exitChan chan bool, connMgr *engine.ConnManager) servmanager.Service

NewFreeswitchAgent returns the Freeswitch Agent

func NewHTTPAgent 

func NewHTTPAgent(cfg *config.CGRConfig, filterSChan chan *engine.FilterS,
	server *utils.Server, connMgr *engine.ConnManager) servmanager.Service

NewHTTPAgent returns the HTTP Agent

func NewKamailioAgent 

func NewKamailioAgent(cfg *config.CGRConfig,
	exitChan chan bool, connMgr *engine.ConnManager) servmanager.Service

NewKamailioAgent returns the Kamailio Agent

func NewLoaderService 

func NewLoaderService(cfg *config.CGRConfig, dm *DataDBService,
	filterSChan chan *engine.FilterS, server *utils.Server,
	exitChan chan bool, internalLoaderSChan chan birpc.ClientConnector,
	connMgr *engine.ConnManager) servmanager.Service

NewLoaderService returns the Loader Service

func NewRadiusAgent 

func NewRadiusAgent(cfg *config.CGRConfig, filterSChan chan *engine.FilterS,
	exitChan chan bool, connMgr *engine.ConnManager) servmanager.Service

NewRadiusAgent returns the Radius Agent

func NewResourceService 

func NewResourceService(cfg *config.CGRConfig, dm *DataDBService,
	cacheS *engine.CacheS, filterSChan chan *engine.FilterS,
	server *utils.Server, internalResourceSChan chan birpc.ClientConnector,
	connMgr *engine.ConnManager) servmanager.Service

NewResourceService returns the Resource Service

func NewSessionService 

func NewSessionService(cfg *config.CGRConfig, dm *DataDBService,
	server *utils.Server, internalChan chan birpc.ClientConnector,
	exitChan chan bool, connMgr *engine.ConnManager) servmanager.Service

NewSessionService returns the Session Service

func NewStatService 

func NewStatService(cfg *config.CGRConfig, dm *DataDBService,
	cacheS *engine.CacheS, filterSChan chan *engine.FilterS,
	server *utils.Server, internalStatSChan chan birpc.ClientConnector, connMgr *engine.ConnManager) servmanager.Service

NewStatService returns the Stat Service

func NewSupplierService 

func NewSupplierService(cfg *config.CGRConfig, dm *DataDBService,
	cacheS *engine.CacheS, filterSChan chan *engine.FilterS,
	server *utils.Server, internalSupplierSChan chan birpc.ClientConnector,
	connMgr *engine.ConnManager) servmanager.Service

NewSupplierService returns the Supplier Service

func NewThresholdService 

func NewThresholdService(cfg *config.CGRConfig, dm *DataDBService,
	cacheS *engine.CacheS, filterSChan chan *engine.FilterS,
	server *utils.Server, internalThresholdSChan chan birpc.ClientConnector) servmanager.Service

NewThresholdService returns the Threshold Service

Types

type APIerSv1Service 

type APIerSv1Service struct {
	sync.RWMutex

	APIerSv1Chan chan *v1.APIerSv1
	// contains filtered or unexported fields
}

APIerSv1Service implements Service interface

func NewAPIerSv1Service 

func NewAPIerSv1Service(cfg *config.CGRConfig, dm *DataDBService,
	storDB *StorDBService, filterSChan chan *engine.FilterS,
	server *utils.Server,
	schedService *SchedulerService,
	responderService *ResponderService,
	internalAPIerSv1Chan chan birpc.ClientConnector,
	connMgr *engine.ConnManager) *APIerSv1Service

NewAPIerSv1Service returns the APIerSv1 Service

func (*APIerSv1Service) GetAPIerSv1 

func (apiService *APIerSv1Service) GetAPIerSv1() *v1.APIerSv1

GetAPIerSv1 returns the APIerSv1

func (*APIerSv1Service) GetAPIerSv1Chan 

func (apiService *APIerSv1Service) GetAPIerSv1Chan() chan *v1.APIerSv1

GetDMChan returns the DataManager chanel

func (*APIerSv1Service) IsRunning 

func (apiService *APIerSv1Service) IsRunning() bool

IsRunning returns if the service is running

func (*APIerSv1Service) Reload 

func (apiService *APIerSv1Service) Reload() (err error)

Reload handles the change of config

func (*APIerSv1Service) ServiceName 

func (apiService *APIerSv1Service) ServiceName() string

ServiceName returns the service name

func (*APIerSv1Service) ShouldRun 

func (apiService *APIerSv1Service) ShouldRun() bool

ShouldRun returns if the service should be running

func (*APIerSv1Service) Shutdown 

func (apiService *APIerSv1Service) Shutdown() (err error)

Shutdown stops the service

func (*APIerSv1Service) Start 

func (apiService *APIerSv1Service) Start() (err error)

Start should handle the sercive start For this service the start should be called from RAL Service

type APIerSv2Service 

type APIerSv2Service struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

APIerSv2Service implements Service interface

func NewAPIerSv2Service 

func NewAPIerSv2Service(apiv1 *APIerSv1Service, cfg *config.CGRConfig,
	server *utils.Server,
	internalAPIerSv2Chan chan birpc.ClientConnector) *APIerSv2Service

NewAPIerSv2Service returns the APIerSv2 Service

func (*APIerSv2Service) IsRunning 

func (api *APIerSv2Service) IsRunning() bool

IsRunning returns if the service is running

func (*APIerSv2Service) Reload 

func (api *APIerSv2Service) Reload() (err error)

Reload handles the change of config

func (*APIerSv2Service) ServiceName 

func (api *APIerSv2Service) ServiceName() string

ServiceName returns the service name

func (*APIerSv2Service) ShouldRun 

func (api *APIerSv2Service) ShouldRun() bool

ShouldRun returns if the service should be running

func (*APIerSv2Service) Shutdown 

func (api *APIerSv2Service) Shutdown() (err error)

Shutdown stops the service

func (*APIerSv2Service) Start 

func (api *APIerSv2Service) Start() (err error)

Start should handle the sercive start For this service the start should be called from RAL Service

type AnalyzerService 

type AnalyzerService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

AnalyzerService implements Service interface

func (*AnalyzerService) IsRunning 

func (anz *AnalyzerService) IsRunning() bool

IsRunning returns if the service is running

func (*AnalyzerService) Reload 

func (anz *AnalyzerService) Reload() (err error)

Reload handles the change of config

func (*AnalyzerService) ServiceName 

func (anz *AnalyzerService) ServiceName() string

ServiceName returns the service name

func (*AnalyzerService) ShouldRun 

func (anz *AnalyzerService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*AnalyzerService) Shutdown 

func (anz *AnalyzerService) Shutdown() (err error)

Shutdown stops the service

func (*AnalyzerService) Start 

func (anz *AnalyzerService) Start() (err error)

Start should handle the sercive start

type AsteriskAgent 

type AsteriskAgent struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

AsteriskAgent implements Agent interface

func (*AsteriskAgent) IsRunning 

func (ast *AsteriskAgent) IsRunning() bool

IsRunning returns if the service is running

func (*AsteriskAgent) Reload 

func (ast *AsteriskAgent) Reload() (err error)

Reload handles the change of config

func (*AsteriskAgent) ServiceName 

func (ast *AsteriskAgent) ServiceName() string

ServiceName returns the service name

func (*AsteriskAgent) ShouldRun 

func (ast *AsteriskAgent) ShouldRun() bool

ShouldRun returns if the service should be running

func (*AsteriskAgent) Shutdown 

func (ast *AsteriskAgent) Shutdown() (err error)

Shutdown stops the service

func (*AsteriskAgent) Start 

func (ast *AsteriskAgent) Start() (err error)

Start should handle the sercive start

type AttributeService 

type AttributeService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

AttributeService implements Service interface

func (*AttributeService) IsRunning 

func (attrS *AttributeService) IsRunning() bool

IsRunning returns if the service is running

func (*AttributeService) Reload 

func (attrS *AttributeService) Reload() (err error)

Reload handles the change of config

func (*AttributeService) ServiceName 

func (attrS *AttributeService) ServiceName() string

ServiceName returns the service name

func (*AttributeService) ShouldRun 

func (attrS *AttributeService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*AttributeService) Shutdown 

func (attrS *AttributeService) Shutdown() (err error)

Shutdown stops the service

func (*AttributeService) Start 

func (attrS *AttributeService) Start() (err error)

Start should handle the sercive start

type CDRServer 

type CDRServer struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

CDRServer implements Service interface

func (*CDRServer) IsRunning 

func (cdrService *CDRServer) IsRunning() bool

IsRunning returns if the service is running

func (*CDRServer) Reload 

func (cdrService *CDRServer) Reload() (err error)

Reload handles the change of config

func (*CDRServer) ServiceName 

func (cdrService *CDRServer) ServiceName() string

ServiceName returns the service name

func (*CDRServer) ShouldRun 

func (cdrService *CDRServer) ShouldRun() bool

ShouldRun returns if the service should be running

func (*CDRServer) Shutdown 

func (cdrService *CDRServer) Shutdown() (err error)

Shutdown stops the service

func (*CDRServer) Start 

func (cdrService *CDRServer) Start() (err error)

Start should handle the sercive start

type ChargerService 

type ChargerService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

ChargerService implements Service interface

func (*ChargerService) IsRunning 

func (chrS *ChargerService) IsRunning() bool

IsRunning returns if the service is running

func (*ChargerService) Reload 

func (chrS *ChargerService) Reload() (err error)

Reload handles the change of config

func (*ChargerService) ServiceName 

func (chrS *ChargerService) ServiceName() string

ServiceName returns the service name

func (*ChargerService) ShouldRun 

func (chrS *ChargerService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*ChargerService) Shutdown 

func (chrS *ChargerService) Shutdown() (err error)

Shutdown stops the service

func (*ChargerService) Start 

func (chrS *ChargerService) Start() (err error)

Start should handle the sercive start

type DNSAgent 

type DNSAgent struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

DNSAgent implements Agent interface

func (*DNSAgent) IsRunning 

func (dns *DNSAgent) IsRunning() bool

IsRunning returns if the service is running

func (*DNSAgent) Reload 

func (dns *DNSAgent) Reload() (err error)

Reload handles the change of config

func (*DNSAgent) ServiceName 

func (dns *DNSAgent) ServiceName() string

ServiceName returns the service name

func (*DNSAgent) ShouldRun 

func (dns *DNSAgent) ShouldRun() bool

ShouldRun returns if the service should be running

func (*DNSAgent) Shutdown 

func (dns *DNSAgent) Shutdown() (err error)

Shutdown stops the service

func (*DNSAgent) Start 

func (dns *DNSAgent) Start() (err error)

Start should handle the sercive start

type DataDBService 

type DataDBService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

DataDBService implements Service interface

func NewDataDBService 

func NewDataDBService(cfg *config.CGRConfig, connMgr *engine.ConnManager) *DataDBService

NewDataDBService returns the DataDB Service

func (*DataDBService) GetDM 

func (db *DataDBService) GetDM() *engine.DataManager

GetDM returns the DataManager

func (*DataDBService) GetDMChan 

func (db *DataDBService) GetDMChan() chan *engine.DataManager

GetDMChan returns the DataManager chanel

func (*DataDBService) IsRunning 

func (db *DataDBService) IsRunning() bool

IsRunning returns if the service is running

func (*DataDBService) Reload 

func (db *DataDBService) Reload() (err error)

Reload handles the change of config

func (*DataDBService) ServiceName 

func (db *DataDBService) ServiceName() string

ServiceName returns the service name

func (*DataDBService) ShouldRun 

func (db *DataDBService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*DataDBService) Shutdown 

func (db *DataDBService) Shutdown() (err error)

Shutdown stops the service

func (*DataDBService) Start 

func (db *DataDBService) Start() (err error)

Start should handle the sercive start

type DiameterAgent 

type DiameterAgent struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

DiameterAgent implements Agent interface

func (*DiameterAgent) IsRunning 

func (da *DiameterAgent) IsRunning() bool

IsRunning returns if the service is running

func (*DiameterAgent) Reload 

func (da *DiameterAgent) Reload() (err error)

Reload handles the change of config

func (*DiameterAgent) ServiceName 

func (da *DiameterAgent) ServiceName() string

ServiceName returns the service name

func (*DiameterAgent) ShouldRun 

func (da *DiameterAgent) ShouldRun() bool

ShouldRun returns if the service should be running

func (*DiameterAgent) Shutdown 

func (da *DiameterAgent) Shutdown() (err error)

Shutdown stops the service

func (*DiameterAgent) Start 

func (da *DiameterAgent) Start() (err error)

Start should handle the sercive start

type DispatcherService 

type DispatcherService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

DispatcherService implements Service interface

func (*DispatcherService) IsRunning 

func (dspS *DispatcherService) IsRunning() bool

IsRunning returns if the service is running

func (*DispatcherService) Reload 

func (dspS *DispatcherService) Reload() (err error)

Reload handles the change of config

func (*DispatcherService) ServiceName 

func (dspS *DispatcherService) ServiceName() string

ServiceName returns the service name

func (*DispatcherService) ShouldRun 

func (dspS *DispatcherService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*DispatcherService) Shutdown 

func (dspS *DispatcherService) Shutdown() (err error)

Shutdown stops the service

func (*DispatcherService) Start 

func (dspS *DispatcherService) Start() (err error)

Start should handle the sercive start

type EventReaderService 

type EventReaderService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

EventReaderService implements Service interface

func (*EventReaderService) IsRunning 

func (erS *EventReaderService) IsRunning() bool

IsRunning returns if the service is running

func (*EventReaderService) Reload 

func (erS *EventReaderService) Reload() (err error)

Reload handles the change of config

func (*EventReaderService) ServiceName 

func (erS *EventReaderService) ServiceName() string

ServiceName returns the service name

func (*EventReaderService) ShouldRun 

func (erS *EventReaderService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*EventReaderService) Shutdown 

func (erS *EventReaderService) Shutdown() (err error)

Shutdown stops the service

func (*EventReaderService) Start 

func (erS *EventReaderService) Start() (err error)

Start should handle the sercive start

type FreeswitchAgent 

type FreeswitchAgent struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

FreeswitchAgent implements Agent interface

func (*FreeswitchAgent) IsRunning 

func (fS *FreeswitchAgent) IsRunning() bool

IsRunning returns if the service is running

func (*FreeswitchAgent) Reload 

func (fS *FreeswitchAgent) Reload() (err error)

Reload handles the change of config

func (*FreeswitchAgent) ServiceName 

func (fS *FreeswitchAgent) ServiceName() string

ServiceName returns the service name

func (*FreeswitchAgent) ShouldRun 

func (fS *FreeswitchAgent) ShouldRun() bool

ShouldRun returns if the service should be running

func (*FreeswitchAgent) Shutdown 

func (fS *FreeswitchAgent) Shutdown() (err error)

Shutdown stops the service

func (*FreeswitchAgent) Start 

func (fS *FreeswitchAgent) Start() (err error)

Start should handle the sercive start

type HTTPAgent 

type HTTPAgent struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

HTTPAgent implements Agent interface

func (*HTTPAgent) IsRunning 

func (ha *HTTPAgent) IsRunning() bool

IsRunning returns if the service is running

func (*HTTPAgent) Reload 

func (ha *HTTPAgent) Reload() (err error)

Reload handles the change of config

func (*HTTPAgent) ServiceName 

func (ha *HTTPAgent) ServiceName() string

ServiceName returns the service name

func (*HTTPAgent) ShouldRun 

func (ha *HTTPAgent) ShouldRun() bool

ShouldRun returns if the service should be running

func (*HTTPAgent) Shutdown 

func (ha *HTTPAgent) Shutdown() (err error)

Shutdown stops the service

func (*HTTPAgent) Start 

func (ha *HTTPAgent) Start() (err error)

Start should handle the sercive start

type KamailioAgent 

type KamailioAgent struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

KamailioAgent implements Agent interface

func (*KamailioAgent) IsRunning 

func (kam *KamailioAgent) IsRunning() bool

IsRunning returns if the service is running

func (*KamailioAgent) Reload 

func (kam *KamailioAgent) Reload() (err error)

Reload handles the change of config

func (*KamailioAgent) ServiceName 

func (kam *KamailioAgent) ServiceName() string

ServiceName returns the service name

func (*KamailioAgent) ShouldRun 

func (kam *KamailioAgent) ShouldRun() bool

ShouldRun returns if the service should be running

func (*KamailioAgent) Shutdown 

func (kam *KamailioAgent) Shutdown() (err error)

Shutdown stops the service

func (*KamailioAgent) Start 

func (kam *KamailioAgent) Start() (err error)

Start should handle the sercive start

type LoaderService 

type LoaderService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

LoaderService implements Service interface

func (*LoaderService) IsRunning 

func (ldrs *LoaderService) IsRunning() bool

IsRunning returns if the service is running

func (*LoaderService) Reload 

func (ldrs *LoaderService) Reload() (err error)

Reload handles the change of config

func (*LoaderService) ServiceName 

func (ldrs *LoaderService) ServiceName() string

ServiceName returns the service name

func (*LoaderService) ShouldRun 

func (ldrs *LoaderService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*LoaderService) Shutdown 

func (ldrs *LoaderService) Shutdown() (err error)

Shutdown stops the service

func (*LoaderService) Start 

func (ldrs *LoaderService) Start() (err error)

Start should handle the sercive start

type RadiusAgent 

type RadiusAgent struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

RadiusAgent implements Agent interface

func (*RadiusAgent) IsRunning 

func (rad *RadiusAgent) IsRunning() bool

IsRunning returns if the service is running

func (*RadiusAgent) Reload 

func (rad *RadiusAgent) Reload() (err error)

Reload handles the change of config

func (*RadiusAgent) ServiceName 

func (rad *RadiusAgent) ServiceName() string

ServiceName returns the service name

func (*RadiusAgent) ShouldRun 

func (rad *RadiusAgent) ShouldRun() bool

ShouldRun returns if the service should be running

func (*RadiusAgent) Shutdown 

func (rad *RadiusAgent) Shutdown() (err error)

Shutdown stops the service

func (*RadiusAgent) Start 

func (rad *RadiusAgent) Start() (err error)

Start should handle the sercive start

type RalService 

type RalService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

RalService implements Service interface

func NewRalService 

func NewRalService(cfg *config.CGRConfig, cacheS *engine.CacheS, server *utils.Server,
	internalRALsChan, internalResponderChan chan birpc.ClientConnector, exitChan chan bool,
	connMgr *engine.ConnManager) *RalService

NewRalService returns the Ral Service

func (*RalService) GetResponder 

func (rals *RalService) GetResponder() servmanager.Service

GetResponder returns the responder service

func (*RalService) GetResponderService 

func (rals *RalService) GetResponderService() *ResponderService

GetResponder returns the responder service

func (*RalService) IsRunning 

func (rals *RalService) IsRunning() bool

IsRunning returns if the service is running

func (*RalService) Reload 

func (rals *RalService) Reload() (err error)

Reload handles the change of config

func (*RalService) ServiceName 

func (rals *RalService) ServiceName() string

ServiceName returns the service name

func (*RalService) ShouldRun 

func (rals *RalService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*RalService) Shutdown 

func (rals *RalService) Shutdown() (err error)

Shutdown stops the service

func (*RalService) Start 

func (rals *RalService) Start() (err error)

Start should handle the sercive start For this service the start should be called from RAL Service

type ResourceService 

type ResourceService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

ResourceService implements Service interface

func (*ResourceService) IsRunning 

func (reS *ResourceService) IsRunning() bool

IsRunning returns if the service is running

func (*ResourceService) Reload 

func (reS *ResourceService) Reload() (err error)

Reload handles the change of config

func (*ResourceService) ServiceName 

func (reS *ResourceService) ServiceName() string

ServiceName returns the service name

func (*ResourceService) ShouldRun 

func (reS *ResourceService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*ResourceService) Shutdown 

func (reS *ResourceService) Shutdown() (err error)

Shutdown stops the service

func (*ResourceService) Start 

func (reS *ResourceService) Start() (err error)

Start should handle the sercive start

type ResponderService 

type ResponderService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

ResponderService implements Service interface

func NewResponderService 

func NewResponderService(cfg *config.CGRConfig, server *utils.Server,
	internalRALsChan chan birpc.ClientConnector,
	exitChan chan bool) *ResponderService

NewResponderService returns the Resonder Service

func (*ResponderService) GetResponder 

func (resp *ResponderService) GetResponder() *engine.Responder

GetResponder returns the responder created

func (*ResponderService) IsRunning 

func (resp *ResponderService) IsRunning() bool

IsRunning returns if the service is running

func (*ResponderService) Reload 

func (resp *ResponderService) Reload() (err error)

Reload handles the change of config

func (*ResponderService) ServiceName 

func (resp *ResponderService) ServiceName() string

ServiceName returns the service name

func (*ResponderService) ShouldRun 

func (resp *ResponderService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*ResponderService) Shutdown 

func (resp *ResponderService) Shutdown() (err error)

Shutdown stops the service

func (*ResponderService) Start 

func (resp *ResponderService) Start() (err error)

Start should handle the sercive start For this service the start should be called from RAL Service

type SchedulerService 

type SchedulerService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

SchedulerService implements Service interface

func NewSchedulerService 

func NewSchedulerService(cfg *config.CGRConfig, dm *DataDBService,
	cacheS *engine.CacheS, fltrSChan chan *engine.FilterS,
	server *utils.Server, internalSchedulerrSChan chan birpc.ClientConnector,
	connMgr *engine.ConnManager) *SchedulerService

NewSchedulerService returns the Scheduler Service

func (*SchedulerService) GetScheduler 

func (schS *SchedulerService) GetScheduler() *scheduler.Scheduler

GetScheduler returns the Scheduler

func (*SchedulerService) IsRunning 

func (schS *SchedulerService) IsRunning() bool

IsRunning returns if the service is running

func (*SchedulerService) Reload 

func (schS *SchedulerService) Reload() (err error)

Reload handles the change of config

func (*SchedulerService) ServiceName 

func (schS *SchedulerService) ServiceName() string

ServiceName returns the service name

func (*SchedulerService) ShouldRun 

func (schS *SchedulerService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*SchedulerService) Shutdown 

func (schS *SchedulerService) Shutdown() (err error)

Shutdown stops the service

func (*SchedulerService) Start 

func (schS *SchedulerService) Start() (err error)

Start should handle the sercive start

type SessionService 

type SessionService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

SessionService implements Service interface

func (*SessionService) IsRunning 

func (smg *SessionService) IsRunning() bool

IsRunning returns if the service is running

func (*SessionService) Reload 

func (smg *SessionService) Reload() (err error)

Reload handles the change of config

func (*SessionService) ServiceName 

func (smg *SessionService) ServiceName() string

ServiceName returns the service name

func (*SessionService) ShouldRun 

func (smg *SessionService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*SessionService) Shutdown 

func (smg *SessionService) Shutdown() (err error)

Shutdown stops the service

func (*SessionService) Start 

func (smg *SessionService) Start() (err error)

Start should handle the service start

type StatService 

type StatService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

StatService implements Service interface

func (*StatService) IsRunning 

func (sts *StatService) IsRunning() bool

IsRunning returns if the service is running

func (*StatService) Reload 

func (sts *StatService) Reload() (err error)

Reload handles the change of config

func (*StatService) ServiceName 

func (sts *StatService) ServiceName() string

ServiceName returns the service name

func (*StatService) ShouldRun 

func (sts *StatService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*StatService) Shutdown 

func (sts *StatService) Shutdown() (err error)

Shutdown stops the service

func (*StatService) Start 

func (sts *StatService) Start() (err error)

Start should handle the sercive start

type StorDBService 

type StorDBService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

StorDBService implements Service interface

func NewStorDBService 

func NewStorDBService(cfg *config.CGRConfig) *StorDBService

NewStorDBService returns the StorDB Service

func (*StorDBService) IsRunning 

func (db *StorDBService) IsRunning() bool

IsRunning returns if the service is running

func (*StorDBService) RegisterSyncChan 

func (db *StorDBService) RegisterSyncChan(c chan engine.StorDB)

RegisterSyncChan used by dependent subsystems to register a chanel to reload only the storDB(thread safe)

func (*StorDBService) Reload 

func (db *StorDBService) Reload() (err error)

Reload handles the change of config

func (*StorDBService) ServiceName 

func (db *StorDBService) ServiceName() string

ServiceName returns the service name

func (*StorDBService) ShouldRun 

func (db *StorDBService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*StorDBService) Shutdown 

func (db *StorDBService) Shutdown() (err error)

Shutdown stops the service

func (*StorDBService) Start 

func (db *StorDBService) Start() (err error)

Start should handle the sercive start

type SupplierService 

type SupplierService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

SupplierService implements Service interface

func (*SupplierService) IsRunning 

func (splS *SupplierService) IsRunning() bool

IsRunning returns if the service is running

func (*SupplierService) Reload 

func (splS *SupplierService) Reload() (err error)

Reload handles the change of config

func (*SupplierService) ServiceName 

func (splS *SupplierService) ServiceName() string

ServiceName returns the service name

func (*SupplierService) ShouldRun 

func (splS *SupplierService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*SupplierService) Shutdown 

func (splS *SupplierService) Shutdown() (err error)

Shutdown stops the service

func (*SupplierService) Start 

func (splS *SupplierService) Start() (err error)

Start should handle the sercive start

type ThresholdService 

type ThresholdService struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

ThresholdService implements Service interface

func (*ThresholdService) IsRunning 

func (thrs *ThresholdService) IsRunning() bool

IsRunning returns if the service is running

func (*ThresholdService) Reload 

func (thrs *ThresholdService) Reload() (err error)

Reload handles the change of config

func (*ThresholdService) ServiceName 

func (thrs *ThresholdService) ServiceName() string

ServiceName returns the service name

func (*ThresholdService) ShouldRun 

func (thrs *ThresholdService) ShouldRun() bool

ShouldRun returns if the service should be running

func (*ThresholdService) Shutdown 

func (thrs *ThresholdService) Shutdown() (err error)

Shutdown stops the service

func (*ThresholdService) Start 

func (thrs *ThresholdService) Start() (err error)

Start should handle the sercive start

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.