v1

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: 29 Imported by: 16

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetCacheOpt 

func GetCacheOpt(apiOpt *string) string

GetCacheOpt receive the apiOpt and compare with default value overwrite the default if it's present visible in APIerSv2

Types

type APIerSv1 

type APIerSv1 struct {
	StorDb           engine.LoadStorage // we should consider keeping only one of StorDB type
	CdrDb            engine.CdrStorage
	DataManager      *engine.DataManager
	Config           *config.CGRConfig
	Responder        *engine.Responder
	SchedulerService SchedulerGeter  // Need to have them capitalize so we can export in V2
	FilterS          *engine.FilterS //Used for CDR Exporter
	ConnMgr          *engine.ConnManager

	StorDBChan chan engine.StorDB
}

func (*APIerSv1) AddAccountActionTriggers 

func (api *APIerSv1) AddAccountActionTriggers(attr AttrAddAccountActionTriggers, reply *string) (err error)

func (*APIerSv1) AddBalance 

func (api *APIerSv1) AddBalance(attr *AttrAddBalance, reply *string) error

func (*APIerSv1) AddTriggeredAction 

func (api *APIerSv1) AddTriggeredAction(attr AttrAddActionTrigger, reply *string) error

Deprecated in rc8, replaced by AddAccountActionTriggers

func (*APIerSv1) Call 

func (apiv1 *APIerSv1) Call(ctx *context.Context, serviceMethod string,
	args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*APIerSv1) CallCache 

func (apiv1 *APIerSv1) CallCache(tnt, cacheOpt string, args utils.ArgsGetCacheItem) (err error)

CallCache caching the item based on cacheopt visible in APIerSv2

func (*APIerSv1) ComputeAccountActionPlans 

func (apiv1 *APIerSv1) ComputeAccountActionPlans(tnt *utils.TenantWithArgDispatcher, reply *string) (err error)

ComputeAccountActionPlans will rebuild complete reverse accountActions data

func (*APIerSv1) ComputeActionPlanIndexes 

func (apiv1 *APIerSv1) ComputeActionPlanIndexes(_ string, reply *string) (err error)

func (*APIerSv1) ComputeFilterIndexIDs 

func (api *APIerSv1) ComputeFilterIndexIDs(args utils.ArgsComputeFilterIndexIDs, reply *string) (err error)

ComputeFilterIndexIDs computes specific filter indexes

func (*APIerSv1) ComputeFilterIndexes 

func (api *APIerSv1) ComputeFilterIndexes(args utils.ArgsComputeFilterIndexes, reply *string) (err error)

ComputeFilterIndexes selects which index filters to recompute

func (*APIerSv1) ComputeReverseDestinations 

func (apiv1 *APIerSv1) ComputeReverseDestinations(ignr string, reply *string) (err error)

ComputeReverseDestinations will rebuild complete reverse destinations data

func (*APIerSv1) DebitBalance 

func (api *APIerSv1) DebitBalance(attr *AttrAddBalance, reply *string) error

func (*APIerSv1) DebitUsage 

func (apier *APIerSv1) DebitUsage(usageRecord engine.UsageRecordWithArgDispatcher, reply *string) error

DebitUsage will debit the balance for the usage cost, allowing the account to go negative if the cost calculated is greater than the balance

func (*APIerSv1) DebitUsageWithOptions 

func (apier *APIerSv1) DebitUsageWithOptions(args AttrDebitUsageWithOptions, reply *string) error

DebitUsageWithOptions will debit the account based on the usage cost with additional options to control if the balance can go negative

func (*APIerSv1) ExecuteAction 

func (apiv1 *APIerSv1) ExecuteAction(attr *utils.AttrExecuteAction, reply *string) error

func (*APIerSv1) ExecuteScheduledActions 

func (self *APIerSv1) ExecuteScheduledActions(attr AttrsExecuteScheduledActions, reply *string) error

func (*APIerSv1) ExportCDRs 

func (api *APIerSv1) ExportCDRs(arg ArgExportCDRs, reply *RplExportedCDRs) (err error)

ExportCDRs exports CDRs on a path (file or remote)

func (*APIerSv1) ExportCdrsToFile 

func (api *APIerSv1) ExportCdrsToFile(attr utils.AttrExpFileCdrs, reply *utils.ExportedFileCdrs) (err error)

Deprecated by AttrExportCDRsToFile

func (*APIerSv1) ExportCdrsToZipString 

func (api *APIerSv1) ExportCdrsToZipString(attr utils.AttrExpFileCdrs, reply *string) error

func (*APIerSv1) ExportTPToFolder 

func (self *APIerSv1) ExportTPToFolder(attrs utils.AttrDirExportTP, exported *utils.ExportedTPStats) error

func (*APIerSv1) ExportTPToZipString 

func (self *APIerSv1) ExportTPToZipString(attrs utils.AttrDirExportTP, reply *string) error

func (*APIerSv1) GetAccount 

func (api *APIerSv1) GetAccount(attr *utils.AttrGetAccount, reply *any) error

GetAccount returns the account

func (*APIerSv1) GetAccountActionPlan 

func (api *APIerSv1) GetAccountActionPlan(attrs utils.TenantAccount, reply *[]*AccountActionTiming) error

func (*APIerSv1) GetAccountActionPlansIndexHealth added in v0.10.3 

func (apierSv1 *APIerSv1) GetAccountActionPlansIndexHealth(args *engine.IndexHealthArgsWith2Ch, reply *engine.AccountActionPlanIHReply) error

func (*APIerSv1) GetAccountActionTriggers 

func (api *APIerSv1) GetAccountActionTriggers(attrs utils.TenantAccount, reply *engine.ActionTriggers) error

Returns a list of ActionTriggers on an account

func (*APIerSv1) GetAccounts 

func (api *APIerSv1) GetAccounts(attr utils.AttrGetAccounts, reply *[]any) error

func (*APIerSv1) GetAccountsCount 

func (api *APIerSv1) GetAccountsCount(attr utils.TenantArg, reply *int) (err error)

func (*APIerSv1) GetActionPlan 

func (apiv1 *APIerSv1) GetActionPlan(attr AttrGetActionPlan, reply *[]*engine.ActionPlan) error

func (*APIerSv1) GetActionPlanIDs 

func (apiv1 *APIerSv1) GetActionPlanIDs(args utils.TenantArgWithPaginator, attrPrfIDs *[]string) error

GetActionPlanIDs returns list of ActionPlan IDs registered for a tenant

func (*APIerSv1) GetActionTriggers 

func (api *APIerSv1) GetActionTriggers(attr AttrGetActionTriggers, atrs *engine.ActionTriggers) error

func (*APIerSv1) GetActions 

func (apiv1 *APIerSv1) GetActions(actsId string, reply *[]*utils.TPAction) error

Retrieves actions attached to specific ActionsId within cache

func (*APIerSv1) GetAttributeProfile 

func (APIerSv1 *APIerSv1) GetAttributeProfile(arg utils.TenantIDWithArgDispatcher, reply *engine.AttributeProfile) error

GetAttributeProfile returns an Attribute Profile

func (*APIerSv1) GetAttributeProfileIDs 

func (APIerSv1 *APIerSv1) GetAttributeProfileIDs(args utils.TenantArgWithPaginator, attrPrfIDs *[]string) error

GetAttributeProfileIDs returns list of attributeProfile IDs registered for a tenant

func (*APIerSv1) GetAttributesIndexesHealth added in v0.10.3 

func (apierSv1 *APIerSv1) GetAttributesIndexesHealth(args *engine.IndexHealthArgsWith3Ch, reply *engine.FilterIHReply) error

func (*APIerSv1) GetCDRs 

func (apier *APIerSv1) GetCDRs(attrs utils.AttrGetCdrs, reply *[]*engine.ExternalCDR) error

Retrieves CDRs based on the filters

func (*APIerSv1) GetChargerProfile 

func (APIerSv1 *APIerSv1) GetChargerProfile(arg *utils.TenantID, reply *engine.ChargerProfile) error

GetChargerProfile returns a Charger Profile

func (*APIerSv1) GetChargerProfileIDs 

func (APIerSv1 *APIerSv1) GetChargerProfileIDs(args *utils.TenantArgWithPaginator, chPrfIDs *[]string) error

GetChargerProfileIDs returns list of chargerProfile IDs registered for a tenant

func (*APIerSv1) GetChargersIndexesHealth added in v0.10.3 

func (apierSv1 *APIerSv1) GetChargersIndexesHealth(args *engine.IndexHealthArgsWith3Ch, reply *engine.FilterIHReply) error

func (*APIerSv1) GetCost 

func (apier *APIerSv1) GetCost(attrs AttrGetCost, ec *engine.EventCost) error

func (*APIerSv1) GetDataCost 

func (apier *APIerSv1) GetDataCost(attrs AttrGetDataCost, reply *engine.DataCost) error

func (*APIerSv1) GetDataDBVersions 

func (self *APIerSv1) GetDataDBVersions(ign string, reply *engine.Versions) error

Queries all versions from dataDB

func (*APIerSv1) GetDestination 

func (apiv1 *APIerSv1) GetDestination(dstId string, reply *engine.Destination) error

func (*APIerSv1) GetDispatcherHost 

func (APIerSv1 *APIerSv1) GetDispatcherHost(arg *utils.TenantID, reply *engine.DispatcherHost) error

GetDispatcherHost returns a Dispatcher Host

func (*APIerSv1) GetDispatcherHostIDs 

func (APIerSv1 *APIerSv1) GetDispatcherHostIDs(tenantArg utils.TenantArgWithPaginator, dPrfIDs *[]string) error

GetDispatcherHostIDs returns list of dispatcherHost IDs registered for a tenant

func (*APIerSv1) GetDispatcherProfile 

func (APIerSv1 *APIerSv1) GetDispatcherProfile(arg *utils.TenantID, reply *engine.DispatcherProfile) error

GetDispatcherProfile returns a Dispatcher Profile

func (*APIerSv1) GetDispatcherProfileIDs 

func (APIerSv1 *APIerSv1) GetDispatcherProfileIDs(tenantArg utils.TenantArgWithPaginator, dPrfIDs *[]string) error

GetDispatcherProfileIDs returns list of dispatcherProfile IDs registered for a tenant

func (*APIerSv1) GetDispatchersIndexesHealth added in v0.10.3 

func (apierSv1 *APIerSv1) GetDispatchersIndexesHealth(args *engine.IndexHealthArgsWith3Ch, reply *engine.FilterIHReply) error

func (*APIerSv1) GetEventCost 

func (apier *APIerSv1) GetEventCost(attrs utils.AttrGetCallCost, reply *engine.EventCost) error

Retrieves the callCost out of CGR logDb

func (*APIerSv1) GetFilter 

func (APIerSv1 *APIerSv1) GetFilter(arg utils.TenantID, reply *engine.Filter) error

GetFilter returns a Filter

func (*APIerSv1) GetFilterIDs 

func (APIerSv1 *APIerSv1) GetFilterIDs(args utils.TenantArgWithPaginator, fltrIDs *[]string) error

GetFilterIDs returns list of Filter IDs registered for a tenant

func (*APIerSv1) GetFilterIndexes 

func (api *APIerSv1) GetFilterIndexes(arg AttrGetFilterIndexes, reply *[]string) (err error)

func (*APIerSv1) GetLoadHistory 

func (apiv1 *APIerSv1) GetLoadHistory(attrs utils.Paginator, reply *[]*utils.LoadInstance) error

func (*APIerSv1) GetLoadIDs 

func (apiv1 *APIerSv1) GetLoadIDs(args string, reply *map[string]int64) (err error)

func (*APIerSv1) GetLoadTimes 

func (apiv1 *APIerSv1) GetLoadTimes(args LoadTimeArgs, reply *map[string]string) (err error)

func (*APIerSv1) GetMaxUsage 

func (self *APIerSv1) GetMaxUsage(usageRecord engine.UsageRecordWithArgDispatcher, maxUsage *int64) error

Returns MaxUsage (for calls in seconds), -1 for no limit

func (*APIerSv1) GetRatingPlan 

func (apiv1 *APIerSv1) GetRatingPlan(rplnId string, reply *engine.RatingPlan) error

func (*APIerSv1) GetRatingPlanIDs 

func (apiv1 *APIerSv1) GetRatingPlanIDs(args utils.TenantArgWithPaginator, attrPrfIDs *[]string) error

GetRatingPlanIDs returns list of RatingPlan IDs registered for a tenant

func (*APIerSv1) GetRatingProfile 

func (apiv1 *APIerSv1) GetRatingProfile(attrs utils.AttrGetRatingProfile, reply *engine.RatingProfile) (err error)

func (*APIerSv1) GetRatingProfileIDs 

func (apiv1 *APIerSv1) GetRatingProfileIDs(args utils.TenantArgWithPaginator, rsPrfIDs *[]string) error

GetRatingProfileIDs returns list of resourceProfile IDs registered for a tenant

func (*APIerSv1) GetResourceProfile 

func (APIerSv1 *APIerSv1) GetResourceProfile(arg utils.TenantID, reply *engine.ResourceProfile) error

GetResourceProfile returns a resource configuration

func (*APIerSv1) GetResourceProfileIDs 

func (APIerSv1 *APIerSv1) GetResourceProfileIDs(args utils.TenantArgWithPaginator, rsPrfIDs *[]string) error

GetResourceProfileIDs returns list of resourceProfile IDs registered for a tenant

func (*APIerSv1) GetResourcesIndexesHealth added in v0.10.3 

func (apierSv1 *APIerSv1) GetResourcesIndexesHealth(args *engine.IndexHealthArgsWith3Ch, reply *engine.FilterIHReply) error

func (*APIerSv1) GetReverseDestination 

func (apiv1 *APIerSv1) GetReverseDestination(prefix string, reply *[]string) (err error)

GetReverseDestination retrieves revese destination list for a prefix

func (*APIerSv1) GetReverseDestinationsIndexHealth added in v0.10.3 

func (apierSv1 *APIerSv1) GetReverseDestinationsIndexHealth(args *engine.IndexHealthArgsWith2Ch, reply *engine.ReverseDestinationsIHReply) error

func (*APIerSv1) GetScheduledActions 

func (self *APIerSv1) GetScheduledActions(args scheduler.ArgsGetScheduledActions, reply *[]*scheduler.ScheduledAction) error

func (*APIerSv1) GetSharedGroup 

func (apiv1 *APIerSv1) GetSharedGroup(sgId string, reply *engine.SharedGroup) error

func (*APIerSv1) GetStatQueueProfile 

func (APIerSv1 *APIerSv1) GetStatQueueProfile(arg *utils.TenantID, reply *engine.StatQueueProfile) (err error)

GetStatQueueProfile returns a StatQueue profile

func (*APIerSv1) GetStatQueueProfileIDs 

func (APIerSv1 *APIerSv1) GetStatQueueProfileIDs(args utils.TenantArgWithPaginator, stsPrfIDs *[]string) error

GetStatQueueProfileIDs returns list of statQueueProfile IDs registered for a tenant

func (*APIerSv1) GetStatsIndexesHealth added in v0.10.3 

func (apierSv1 *APIerSv1) GetStatsIndexesHealth(args *engine.IndexHealthArgsWith3Ch, reply *engine.FilterIHReply) error

func (*APIerSv1) GetStorDBVersions 

func (self *APIerSv1) GetStorDBVersions(ign string, reply *engine.Versions) error

Queries all versions from stordb

func (*APIerSv1) GetSupplierProfile 

func (APIerSv1 *APIerSv1) GetSupplierProfile(arg utils.TenantID, reply *engine.SupplierProfile) error

GetSupplierProfile returns a Supplier configuration

func (*APIerSv1) GetSupplierProfileIDs 

func (APIerSv1 *APIerSv1) GetSupplierProfileIDs(args utils.TenantArgWithPaginator, sppPrfIDs *[]string) error

GetSupplierProfileIDs returns list of supplierProfile IDs registered for a tenant

func (*APIerSv1) GetSuppliersIndexesHealth added in v0.10.3 

func (apierSv1 *APIerSv1) GetSuppliersIndexesHealth(args *engine.IndexHealthArgsWith3Ch, reply *engine.FilterIHReply) error

func (*APIerSv1) GetTPAccountActionIds 

func (self *APIerSv1) GetTPAccountActionIds(attrs AttrGetTPAccountActionIds, reply *[]string) error

Queries DerivedCharges identities on specific tariff plan.

func (*APIerSv1) GetTPAccountActionLoadIds 

func (self *APIerSv1) GetTPAccountActionLoadIds(attrs AttrGetTPAccountActionIds, reply *[]string) error

Queries AccountActions identities on specific tariff plan.

func (*APIerSv1) GetTPAccountActions 

func (self *APIerSv1) GetTPAccountActions(attrs AttrGetTPAccountActions, reply *utils.TPAccountActions) error

Queries specific DerivedCharge on tariff plan

func (*APIerSv1) GetTPAccountActionsByLoadId 

func (self *APIerSv1) GetTPAccountActionsByLoadId(attrs utils.TPAccountActions, reply *[]*utils.TPAccountActions) error

Queries specific AccountActions profile on tariff plan

func (*APIerSv1) GetTPActionIds 

func (self *APIerSv1) GetTPActionIds(attrs AttrGetTPActionIds, reply *[]string) error

Queries Actions identities on specific tariff plan.

func (*APIerSv1) GetTPActionPlan 

func (self *APIerSv1) GetTPActionPlan(attrs AttrGetTPActionPlan, reply *utils.TPActionPlan) error

Queries specific ActionPlan profile on tariff plan

func (*APIerSv1) GetTPActionPlanIds 

func (self *APIerSv1) GetTPActionPlanIds(attrs AttrGetTPActionPlanIds, reply *[]string) error

Queries ActionPlan identities on specific tariff plan.

func (*APIerSv1) GetTPActionTriggerIds 

func (api *APIerSv1) GetTPActionTriggerIds(attrs AttrGetTPActionTriggerIds, reply *[]string) error

GetTPActionTriggerIds queries ActionTriggers identities on specific tariff plan.

func (*APIerSv1) GetTPActionTriggers 

func (api *APIerSv1) GetTPActionTriggers(attrs AttrGetTPActionTriggers, reply *utils.TPActionTriggers) error

GetTPActionTriggers queries specific ActionTriggers profile on tariff plan

func (*APIerSv1) GetTPActions 

func (self *APIerSv1) GetTPActions(attrs AttrGetTPActions, reply *utils.TPActions) error

Queries specific Actions profile on tariff plan

func (*APIerSv1) GetTPAttributeProfile 

func (api *APIerSv1) GetTPAttributeProfile(attr *utils.TPTntID, reply *utils.TPAttributeProfile) error

GetTPAttributeProfile queries specific AttributeProfile on Tariff plan

func (*APIerSv1) GetTPAttributeProfileIds 

func (api *APIerSv1) GetTPAttributeProfileIds(attrs *AttrGetTPAttributeProfileIds, reply *[]string) error

GetTPAttributeProfileIds queries attribute identities on specific tariff plan.

func (*APIerSv1) GetTPCharger 

func (api *APIerSv1) GetTPCharger(attr *utils.TPTntID, reply *utils.TPChargerProfile) error

GetTPCharger queries specific ChargerProfile on Tariff plan

func (*APIerSv1) GetTPChargerIDs 

func (api *APIerSv1) GetTPChargerIDs(attrs *AttrGetTPChargerIds, reply *[]string) error

GetTPChargerIDs queries Charger identities on specific tariff plan.

func (*APIerSv1) GetTPDestination 

func (self *APIerSv1) GetTPDestination(attrs AttrGetTPDestination, reply *utils.TPDestination) error

Queries a specific destination

func (*APIerSv1) GetTPDestinationIDs 

func (self *APIerSv1) GetTPDestinationIDs(attrs AttrGetTPDestinationIds, reply *[]string) error

Queries destination identities on specific tariff plan.

func (*APIerSv1) GetTPDestinationRate 

func (self *APIerSv1) GetTPDestinationRate(attrs AttrGetTPDestinationRate, reply *utils.TPDestinationRate) error

Queries specific DestinationRate profile on tariff plan

func (*APIerSv1) GetTPDestinationRateIds 

func (self *APIerSv1) GetTPDestinationRateIds(attrs AttrGetTPRateIds, reply *[]string) error

Queries DestinationRate identities on specific tariff plan.

func (*APIerSv1) GetTPDispatcherHost 

func (api *APIerSv1) GetTPDispatcherHost(attr *utils.TPTntID, reply *utils.TPDispatcherHost) error

GetTPDispatcherHost queries specific DispatcherHosts on Tariff plan

func (*APIerSv1) GetTPDispatcherHostIDs 

func (api *APIerSv1) GetTPDispatcherHostIDs(attrs *AttrGetTPDispatcherIds, reply *[]string) error

GetTPDispatcherHostIDs queries dispatcher host identities on specific tariff plan.

func (*APIerSv1) GetTPDispatcherProfile 

func (api *APIerSv1) GetTPDispatcherProfile(attr *utils.TPTntID, reply *utils.TPDispatcherProfile) error

GetTPDispatcherProfile queries specific DispatcherProfile on Tariff plan

func (*APIerSv1) GetTPDispatcherProfileIDs 

func (api *APIerSv1) GetTPDispatcherProfileIDs(attrs *AttrGetTPDispatcherIds, reply *[]string) error

GetTPDispatcherProfileIDs queries dispatcher identities on specific tariff plan.

func (*APIerSv1) GetTPFilterProfile 

func (api *APIerSv1) GetTPFilterProfile(attr *utils.TPTntID, reply *utils.TPFilterProfile) error

GetTPFilterProfile queries specific FilterProfile on tariff plan

func (*APIerSv1) GetTPFilterProfileIds 

func (api *APIerSv1) GetTPFilterProfileIds(attrs *AttrGetTPFilterProfileIds, reply *[]string) error

GetTPFilterProfileIds queries FilterProfile identities on specific tariff plan.

func (*APIerSv1) GetTPIds 

func (self *APIerSv1) GetTPIds(attrs AttrGetTPIds, reply *[]string) error

Queries tarrif plan identities gathered from all tables.

func (*APIerSv1) GetTPRate 

func (self *APIerSv1) GetTPRate(attrs AttrGetTPRate, reply *utils.TPRate) error

Queries specific Rate on tariff plan

func (*APIerSv1) GetTPRateIds 

func (self *APIerSv1) GetTPRateIds(attrs AttrGetTPRateIds, reply *[]string) error

Queries rate identities on specific tariff plan.

func (*APIerSv1) GetTPRatingPlan 

func (self *APIerSv1) GetTPRatingPlan(attrs AttrGetTPRatingPlan, reply *utils.TPRatingPlan) error

Queries specific RatingPlan profile on tariff plan

func (*APIerSv1) GetTPRatingPlanIds 

func (self *APIerSv1) GetTPRatingPlanIds(attrs AttrGetTPRatingPlanIds, reply *[]string) error

Queries RatingPlan identities on specific tariff plan.

func (*APIerSv1) GetTPRatingProfile 

func (api *APIerSv1) GetTPRatingProfile(attrs AttrGetTPRatingProfile, reply *utils.TPRatingProfile) error

GetTPRatingProfile queries specific RatingProfile on tariff plan

func (*APIerSv1) GetTPRatingProfileIds 

func (api *APIerSv1) GetTPRatingProfileIds(attrs AttrGetTPRatingProfileIds, reply *[]string) error

GetTPRatingProfileIds queries RatingProfiles identities on specific tariff plan.

func (*APIerSv1) GetTPRatingProfileLoadIds 

func (api *APIerSv1) GetTPRatingProfileLoadIds(attrs utils.AttrTPRatingProfileIds, reply *[]string) error

GetTPRatingProfileLoadIds queries RatingProfile identities on specific tariff plan.

func (*APIerSv1) GetTPRatingProfilesByLoadID 

func (api *APIerSv1) GetTPRatingProfilesByLoadID(attrs utils.TPRatingProfile, reply *[]*utils.TPRatingProfile) error

GetTPRatingProfilesByLoadID queries specific RatingProfile on tariff plan

func (*APIerSv1) GetTPResource 

func (self *APIerSv1) GetTPResource(attr *utils.TPTntID, reply *utils.TPResourceProfile) error

Queries specific Resource on Tariff plan

func (*APIerSv1) GetTPResourceIDs 

func (self *APIerSv1) GetTPResourceIDs(attrs *AttrGetTPResourceIds, reply *[]string) error

Queries Resource identities on specific tariff plan.

func (*APIerSv1) GetTPSharedGroupIds 

func (self *APIerSv1) GetTPSharedGroupIds(attrs AttrGetTPSharedGroupIds, reply *[]string) error

Queries SharedGroups identities on specific tariff plan.

func (*APIerSv1) GetTPSharedGroups 

func (self *APIerSv1) GetTPSharedGroups(attrs AttrGetTPSharedGroups, reply *utils.TPSharedGroups) error

Queries specific SharedGroup on tariff plan

func (*APIerSv1) GetTPStat 

func (self *APIerSv1) GetTPStat(attr *utils.TPTntID, reply *utils.TPStatProfile) error

Queries specific Stat on Tariff plan

func (*APIerSv1) GetTPStatIDs 

func (self *APIerSv1) GetTPStatIDs(attrs *AttrGetTPStatIds, reply *[]string) error

Queries Stat identities on specific tariff plan.

func (*APIerSv1) GetTPSupplierProfile 

func (api *APIerSv1) GetTPSupplierProfile(attr *utils.TPTntID, reply *utils.TPSupplierProfile) error

GetTPSupplierProfile queries specific SupplierProfile on tariff plan

func (*APIerSv1) GetTPSupplierProfileIDs 

func (api *APIerSv1) GetTPSupplierProfileIDs(attrs *AttrGetTPSupplierProfileIDs, reply *[]string) error

GetTPSupplierProfileIDs queries SupplierProfile identities on specific tariff plan.

func (*APIerSv1) GetTPThreshold 

func (api *APIerSv1) GetTPThreshold(attr *utils.TPTntID, reply *utils.TPThresholdProfile) error

GetTPThreshold queries specific Threshold on Tariff plan

func (*APIerSv1) GetTPThresholdIDs 

func (api *APIerSv1) GetTPThresholdIDs(attrs *AttrGetTPThresholdIds, reply *[]string) error

GetTPThresholdIDs queries Threshold identities on specific tariff plan.

func (*APIerSv1) GetTPTiming 

func (self *APIerSv1) GetTPTiming(attrs AttrGetTPTiming, reply *utils.ApierTPTiming) error

Queries specific Timing on Tariff plan

func (*APIerSv1) GetTPTimingIds 

func (self *APIerSv1) GetTPTimingIds(attrs AttrGetTPTimingIds, reply *[]string) error

Queries timing identities on specific tariff plan.

func (*APIerSv1) GetThresholdProfile 

func (APIerSv1 *APIerSv1) GetThresholdProfile(arg *utils.TenantID, reply *engine.ThresholdProfile) (err error)

GetThresholdProfile returns a Threshold Profile

func (*APIerSv1) GetThresholdProfileIDs 

func (APIerSv1 *APIerSv1) GetThresholdProfileIDs(args utils.TenantArgWithPaginator, thPrfIDs *[]string) error

GetThresholdProfileIDs returns list of thresholdProfile IDs registered for a tenant

func (*APIerSv1) GetThresholdsIndexesHealth added in v0.10.3 

func (apierSv1 *APIerSv1) GetThresholdsIndexesHealth(args *engine.IndexHealthArgsWith3Ch, reply *engine.FilterIHReply) error

func (*APIerSv1) ImportTPZipFile 

func (self *APIerSv1) ImportTPZipFile(attrs AttrImportTPZipFile, reply *string) error

func (*APIerSv1) ImportTariffPlanFromFolder 

func (apiv1 *APIerSv1) ImportTariffPlanFromFolder(attrs utils.AttrImportTPFromFolder, reply *string) error

func (*APIerSv1) ListenAndServe 

func (apiv1 *APIerSv1) ListenAndServe(stopChan chan struct{}) (err error)

ListenAndServe listen for storbd reload

func (*APIerSv1) LoadAccountActions 

func (apiv1 *APIerSv1) LoadAccountActions(attrs utils.TPAccountActions, reply *string) error

Process dependencies and load a specific AccountActions profile from storDb into dataDb.

func (*APIerSv1) LoadDestination 

func (apiv1 *APIerSv1) LoadDestination(attrs AttrLoadDestination, reply *string) error

Load destinations from storDb into dataDb.

func (*APIerSv1) LoadRatingPlan 

func (apiv1 *APIerSv1) LoadRatingPlan(attrs AttrLoadRatingPlan, reply *string) error

Process dependencies and load a specific rating plan from storDb into dataDb.

func (*APIerSv1) LoadRatingProfile 

func (apiv1 *APIerSv1) LoadRatingProfile(attrs utils.TPRatingProfile, reply *string) error

Process dependencies and load a specific rating profile from storDb into dataDb.

func (*APIerSv1) LoadSharedGroup 

func (apiv1 *APIerSv1) LoadSharedGroup(attrs AttrLoadSharedGroup, reply *string) error

Load destinations from storDb into dataDb.

func (*APIerSv1) LoadTariffPlanFromFolder 

func (apiv1 *APIerSv1) LoadTariffPlanFromFolder(attrs utils.AttrLoadTpFromFolder, reply *string) error

func (*APIerSv1) LoadTariffPlanFromStorDb 

func (apiv1 *APIerSv1) LoadTariffPlanFromStorDb(attrs AttrLoadTpFromStorDb, reply *string) error

Loads complete data in a TP from storDb

func (*APIerSv1) Ping 

func (apiv1 *APIerSv1) Ping(ign *utils.CGREvent, reply *string) error

Ping return pong if the service is active

func (*APIerSv1) ReloadCdreConfig 

func (apier *APIerSv1) ReloadCdreConfig(attrs ConfigPathArg, reply *string) error

Reloads CDRE configuration out of folder specified

func (*APIerSv1) RemTP 

func (self *APIerSv1) RemTP(attrs AttrRemTp, reply *string) error

func (*APIerSv1) RemoveAccount 

func (api *APIerSv1) RemoveAccount(attr utils.AttrRemoveAccount, reply *string) (err error)

func (*APIerSv1) RemoveAccountActionTriggers 

func (api *APIerSv1) RemoveAccountActionTriggers(attr AttrRemoveAccountActionTriggers, reply *string) error

func (*APIerSv1) RemoveActionPlan 

func (apiv1 *APIerSv1) RemoveActionPlan(attr AttrGetActionPlan, reply *string) (err error)

func (*APIerSv1) RemoveActionTiming 

func (api *APIerSv1) RemoveActionTiming(attrs AttrRemoveActionTiming, reply *string) (err error)

Removes an ActionTimings or parts of it depending on filters being set

func (*APIerSv1) RemoveActionTrigger 

func (api *APIerSv1) RemoveActionTrigger(attr AttrRemoveActionTrigger, reply *string) error

func (*APIerSv1) RemoveActions 

func (apiv1 *APIerSv1) RemoveActions(attr AttrRemoveActions, reply *string) error

func (*APIerSv1) RemoveAttributeProfile 

func (APIerSv1 *APIerSv1) RemoveAttributeProfile(arg *utils.TenantIDWithCache, reply *string) error

RemoveAttributeProfile remove a specific Attribute Profile

func (*APIerSv1) RemoveBalances 

func (api *APIerSv1) RemoveBalances(attr *utils.AttrSetBalance, reply *string) (err error)

RemoveBalances remove the matching balances for the account

func (*APIerSv1) RemoveCDRs 

func (apier *APIerSv1) RemoveCDRs(attrs utils.RPCCDRsFilter, reply *string) error

New way of removing CDRs

func (*APIerSv1) RemoveChargerProfile 

func (APIerSv1 *APIerSv1) RemoveChargerProfile(arg *utils.TenantIDWithCache, reply *string) error

RemoveChargerProfile remove a specific Charger Profile

func (*APIerSv1) RemoveDestination 

func (apiv1 *APIerSv1) RemoveDestination(attr AttrRemoveDestination, reply *string) (err error)

func (*APIerSv1) RemoveDispatcherHost 

func (APIerSv1 *APIerSv1) RemoveDispatcherHost(arg *utils.TenantIDWithCache, reply *string) error

RemoveDispatcherHost remove a specific Dispatcher Host

func (*APIerSv1) RemoveDispatcherProfile 

func (APIerSv1 *APIerSv1) RemoveDispatcherProfile(arg *utils.TenantIDWithCache, reply *string) error

RemoveDispatcherProfile remove a specific Dispatcher Profile

func (*APIerSv1) RemoveFilter 

func (APIerSv1 *APIerSv1) RemoveFilter(arg utils.TenantIDWithCache, reply *string) error

RemoveFilter remove a specific filter

func (*APIerSv1) RemoveFilterIndexes 

func (api *APIerSv1) RemoveFilterIndexes(arg AttrRemFilterIndexes, reply *string) (err error)

func (*APIerSv1) RemoveRatingPlan 

func (apiv1 *APIerSv1) RemoveRatingPlan(ID string, reply *string) error

func (*APIerSv1) RemoveRatingProfile 

func (apiv1 *APIerSv1) RemoveRatingProfile(attr AttrRemoveRatingProfile, reply *string) error

func (*APIerSv1) RemoveResourceProfile 

func (APIerSv1 *APIerSv1) RemoveResourceProfile(arg utils.TenantIDWithCache, reply *string) error

RemoveResourceProfile remove a specific resource configuration

func (*APIerSv1) RemoveStatQueueProfile 

func (APIerSv1 *APIerSv1) RemoveStatQueueProfile(args *utils.TenantIDWithCache, reply *string) error

Remove a specific stat configuration

func (*APIerSv1) RemoveSupplierProfile 

func (APIerSv1 *APIerSv1) RemoveSupplierProfile(args *utils.TenantIDWithCache, reply *string) error

RemoveSupplierProfile remove a specific Supplier configuration

func (*APIerSv1) RemoveTPAccountActions 

func (self *APIerSv1) RemoveTPAccountActions(attrs AttrGetTPAccountActions, reply *string) error

Removes specific AccountActions on Tariff plan

func (*APIerSv1) RemoveTPActionPlan 

func (self *APIerSv1) RemoveTPActionPlan(attrs AttrGetTPActionPlan, reply *string) error

Removes specific ActionPlan on Tariff plan

func (*APIerSv1) RemoveTPActionTriggers 

func (api *APIerSv1) RemoveTPActionTriggers(attrs AttrGetTPActionTriggers, reply *string) error

RemoveTPActionTriggers removes specific ActionTriggers on Tariff plan

func (*APIerSv1) RemoveTPActions 

func (self *APIerSv1) RemoveTPActions(attrs AttrGetTPActions, reply *string) error

Removes specific Actions on Tariff plan

func (*APIerSv1) RemoveTPAttributeProfile 

func (api *APIerSv1) RemoveTPAttributeProfile(attrs *utils.TPTntID, reply *string) error

RemoveTPAttributeProfile removes specific AttributeProfile on Tariff plan

func (*APIerSv1) RemoveTPCharger 

func (api *APIerSv1) RemoveTPCharger(attrs *utils.TPTntID, reply *string) error

RemoveTPCharger removes specific ChargerProfile on Tariff plan

func (*APIerSv1) RemoveTPDestination 

func (self *APIerSv1) RemoveTPDestination(attrs AttrGetTPDestination, reply *string) error

Removes specific Destination on Tariff plan

func (*APIerSv1) RemoveTPDestinationRate 

func (self *APIerSv1) RemoveTPDestinationRate(attrs AttrGetTPDestinationRate, reply *string) error

Removes specific DestinationRate on Tariff plan

func (*APIerSv1) RemoveTPDispatcherHost 

func (api *APIerSv1) RemoveTPDispatcherHost(attrs *utils.TPTntID, reply *string) error

RemoveTPDispatcherHost removes specific DispatcherHost on Tariff plan

func (*APIerSv1) RemoveTPDispatcherProfile 

func (api *APIerSv1) RemoveTPDispatcherProfile(attrs *utils.TPTntID, reply *string) error

RemoveTPDispatcherProfile removes specific DispatcherProfile on Tariff plan

func (*APIerSv1) RemoveTPFilterProfile 

func (api *APIerSv1) RemoveTPFilterProfile(attrs *utils.TPTntID, reply *string) error

RemoveTPFilterProfile removes specific FilterProfile on Tariff plan

func (*APIerSv1) RemoveTPFromFolder 

func (apiv1 *APIerSv1) RemoveTPFromFolder(attrs utils.AttrLoadTpFromFolder, reply *string) error

RemoveTPFromFolder will load the tarrifplan from folder into TpReader object and will delete if from database

func (*APIerSv1) RemoveTPFromStorDB 

func (apiv1 *APIerSv1) RemoveTPFromStorDB(attrs AttrLoadTpFromStorDb, reply *string) error

RemoveTPFromStorDB will load the tarrifplan from StorDB into TpReader object and will delete if from database

func (*APIerSv1) RemoveTPRate 

func (self *APIerSv1) RemoveTPRate(attrs AttrGetTPRate, reply *string) error

Removes specific Rate on Tariff plan

func (*APIerSv1) RemoveTPRatingPlan 

func (self *APIerSv1) RemoveTPRatingPlan(attrs AttrGetTPRatingPlan, reply *string) error

Removes specific RatingPlan on Tariff plan

func (*APIerSv1) RemoveTPRatingProfile 

func (api *APIerSv1) RemoveTPRatingProfile(attrs AttrGetTPRatingProfile, reply *string) (err error)

RemoveTPRatingProfile removes specific RatingProfiles on Tariff plan

func (*APIerSv1) RemoveTPResource 

func (self *APIerSv1) RemoveTPResource(attrs *utils.TPTntID, reply *string) error

Removes specific Resource on Tariff plan

func (*APIerSv1) RemoveTPSharedGroups 

func (self *APIerSv1) RemoveTPSharedGroups(attrs AttrGetTPSharedGroups, reply *string) error

Removes specific SharedGroups on Tariff plan

func (*APIerSv1) RemoveTPStat 

func (self *APIerSv1) RemoveTPStat(attrs *utils.TPTntID, reply *string) error

Removes specific Stat on Tariff plan

func (*APIerSv1) RemoveTPSupplierProfile 

func (api *APIerSv1) RemoveTPSupplierProfile(attrs *utils.TPTntID, reply *string) error

RemoveTPSupplierProfile removes specific SupplierProfile on Tariff plan

func (*APIerSv1) RemoveTPThreshold 

func (api *APIerSv1) RemoveTPThreshold(attrs *utils.TPTntID, reply *string) error

RemoveTPThreshold removes specific Threshold on Tariff plan

func (*APIerSv1) RemoveTPTiming 

func (self *APIerSv1) RemoveTPTiming(attrs AttrGetTPTiming, reply *string) error

Removes specific Timing on Tariff plan

func (*APIerSv1) RemoveThresholdProfile 

func (APIerSv1 *APIerSv1) RemoveThresholdProfile(args *utils.TenantIDWithCache, reply *string) error

Remove a specific Threshold Profile

func (*APIerSv1) ReplayFailedPosts 

func (apiv1 *APIerSv1) ReplayFailedPosts(args ArgsReplyFailedPosts, reply *string) (err error)

ReplayFailedPosts will repost failed requests found in the FailedRequestsInDir

func (*APIerSv1) ResetAccountActionTriggers 

func (api *APIerSv1) ResetAccountActionTriggers(attr AttrResetAccountActionTriggers, reply *string) error

func (*APIerSv1) SetAccount 

func (api *APIerSv1) SetAccount(attr utils.AttrSetAccount, reply *string) (err error)

Ads a new account into dataDb. If already defined, returns success.

func (*APIerSv1) SetAccountActionTriggers 

func (api *APIerSv1) SetAccountActionTriggers(attr AttrSetAccountActionTriggers, reply *string) error

SetAccountActionTriggers updates or creates if not present the ActionTrigger for an Account

func (*APIerSv1) SetActionPlan 

func (apiv1 *APIerSv1) SetActionPlan(attrs AttrSetActionPlan, reply *string) (err error)

func (*APIerSv1) SetActionTrigger 

func (api *APIerSv1) SetActionTrigger(attr AttrSetActionTrigger, reply *string) (err error)

SetActionTrigger updates a ActionTrigger

func (*APIerSv1) SetActions 

func (apiv1 *APIerSv1) SetActions(attrs V1AttrSetActions, reply *string) (err error)

func (*APIerSv1) SetAttributeProfile 

func (APIerSv1 *APIerSv1) SetAttributeProfile(alsWrp *AttributeWithCache, reply *string) error

SetAttributeProfile add/update a new Attribute Profile

func (*APIerSv1) SetBalance 

func (api *APIerSv1) SetBalance(attr *utils.AttrSetBalance, reply *string) (err error)

SetBalance sets the balance for the given account if the account is not already created it will create the account also

func (*APIerSv1) SetChargerProfile 

func (APIerSv1 *APIerSv1) SetChargerProfile(arg *ChargerWithCache, reply *string) error

SetChargerProfile add/update a new Charger Profile

func (*APIerSv1) SetDataDBVersions 

func (self *APIerSv1) SetDataDBVersions(arg SetVersionsArg, reply *string) error

Queries all versions from dataDB

func (*APIerSv1) SetDestination 

func (apiv1 *APIerSv1) SetDestination(attrs utils.AttrSetDestination, reply *string) (err error)

func (*APIerSv1) SetDispatcherHost 

func (APIerSv1 *APIerSv1) SetDispatcherHost(args *DispatcherHostWithCache, reply *string) error

SetDispatcherHost add/update a new Dispatcher Host

func (*APIerSv1) SetDispatcherProfile 

func (APIerSv1 *APIerSv1) SetDispatcherProfile(args *DispatcherWithCache, reply *string) error

SetDispatcherProfile add/update a new Dispatcher Profile

func (*APIerSv1) SetFilter 

func (APIerSv1 *APIerSv1) SetFilter(arg *FilterWithCache, reply *string) error

SetFilter add a new Filter

func (*APIerSv1) SetRatingProfile 

func (apiv1 *APIerSv1) SetRatingProfile(attrs utils.AttrSetRatingProfile, reply *string) (err error)

Sets a specific rating profile working with data directly in the DataDB without involving storDb

func (*APIerSv1) SetResourceProfile 

func (APIerSv1 *APIerSv1) SetResourceProfile(arg *ResourceWithCache, reply *string) error

SetResourceProfile adds a new resource configuration

func (*APIerSv1) SetStatQueueProfile 

func (APIerSv1 *APIerSv1) SetStatQueueProfile(arg *engine.StatQueueWithCache, reply *string) error

SetStatQueueProfile alters/creates a StatQueueProfile

func (*APIerSv1) SetStorDBVersions 

func (self *APIerSv1) SetStorDBVersions(arg SetVersionsArg, reply *string) error

Queries all versions from stordb

func (*APIerSv1) SetSupplierProfile 

func (APIerSv1 *APIerSv1) SetSupplierProfile(args *SupplierWithCache, reply *string) error

SetSupplierProfile add a new Supplier configuration

func (*APIerSv1) SetTPAccountActions 

func (self *APIerSv1) SetTPAccountActions(attrs utils.TPAccountActions, reply *string) error

Creates a new AccountActions profile within a tariff plan

func (*APIerSv1) SetTPActionPlan 

func (self *APIerSv1) SetTPActionPlan(attrs utils.TPActionPlan, reply *string) error

Creates a new ActionTimings profile within a tariff plan

func (*APIerSv1) SetTPActionTriggers 

func (api *APIerSv1) SetTPActionTriggers(attrs utils.TPActionTriggers, reply *string) error

SetTPActionTriggers creates a new ActionTriggers profile within a tariff plan

func (*APIerSv1) SetTPActions 

func (self *APIerSv1) SetTPActions(attrs utils.TPActions, reply *string) error

Creates a new Actions profile within a tariff plan

func (*APIerSv1) SetTPAttributeProfile 

func (api *APIerSv1) SetTPAttributeProfile(attrs *utils.TPAttributeProfile, reply *string) error

SetTPAttributeProfile creates a new AttributeProfile within a tariff plan

func (*APIerSv1) SetTPCharger 

func (api *APIerSv1) SetTPCharger(attr *utils.TPChargerProfile, reply *string) error

SetTPCharger creates a new ChargerProfile within a tariff plan

func (*APIerSv1) SetTPDestination 

func (self *APIerSv1) SetTPDestination(attrs utils.TPDestination, reply *string) error

Creates a new destination within a tariff plan

func (*APIerSv1) SetTPDestinationRate 

func (self *APIerSv1) SetTPDestinationRate(attrs utils.TPDestinationRate, reply *string) error

Creates a new DestinationRate profile within a tariff plan

func (*APIerSv1) SetTPDispatcherHost 

func (api *APIerSv1) SetTPDispatcherHost(attr *utils.TPDispatcherHost, reply *string) error

SetTPDispatcherHost creates a new DispatcherHost within a tariff plan

func (*APIerSv1) SetTPDispatcherProfile 

func (api *APIerSv1) SetTPDispatcherProfile(attr *utils.TPDispatcherProfile, reply *string) error

SetTPDispatcherProfile creates a new DispatcherProfile within a tariff plan

func (*APIerSv1) SetTPFilterProfile 

func (api *APIerSv1) SetTPFilterProfile(attrs *utils.TPFilterProfile, reply *string) error

SetTPFilterProfile creates a new FilterProfile within a tariff plan

func (*APIerSv1) SetTPRate 

func (self *APIerSv1) SetTPRate(attrs utils.TPRate, reply *string) error

Creates a new rate within a tariff plan

func (*APIerSv1) SetTPRatingPlan 

func (self *APIerSv1) SetTPRatingPlan(attrs utils.TPRatingPlan, reply *string) error

Creates a new DestinationRateTiming profile within a tariff plan

func (*APIerSv1) SetTPRatingProfile 

func (api *APIerSv1) SetTPRatingProfile(attrs utils.TPRatingProfile, reply *string) error

SetTPRatingProfile creates a new RatingProfile within a tariff plan

func (*APIerSv1) SetTPResource 

func (self *APIerSv1) SetTPResource(attr *utils.TPResourceProfile, reply *string) error

Creates a new resource within a tariff plan

func (*APIerSv1) SetTPSharedGroups 

func (self *APIerSv1) SetTPSharedGroups(attrs utils.TPSharedGroups, reply *string) error

Creates a new SharedGroups profile within a tariff plan

func (*APIerSv1) SetTPStat 

func (self *APIerSv1) SetTPStat(attr *utils.TPStatProfile, reply *string) error

Creates a new stat within a tariff plan

func (*APIerSv1) SetTPSupplierProfile 

func (api *APIerSv1) SetTPSupplierProfile(attrs *utils.TPSupplierProfile, reply *string) error

SetTPSupplierProfile creates a new SupplierProfile within a tariff plan

func (*APIerSv1) SetTPThreshold 

func (api *APIerSv1) SetTPThreshold(attr *utils.TPThresholdProfile, reply *string) error

SetTPThreshold creates a new threshold within a tariff plan

func (*APIerSv1) SetTPTiming 

func (self *APIerSv1) SetTPTiming(attrs utils.ApierTPTiming, reply *string) error

Creates a new timing within a tariff plan

func (*APIerSv1) SetThresholdProfile 

func (APIerSv1 *APIerSv1) SetThresholdProfile(args *engine.ThresholdWithCache, reply *string) error

SetThresholdProfile alters/creates a ThresholdProfile

type AccountActionTiming 

type AccountActionTiming struct {
	ActionPlanId string    // The id of the ActionPlanId profile attached to the account
	Uuid         string    // The id to reference this particular ActionTiming
	ActionsId    string    // The id of actions which will be executed
	NextExecTime time.Time // Next execution time
}

type AnalyzerSv1 

type AnalyzerSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewAnalyzerSv1 

func NewAnalyzerSv1(aS *analyzers.AnalyzerService) *AnalyzerSv1

NewAnalyzerSv1 initializes AnalyzerSv1

func (*AnalyzerSv1) Call 

func (aSv1 *AnalyzerSv1) Call(ctx *context.Context, serviceMethod string,
	args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*AnalyzerSv1) Ping 

func (alSv1 *AnalyzerSv1) Ping(ign *utils.CGREvent, reply *string) error

Ping return pong if the service is active

type ArgExportCDRs 

type ArgExportCDRs struct {
	ExportArgs          map[string]any
	Verbose             bool // Disable CgrIds reporting in reply/ExportedCgrIds and reply/UnexportedCgrIds
	utils.RPCCDRsFilter      // Inherit the CDR filter attributes
}

ArgExportCDRs are the arguments passed to ExportCDRs method

type ArgsReplyFailedPosts 

type ArgsReplyFailedPosts struct {
	FailedRequestsInDir  *string  // if defined it will be our source of requests to be replayed
	FailedRequestsOutDir *string  // if defined it will become our destination for files failing to be replayed, *none to be discarded
	Modules              []string // list of modules for which replay the requests, nil for all
}

type AttrActionPlan 

type AttrActionPlan struct {
	ActionsId string  // Actions id
	Years     string  // semicolon separated list of years this timing is valid on, *any or empty supported
	Months    string  // semicolon separated list of months this timing is valid on, *any or empty supported
	MonthDays string  // semicolon separated list of month's days this timing is valid on, *any or empty supported
	WeekDays  string  // semicolon separated list of week day names this timing is valid on *any or empty supported
	Time      string  // String representing the time this timing starts on, *asap supported
	Weight    float64 // Binding's weight
}

type AttrAddAccountActionTriggers 

type AttrAddAccountActionTriggers struct {
	Tenant                 string
	Account                string
	ActionTriggerIDs       []string
	ActionTriggerOverwrite bool
	ActivationDate         string
	Executed               bool
}

type AttrAddActionTrigger 

type AttrAddActionTrigger struct {
	ActionTriggersId      string
	Tenant                string
	Account               string
	ThresholdType         string
	ThresholdValue        float64
	BalanceId             string
	BalanceType           string
	BalanceDestinationIds string
	BalanceRatingSubject  string
	BalanceWeight         float64
	BalanceExpiryTime     string
	BalanceSharedGroup    string
	Weight                float64
	ActionsId             string
}

type AttrAddBalance 

type AttrAddBalance struct {
	Tenant          string
	Account         string
	BalanceType     string
	Value           float64
	Balance         map[string]any
	ActionExtraData *map[string]any
	Overwrite       bool // When true it will reset if the balance is already there
	Cdrlog          bool
}

type AttrDebitUsageWithOptions 

type AttrDebitUsageWithOptions struct {
	UsageRecord          *engine.UsageRecordWithArgDispatcher
	AllowNegativeAccount bool // allow account to go negative during debit
}

AttrDebitUsageWithOptions represents the DebitUsage request

type AttrGetActionPlan 

type AttrGetActionPlan struct {
	ID string
}

type AttrGetActionTriggers 

type AttrGetActionTriggers struct {
	GroupIDs []string
}

type AttrGetCost 

type AttrGetCost struct {
	Tenant      string
	Category    string
	Subject     string
	AnswerTime  string
	Destination string
	Usage       string
	*utils.ArgDispatcher
}

type AttrGetDataCost 

type AttrGetDataCost struct {
	Tenant     string
	Category   string
	Subject    string
	AnswerTime string
	Usage      time.Duration // the call duration so far (till TimeEnd)
	*utils.ArgDispatcher
}

type AttrGetFilterIndexes 

type AttrGetFilterIndexes struct {
	Tenant      string
	Context     string
	ItemType    string
	FilterType  string
	FilterField string
	FilterValue string
	utils.Paginator
}

type AttrGetTPAccountActionIds 

type AttrGetTPAccountActionIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttrGetTPAccountActions 

type AttrGetTPAccountActions struct {
	TPid             string // Tariff plan id
	AccountActionsId string // DerivedCharge id
}

type AttrGetTPAccountActionsByLoadId 

type AttrGetTPAccountActionsByLoadId struct {
	TPid   string // Tariff plan id
	LoadId string // AccountActions id
}

type AttrGetTPActionIds 

type AttrGetTPActionIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttrGetTPActionPlan 

type AttrGetTPActionPlan struct {
	TPid string // Tariff plan id
	ID   string // ActionPlans id
}

type AttrGetTPActionPlanIds 

type AttrGetTPActionPlanIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttrGetTPActionTriggerIds 

type AttrGetTPActionTriggerIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

AttrGetTPActionTriggerIds used as argument for GetTPActionTriggerIds and RemoveTPActionTriggers

type AttrGetTPActionTriggers 

type AttrGetTPActionTriggers struct {
	TPid string // Tariff plan id
	ID   string // ActionTrigger id
}

AttrGetTPActionTriggers used as argument for GetTPActionTriggers

type AttrGetTPActions 

type AttrGetTPActions struct {
	TPid string // Tariff plan id
	ID   string // Actions id
}

type AttrGetTPAttributeProfileIds 

type AttrGetTPAttributeProfileIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttrGetTPChargerIds 

type AttrGetTPChargerIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttrGetTPDestination 

type AttrGetTPDestination struct {
	TPid string // Tariff plan id
	ID   string // Destination id
}

type AttrGetTPDestinationIds 

type AttrGetTPDestinationIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttrGetTPDestinationRate 

type AttrGetTPDestinationRate struct {
	TPid string // Tariff plan id
	ID   string // Rate id
	utils.Paginator
}

type AttrGetTPDispatcherIds 

type AttrGetTPDispatcherIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttrGetTPFilterProfileIds 

type AttrGetTPFilterProfileIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttrGetTPIds 

type AttrGetTPIds struct {
}

type AttrGetTPRate 

type AttrGetTPRate struct {
	TPid string // Tariff plan id
	ID   string // Rate id
}

type AttrGetTPRateIds 

type AttrGetTPRateIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttrGetTPRatingPlan 

type AttrGetTPRatingPlan struct {
	TPid string // Tariff plan id
	ID   string // Rate id
	utils.Paginator
}

type AttrGetTPRatingPlanIds 

type AttrGetTPRatingPlanIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttrGetTPRatingProfile 

type AttrGetTPRatingProfile struct {
	TPid            string // Tariff plan id
	RatingProfileID string // RatingProfile id
}

AttrGetTPRatingProfile arguments used by GetTPRatingProfile and RemoveTPRatingProfile

type AttrGetTPRatingProfileIds 

type AttrGetTPRatingProfileIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

AttrGetTPRatingProfileIds arguments used by GetTPRatingProfileIds

type AttrGetTPResourceIds 

type AttrGetTPResourceIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttrGetTPSharedGroupIds 

type AttrGetTPSharedGroupIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttrGetTPSharedGroups 

type AttrGetTPSharedGroups struct {
	TPid string // Tariff plan id
	ID   string // SharedGroup id
}

type AttrGetTPStatIds 

type AttrGetTPStatIds struct {
	TPid   string // Tariff plan id
	Tenant string
	utils.PaginatorWithSearch
}

type AttrGetTPSupplierProfileIDs 

type AttrGetTPSupplierProfileIDs struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttrGetTPThresholdIds 

type AttrGetTPThresholdIds struct {
	TPid   string // Tariff plan id
	Tenant string
	utils.PaginatorWithSearch
}

type AttrGetTPTiming 

type AttrGetTPTiming struct {
	TPid string // Tariff plan id
	ID   string // Timing id
}

type AttrGetTPTimingIds 

type AttrGetTPTimingIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttrImportTPZipFile 

type AttrImportTPZipFile struct {
	TPid string
	File []byte
}

type AttrLoadDestination 

type AttrLoadDestination struct {
	TPid string
	ID   string
}

type AttrLoadRatingPlan 

type AttrLoadRatingPlan struct {
	TPid         string
	RatingPlanId string
}

type AttrLoadSharedGroup 

type AttrLoadSharedGroup struct {
	TPid          string
	SharedGroupId string
}

type AttrLoadTpFromStorDb 

type AttrLoadTpFromStorDb struct {
	TPid          string
	DryRun        bool // Only simulate, no write
	Validate      bool // Run structural checks
	ArgDispatcher *utils.ArgDispatcher
	Caching       *string // Caching strategy
}

type AttrRemFilterIndexes 

type AttrRemFilterIndexes struct {
	Tenant   string
	Context  string
	ItemType string
}

type AttrRemTp 

type AttrRemTp struct {
	TPid string
}

type AttrRemoveAccountActionTriggers 

type AttrRemoveAccountActionTriggers struct {
	Tenant   string
	Account  string
	GroupID  string
	UniqueID string
}

type AttrRemoveActionTiming 

type AttrRemoveActionTiming struct {
	ActionPlanId    string // Id identifying the ActionTimings profile
	ActionTimingId  string // Internal CGR id identifying particular ActionTiming, *all for all user related ActionTimings to be canceled
	Tenant          string // Tenant the account belongs to
	Account         string // Account name
	ReloadScheduler bool   // If set it will reload the scheduler after adding
}

type AttrRemoveActionTrigger 

type AttrRemoveActionTrigger struct {
	GroupID  string
	UniqueID string
}

type AttrRemoveActions 

type AttrRemoveActions struct {
	ActionIDs []string
}

type AttrRemoveDestination 

type AttrRemoveDestination struct {
	DestinationIDs []string
	Prefixes       []string
}

type AttrRemoveRatingProfile 

type AttrRemoveRatingProfile struct {
	Tenant   string
	Category string
	Subject  string
	Cache    *string
}

func (*AttrRemoveRatingProfile) GetId 

func (arrp *AttrRemoveRatingProfile) GetId() (result string)

type AttrResetAccountActionTriggers 

type AttrResetAccountActionTriggers struct {
	Tenant   string
	Account  string
	GroupID  string
	UniqueID string
	Executed bool
}

type AttrSetAccountActionTriggers 

type AttrSetAccountActionTriggers struct {
	Tenant  string
	Account string
	AttrSetActionTrigger
}

type AttrSetActionPlan 

type AttrSetActionPlan struct {
	Id              string            // Profile id
	ActionPlan      []*AttrActionPlan // Set of actions this Actions profile will perform
	Overwrite       bool              // If previously defined, will be overwritten
	ReloadScheduler bool              // Enables automatic reload of the scheduler (eg: useful when adding a single action timing)
}

type AttrSetActionTrigger 

type AttrSetActionTrigger struct {
	GroupID       string
	UniqueID      string
	ActionTrigger map[string]any
}

func (*AttrSetActionTrigger) UpdateActionTrigger 

func (attr *AttrSetActionTrigger) UpdateActionTrigger(at *engine.ActionTrigger, timezone string) (updated bool, err error)

UpdateActionTrigger updates the ActionTrigger if is matching

type AttrTPDestinationRateIds 

type AttrTPDestinationRateIds struct {
	TPid string // Tariff plan id
	utils.PaginatorWithSearch
}

type AttributeSv1 

type AttributeSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewAttributeSv1 

func NewAttributeSv1(attrS *engine.AttributeService) *AttributeSv1

func (*AttributeSv1) Call 

func (alSv1 *AttributeSv1) Call(ctx *context.Context, serviceMethod string,
	args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*AttributeSv1) GetAttributeForEvent 

func (alSv1 *AttributeSv1) GetAttributeForEvent(args *engine.AttrArgsProcessEvent,
	reply *engine.AttributeProfile) (err error)

GetAttributeForEvent returns matching AttributeProfile for Event

func (*AttributeSv1) Ping 

func (alSv1 *AttributeSv1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

func (*AttributeSv1) ProcessEvent 

func (alSv1 *AttributeSv1) ProcessEvent(args *engine.AttrArgsProcessEvent,
	reply *engine.AttrSProcessEventReply) error

ProcessEvent will replace event fields with the ones in matching AttributeProfile

type AttributeSv1Interface 

type AttributeSv1Interface interface {
	GetAttributeForEvent(args *engine.AttrArgsProcessEvent, reply *engine.AttributeProfile) (err error)
	ProcessEvent(args *engine.AttrArgsProcessEvent, reply *engine.AttrSProcessEventReply) error
	Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error
}

type AttributeWithCache 

type AttributeWithCache struct {
	*engine.AttributeProfile
	Cache *string
	*utils.ArgDispatcher
}

type AttrsExecuteScheduledActions 

type AttrsExecuteScheduledActions struct {
	ActionPlanID       string
	TimeStart, TimeEnd time.Time // replay the action timings between the two dates
}

type CDRsV1 

type CDRsV1 struct {
	CDRs *engine.CDRServer
}

Receive CDRs via RPC methods

func NewCDRsV1 

func NewCDRsV1(CDRs *engine.CDRServer) *CDRsV1

func (*CDRsV1) GetCDRs 

func (cdrSv1 *CDRsV1) GetCDRs(args utils.RPCCDRsFilterWithArgDispatcher, reply *[]*engine.CDR) error

func (*CDRsV1) GetCDRsCount 

func (cdrSv1 *CDRsV1) GetCDRsCount(args *utils.RPCCDRsFilterWithArgDispatcher, reply *int64) error

func (*CDRsV1) Ping 

func (cdrSv1 *CDRsV1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

func (*CDRsV1) ProcessCDR 

func (cdrSv1 *CDRsV1) ProcessCDR(cdr *engine.CDRWithArgDispatcher, reply *string) error

ProcessCDR will process a CDR in CGRateS internal format

func (*CDRsV1) ProcessEvent 

func (cdrSv1 *CDRsV1) ProcessEvent(arg *engine.ArgV1ProcessEvent, reply *string) error

ProcessCDR will process a CDR in CGRateS internal format

func (*CDRsV1) ProcessExternalCDR 

func (cdrSv1 *CDRsV1) ProcessExternalCDR(cdr *engine.ExternalCDRWithArgDispatcher, reply *string) error

ProcessExternalCDR will process a CDR in external format

func (*CDRsV1) RateCDRs 

func (cdrSv1 *CDRsV1) RateCDRs(arg *engine.ArgRateCDRs, reply *string) error

RateCDRs can re-/rate remotely CDRs

func (*CDRsV1) StoreSessionCost 

func (cdrSv1 *CDRsV1) StoreSessionCost(attr *engine.AttrCDRSStoreSMCost, reply *string) error

StoreSMCost will store

type CDRsV1Interface 

type CDRsV1Interface interface {
	ProcessCDR(cdr *engine.CDRWithArgDispatcher, reply *string) error
	ProcessEvent(arg *engine.ArgV1ProcessEvent, reply *string) error
	ProcessExternalCDR(cdr *engine.ExternalCDRWithArgDispatcher, reply *string) error
	RateCDRs(arg *engine.ArgRateCDRs, reply *string) error
	StoreSessionCost(attr *engine.AttrCDRSStoreSMCost, reply *string) error
}

type CacheSv1 

type CacheSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from CacheS

func NewCacheSv1 

func NewCacheSv1(cacheS *engine.CacheS) *CacheSv1

func (*CacheSv1) Call 

func (chSv1 *CacheSv1) Call(serviceMethod string,
	args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*CacheSv1) Clear 

func (chSv1 *CacheSv1) Clear(args *utils.AttrCacheIDsWithArgDispatcher,
	reply *string) error

Clear will clear partitions in the cache (nil fol all, empty slice for none)

func (*CacheSv1) FlushCache 

func (chSv1 *CacheSv1) FlushCache(args utils.AttrReloadCacheWithArgDispatcher, reply *string) (err error)

FlushCache wipes out cache for a prefix or completely

func (*CacheSv1) GetCacheStats 

func (chSv1 *CacheSv1) GetCacheStats(args *utils.AttrCacheIDsWithArgDispatcher,
	rply *map[string]*ltcache.CacheStats) error

GetCacheStats returns CacheStats filtered by cacheIDs

func (*CacheSv1) GetGroupItemIDs 

func (chSv1 *CacheSv1) GetGroupItemIDs(args *utils.ArgsGetGroupWithArgDispatcher,
	rply *[]string) (err error)

GetGroupItemIDs returns a list of itemIDs in a cache group

func (*CacheSv1) GetItemExpiryTime 

func (chSv1 *CacheSv1) GetItemExpiryTime(args *utils.ArgsGetCacheItemWithArgDispatcher,
	reply *time.Time) error

GetItemExpiryTime returns the expiryTime for an item

func (*CacheSv1) GetItemIDs 

func (chSv1 *CacheSv1) GetItemIDs(args *utils.ArgsGetCacheItemIDsWithArgDispatcher,
	reply *[]string) error

GetItemIDs returns the IDs for cacheID with given prefix

func (*CacheSv1) HasGroup 

func (chSv1 *CacheSv1) HasGroup(args *utils.ArgsGetGroupWithArgDispatcher,
	rply *bool) (err error)

HasGroup checks existence of a group in cache

func (*CacheSv1) HasItem 

func (chSv1 *CacheSv1) HasItem(args *utils.ArgsGetCacheItemWithArgDispatcher,
	reply *bool) error

HasItem verifies the existence of an Item in cache

func (*CacheSv1) LoadCache 

func (chSv1 *CacheSv1) LoadCache(args utils.AttrReloadCacheWithArgDispatcher, reply *string) (err error)

LoadCache loads cache from DB for a prefix or completely

func (*CacheSv1) Ping 

func (chSv1 *CacheSv1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

Ping used to detreminate if component is active

func (*CacheSv1) PrecacheStatus 

func (chSv1 *CacheSv1) PrecacheStatus(args *utils.AttrCacheIDsWithArgDispatcher, rply *map[string]string) error

PrecacheStatus checks status of active precache processes

func (*CacheSv1) ReloadCache 

func (chSv1 *CacheSv1) ReloadCache(args utils.AttrReloadCacheWithArgDispatcher, reply *string) (err error)

ReloadCache reloads cache from DB for a prefix or completely

func (*CacheSv1) RemoveGroup 

func (chSv1 *CacheSv1) RemoveGroup(args *utils.ArgsGetGroupWithArgDispatcher,
	rply *string) (err error)

RemoveGroup will remove a group and all items belonging to it from cache

func (*CacheSv1) RemoveItem 

func (chSv1 *CacheSv1) RemoveItem(args *utils.ArgsGetCacheItemWithArgDispatcher,
	reply *string) error

RemoveItem removes the Item with ID from cache

type CacheSv1Interface 

type CacheSv1Interface interface {
	GetItemIDs(args *utils.ArgsGetCacheItemIDsWithArgDispatcher, reply *[]string) error
	HasItem(args *utils.ArgsGetCacheItemWithArgDispatcher, reply *bool) error
	GetItemExpiryTime(args *utils.ArgsGetCacheItemWithArgDispatcher, reply *time.Time) error
	RemoveItem(args *utils.ArgsGetCacheItemWithArgDispatcher, reply *string) error
	Clear(cacheIDs *utils.AttrCacheIDsWithArgDispatcher, reply *string) error
	FlushCache(args utils.AttrReloadCacheWithArgDispatcher, reply *string) error
	GetCacheStats(cacheIDs *utils.AttrCacheIDsWithArgDispatcher, rply *map[string]*ltcache.CacheStats) error
	PrecacheStatus(cacheIDs *utils.AttrCacheIDsWithArgDispatcher, rply *map[string]string) error
	HasGroup(args *utils.ArgsGetGroupWithArgDispatcher, rply *bool) error
	GetGroupItemIDs(args *utils.ArgsGetGroupWithArgDispatcher, rply *[]string) error
	RemoveGroup(args *utils.ArgsGetGroupWithArgDispatcher, rply *string) error
	ReloadCache(attrs utils.AttrReloadCacheWithArgDispatcher, reply *string) error
	LoadCache(args utils.AttrReloadCacheWithArgDispatcher, reply *string) error
	Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error
}

type ChargerSv1 

type ChargerSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from ChargerS

func NewChargerSv1 

func NewChargerSv1(cS *engine.ChargerService) *ChargerSv1

func (*ChargerSv1) Call 

func (cSv1 *ChargerSv1) Call(ctx *context.Context, serviceMethod string,
	args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*ChargerSv1) GetChargersForEvent 

func (cSv1 *ChargerSv1) GetChargersForEvent(cgrEv *utils.CGREventWithArgDispatcher,
	reply *engine.ChargerProfiles) error

GetChargerForEvent returns matching ChargerProfile for Event

func (*ChargerSv1) Ping 

func (cSv1 *ChargerSv1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

func (*ChargerSv1) ProcessEvent 

func (cSv1 *ChargerSv1) ProcessEvent(args *utils.CGREventWithArgDispatcher,
	reply *[]*engine.ChrgSProcessEventReply) error

ProcessEvent

type ChargerSv1Interface 

type ChargerSv1Interface interface {
	Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error
	GetChargersForEvent(cgrEv *utils.CGREventWithArgDispatcher, reply *engine.ChargerProfiles) error
	ProcessEvent(args *utils.CGREventWithArgDispatcher, reply *[]*engine.ChrgSProcessEventReply) error
}

type ChargerWithCache 

type ChargerWithCache struct {
	*engine.ChargerProfile
	Cache *string
}

type ConfigPathArg 

type ConfigPathArg struct {
	ConfigPath string
}

type ConfigSv1 

type ConfigSv1 struct {
	// contains filtered or unexported fields
}

ConfigSv1 exports RPC for config

func NewConfigSv1 

func NewConfigSv1(cfg *config.CGRConfig) *ConfigSv1

NewConfigSv1 returns a new ConfigSv1

func (*ConfigSv1) Call 

func (cSv1 *ConfigSv1) Call(ctx *context.Context, serviceMethod string,
	args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*ConfigSv1) GetJSONSection 

func (cSv1 *ConfigSv1) GetJSONSection(section *config.StringWithArgDispatcher, reply *map[string]any) (err error)

GetJSONSection will retrieve from CGRConfig a section

func (*ConfigSv1) ReloadConfigFromJSON 

func (cSv1 *ConfigSv1) ReloadConfigFromJSON(args *config.JSONReloadWithArgDispatcher, reply *string) (err error)

ReloadConfigFromJSON reloads the sections of configz

func (*ConfigSv1) ReloadConfigFromPath 

func (cSv1 *ConfigSv1) ReloadConfigFromPath(args *config.ConfigReloadWithArgDispatcher, reply *string) (err error)

ReloadConfigFromPath reloads the configuration

type ConfigSv1Interface 

type ConfigSv1Interface interface {
	GetJSONSection(section *config.StringWithArgDispatcher, reply *map[string]any) (err error)
	ReloadConfigFromPath(section *config.ConfigReloadWithArgDispatcher, reply *string) (err error)
	ReloadConfigFromJSON(args *config.JSONReloadWithArgDispatcher, reply *string) (err error)
}

type CoreSv1 

type CoreSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewCoreSv1 

func NewCoreSv1(cS *engine.CoreService) *CoreSv1

func (*CoreSv1) Call 

func (cS *CoreSv1) Call(ctx *context.Context, serviceMethod string,
	args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*CoreSv1) Ping 

func (cS *CoreSv1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

Ping used to determinate if component is active

func (*CoreSv1) Sleep added in v0.10.2 

func (cS *CoreSv1) Sleep(arg *utils.DurationArgs, reply *string) error

Sleep is used to test the concurrent requests mechanism

func (*CoreSv1) Status 

func (cS *CoreSv1) Status(arg *utils.TenantWithArgDispatcher, reply *map[string]any) error

type CoreSv1Interface 

type CoreSv1Interface interface {
	Status(arg *utils.TenantWithArgDispatcher, reply *map[string]any) error
	Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error
}

type DispatcherAttributeSv1 

type DispatcherAttributeSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewDispatcherAttributeSv1 

func NewDispatcherAttributeSv1(dps *dispatchers.DispatcherService) *DispatcherAttributeSv1

func (*DispatcherAttributeSv1) GetAttributeForEvent 

func (dA *DispatcherAttributeSv1) GetAttributeForEvent(args *engine.AttrArgsProcessEvent,
	reply *engine.AttributeProfile) error

GetAttributeForEvent implements AttributeSv1GetAttributeForEvent

func (*DispatcherAttributeSv1) Ping 

func (dA *DispatcherAttributeSv1) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping implements SupplierSv1Ping

func (*DispatcherAttributeSv1) ProcessEvent 

func (dA *DispatcherAttributeSv1) ProcessEvent(args *engine.AttrArgsProcessEvent,
	reply *engine.AttrSProcessEventReply) error

ProcessEvent implements AttributeSv1ProcessEvent

type DispatcherCacheSv1 

type DispatcherCacheSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from CacheSv1

func NewDispatcherCacheSv1 

func NewDispatcherCacheSv1(dps *dispatchers.DispatcherService) *DispatcherCacheSv1

func (*DispatcherCacheSv1) Clear 

func (dS *DispatcherCacheSv1) Clear(args *utils.AttrCacheIDsWithArgDispatcher,
	reply *string) error

Clear will clear partitions in the cache (nil fol all, empty slice for none)

func (*DispatcherCacheSv1) FlushCache 

func (dS *DispatcherCacheSv1) FlushCache(args utils.AttrReloadCacheWithArgDispatcher, reply *string) (err error)

FlushCache wipes out cache for a prefix or completely

func (*DispatcherCacheSv1) GetCacheStats 

func (dS *DispatcherCacheSv1) GetCacheStats(args *utils.AttrCacheIDsWithArgDispatcher,
	reply *map[string]*ltcache.CacheStats) error

GetCacheStats returns CacheStats filtered by cacheIDs

func (*DispatcherCacheSv1) GetGroupItemIDs 

func (dS *DispatcherCacheSv1) GetGroupItemIDs(args *utils.ArgsGetGroupWithArgDispatcher,
	reply *[]string) (err error)

GetGroupItemIDs returns a list of itemIDs in a cache group

func (*DispatcherCacheSv1) GetItemExpiryTime 

func (dS *DispatcherCacheSv1) GetItemExpiryTime(args *utils.ArgsGetCacheItemWithArgDispatcher,
	reply *time.Time) error

GetItemExpiryTime returns the expiryTime for an item

func (*DispatcherCacheSv1) GetItemIDs 

func (dS *DispatcherCacheSv1) GetItemIDs(args *utils.ArgsGetCacheItemIDsWithArgDispatcher,
	reply *[]string) error

GetItemIDs returns the IDs for cacheID with given prefix

func (*DispatcherCacheSv1) HasGroup 

func (dS *DispatcherCacheSv1) HasGroup(args *utils.ArgsGetGroupWithArgDispatcher,
	reply *bool) (err error)

HasGroup checks existence of a group in cache

func (*DispatcherCacheSv1) HasItem 

func (dS *DispatcherCacheSv1) HasItem(args *utils.ArgsGetCacheItemWithArgDispatcher,
	reply *bool) error

HasItem verifies the existence of an Item in cache

func (*DispatcherCacheSv1) LoadCache 

func (dS *DispatcherCacheSv1) LoadCache(args utils.AttrReloadCacheWithArgDispatcher, reply *string) (err error)

LoadCache loads cache from DB for a prefix or completely

func (*DispatcherCacheSv1) Ping 

func (dS *DispatcherCacheSv1) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping used to detreminate if component is active

func (*DispatcherCacheSv1) PrecacheStatus 

func (dS *DispatcherCacheSv1) PrecacheStatus(args *utils.AttrCacheIDsWithArgDispatcher, reply *map[string]string) error

PrecacheStatus checks status of active precache processes

func (*DispatcherCacheSv1) ReloadCache 

func (dS *DispatcherCacheSv1) ReloadCache(args utils.AttrReloadCacheWithArgDispatcher, reply *string) (err error)

ReloadCache reloads cache from DB for a prefix or completely

func (*DispatcherCacheSv1) RemoveGroup 

func (dS *DispatcherCacheSv1) RemoveGroup(args *utils.ArgsGetGroupWithArgDispatcher,
	reply *string) (err error)

RemoveGroup will remove a group and all items belonging to it from cache

func (*DispatcherCacheSv1) RemoveItem 

func (dS *DispatcherCacheSv1) RemoveItem(args *utils.ArgsGetCacheItemWithArgDispatcher,
	reply *string) error

RemoveItem removes the Item with ID from cache

type DispatcherChargerSv1 

type DispatcherChargerSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewDispatcherChargerSv1 

func NewDispatcherChargerSv1(dps *dispatchers.DispatcherService) *DispatcherChargerSv1

func (*DispatcherChargerSv1) GetChargersForEvent 

func (dC *DispatcherChargerSv1) GetChargersForEvent(args *utils.CGREventWithArgDispatcher,
	reply *engine.ChargerProfiles) (err error)

GetChargersForEvent implements ChargerSv1GetChargersForEvent

func (*DispatcherChargerSv1) Ping 

func (dC *DispatcherChargerSv1) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping implements ChargerSv1Ping

func (*DispatcherChargerSv1) ProcessEvent 

func (dC *DispatcherChargerSv1) ProcessEvent(args *utils.CGREventWithArgDispatcher,
	reply *[]*engine.ChrgSProcessEventReply) (err error)

ProcessEvent implements ChargerSv1ProcessEvent

type DispatcherConfigSv1 

type DispatcherConfigSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from CDRsV1

func NewDispatcherConfigSv1 

func NewDispatcherConfigSv1(dps *dispatchers.DispatcherService) *DispatcherConfigSv1

func (*DispatcherConfigSv1) GetJSONSection 

func (dS *DispatcherConfigSv1) GetJSONSection(args *config.StringWithArgDispatcher, reply *map[string]any) (err error)

func (*DispatcherConfigSv1) ReloadConfigFromJSON 

func (dS *DispatcherConfigSv1) ReloadConfigFromJSON(args *config.JSONReloadWithArgDispatcher, reply *string) (err error)

func (*DispatcherConfigSv1) ReloadConfigFromPath 

func (dS *DispatcherConfigSv1) ReloadConfigFromPath(args *config.ConfigReloadWithArgDispatcher, reply *string) (err error)

type DispatcherCoreSv1 

type DispatcherCoreSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewDispatcherCoreSv1 

func NewDispatcherCoreSv1(dps *dispatchers.DispatcherService) *DispatcherCoreSv1

func (*DispatcherCoreSv1) Ping 

func (dS *DispatcherCoreSv1) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping used to detreminate if component is active

func (*DispatcherCoreSv1) Status 

func (dS *DispatcherCoreSv1) Status(args *utils.TenantWithArgDispatcher, reply *map[string]any) error

type DispatcherGuardianSv1 

type DispatcherGuardianSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from CacheSv1

func NewDispatcherGuardianSv1 

func NewDispatcherGuardianSv1(dps *dispatchers.DispatcherService) *DispatcherGuardianSv1

func (*DispatcherGuardianSv1) Ping 

func (dS *DispatcherGuardianSv1) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping used to detreminate if component is active

func (*DispatcherGuardianSv1) RemoteLock 

func (dS *DispatcherGuardianSv1) RemoteLock(attr dispatchers.AttrRemoteLockWithApiKey, reply *string) (err error)

RemoteLock will lock a key from remote

func (*DispatcherGuardianSv1) RemoteUnlock 

func (dS *DispatcherGuardianSv1) RemoteUnlock(attr dispatchers.AttrRemoteUnlockWithApiKey, reply *[]string) (err error)

RemoteUnlock will unlock a key from remote based on reference ID

type DispatcherHostWithCache 

type DispatcherHostWithCache struct {
	*engine.DispatcherHost
	Cache *string
}

type DispatcherRALsV1 

type DispatcherRALsV1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewDispatcherRALsV1 

func NewDispatcherRALsV1(dps *dispatchers.DispatcherService) *DispatcherRALsV1

func (*DispatcherRALsV1) GetRatingPlansCost 

func (dS *DispatcherRALsV1) GetRatingPlansCost(args *utils.RatingPlanCostArg, reply *dispatchers.RatingPlanCost) error

func (*DispatcherRALsV1) Ping 

func (dS *DispatcherRALsV1) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping used to detreminate if component is active

type DispatcherResourceSv1 

type DispatcherResourceSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewDispatcherResourceSv1 

func NewDispatcherResourceSv1(dps *dispatchers.DispatcherService) *DispatcherResourceSv1

func (*DispatcherResourceSv1) AllocateResources 

func (dRs *DispatcherResourceSv1) AllocateResources(args utils.ArgRSv1ResourceUsage,
	reply *string) error

func (*DispatcherResourceSv1) AuthorizeResources 

func (dRs *DispatcherResourceSv1) AuthorizeResources(args utils.ArgRSv1ResourceUsage,
	reply *string) error

func (*DispatcherResourceSv1) GetResourcesForEvent 

func (dRs *DispatcherResourceSv1) GetResourcesForEvent(args utils.ArgRSv1ResourceUsage,
	reply *engine.Resources) error

GetResourcesForEvent implements ResourceSv1GetResourcesForEvent

func (*DispatcherResourceSv1) Ping 

func (dRs *DispatcherResourceSv1) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping implements ResourceSv1Ping

func (*DispatcherResourceSv1) ReleaseResources 

func (dRs *DispatcherResourceSv1) ReleaseResources(args utils.ArgRSv1ResourceUsage,
	reply *string) error

type DispatcherResponder 

type DispatcherResponder struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewDispatcherResponder 

func NewDispatcherResponder(dps *dispatchers.DispatcherService) *DispatcherResponder

func (*DispatcherResponder) Debit 

func (dS *DispatcherResponder) Debit(args *engine.CallDescriptorWithArgDispatcher, reply *engine.CallCost) error

func (*DispatcherResponder) GetCost 

func (dS *DispatcherResponder) GetCost(args *engine.CallDescriptorWithArgDispatcher, reply *engine.CallCost) error

func (*DispatcherResponder) GetCostOnRatingPlans added in v0.10.3 

func (dS *DispatcherResponder) GetCostOnRatingPlans(arg *utils.GetCostOnRatingPlansArgs, reply *map[string]any) (err error)

func (*DispatcherResponder) GetMaxSessionTime 

func (dS *DispatcherResponder) GetMaxSessionTime(args *engine.CallDescriptorWithArgDispatcher, reply *time.Duration) error

func (*DispatcherResponder) GetMaxSessionTimeOnAccounts added in v0.10.3 

func (dS *DispatcherResponder) GetMaxSessionTimeOnAccounts(arg *utils.GetMaxSessionTimeOnAccountsArgs, reply *map[string]any) (err error)

func (*DispatcherResponder) MaxDebit 

func (dS *DispatcherResponder) MaxDebit(args *engine.CallDescriptorWithArgDispatcher, reply *engine.CallCost) error

func (*DispatcherResponder) Ping 

func (dS *DispatcherResponder) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping used to determinate if component is active

func (*DispatcherResponder) RefundIncrements 

func (dS *DispatcherResponder) RefundIncrements(args *engine.CallDescriptorWithArgDispatcher, reply *engine.Account) error

func (*DispatcherResponder) RefundRounding 

func (dS *DispatcherResponder) RefundRounding(args *engine.CallDescriptorWithArgDispatcher, reply *engine.Account) error

func (*DispatcherResponder) Shutdown 

func (dS *DispatcherResponder) Shutdown(args *utils.TenantWithArgDispatcher, reply *string) error

type DispatcherSCDRsV1 

type DispatcherSCDRsV1 struct {
	// contains filtered or unexported fields
}

Exports RPC from CDRsV1

func NewDispatcherSCDRsV1 

func NewDispatcherSCDRsV1(dps *dispatchers.DispatcherService) *DispatcherSCDRsV1

func (*DispatcherSCDRsV1) GetCDRs 

func (dS *DispatcherSCDRsV1) GetCDRs(args utils.RPCCDRsFilterWithArgDispatcher, reply *[]*engine.CDR) error

func (*DispatcherSCDRsV1) GetCDRsCount 

func (dS *DispatcherSCDRsV1) GetCDRsCount(args *utils.RPCCDRsFilterWithArgDispatcher, reply *int64) error

func (*DispatcherSCDRsV1) Ping 

func (dS *DispatcherSCDRsV1) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping used to detreminate if component is active

func (*DispatcherSCDRsV1) ProcessCDR 

func (dS *DispatcherSCDRsV1) ProcessCDR(args *engine.CDRWithArgDispatcher, reply *string) error

func (*DispatcherSCDRsV1) ProcessEvent 

func (dS *DispatcherSCDRsV1) ProcessEvent(args *engine.ArgV1ProcessEvent, reply *string) error

func (*DispatcherSCDRsV1) ProcessExternalCDR 

func (dS *DispatcherSCDRsV1) ProcessExternalCDR(args *engine.ExternalCDRWithArgDispatcher, reply *string) error

func (*DispatcherSCDRsV1) RateCDRs 

func (dS *DispatcherSCDRsV1) RateCDRs(args *engine.ArgRateCDRs, reply *string) error

func (*DispatcherSCDRsV1) StoreSessionCost 

func (dS *DispatcherSCDRsV1) StoreSessionCost(args *engine.AttrCDRSStoreSMCost, reply *string) error

type DispatcherSServiceManagerV1 

type DispatcherSServiceManagerV1 struct {
	// contains filtered or unexported fields
}

Exports RPC from ServiceManagerV1

func NewDispatcherSServiceManagerV1 

func NewDispatcherSServiceManagerV1(dps *dispatchers.DispatcherService) *DispatcherSServiceManagerV1

func (*DispatcherSServiceManagerV1) Ping 

func (dS *DispatcherSServiceManagerV1) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping used to detreminate if component is active

func (*DispatcherSServiceManagerV1) ServiceStatus 

func (dS *DispatcherSServiceManagerV1) ServiceStatus(args dispatchers.ArgStartServiceWithApiKey, reply *string) error

func (*DispatcherSServiceManagerV1) StartService 

func (dS *DispatcherSServiceManagerV1) StartService(args dispatchers.ArgStartServiceWithApiKey, reply *string) error

func (*DispatcherSServiceManagerV1) StopService 

func (dS *DispatcherSServiceManagerV1) StopService(args dispatchers.ArgStartServiceWithApiKey, reply *string) error

type DispatcherSchedulerSv1 

type DispatcherSchedulerSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from SchedulerSv1

func NewDispatcherSchedulerSv1 

func NewDispatcherSchedulerSv1(dps *dispatchers.DispatcherService) *DispatcherSchedulerSv1

func (*DispatcherSchedulerSv1) Ping 

func (dS *DispatcherSchedulerSv1) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping used to detreminate if component is active

func (*DispatcherSchedulerSv1) Reload 

func (dS *DispatcherSchedulerSv1) Reload(attr *utils.CGREventWithArgDispatcher, reply *string) (err error)

Reload reloads scheduler instructions

type DispatcherSessionSv1 

type DispatcherSessionSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewDispatcherSessionSv1 

func NewDispatcherSessionSv1(dps *dispatchers.DispatcherService) *DispatcherSessionSv1

func (*DispatcherSessionSv1) AuthorizeEvent 

func (dS *DispatcherSessionSv1) AuthorizeEvent(args *sessions.V1AuthorizeArgs,
	reply *sessions.V1AuthorizeReply) error

func (*DispatcherSessionSv1) AuthorizeEventWithDigest 

func (dS *DispatcherSessionSv1) AuthorizeEventWithDigest(args *sessions.V1AuthorizeArgs,
	reply *sessions.V1AuthorizeReplyWithDigest) error

AuthorizeEventWithDigest implements SessionSv1AuthorizeEventWithDigest

func (*DispatcherSessionSv1) ForceDisconnect 

func (dS *DispatcherSessionSv1) ForceDisconnect(args *utils.SessionFilter,
	reply *string) (err error)

func (*DispatcherSessionSv1) GetActiveSessions 

func (dS *DispatcherSessionSv1) GetActiveSessions(args *utils.SessionFilter,
	reply *[]*sessions.ExternalSession) (err error)

func (*DispatcherSessionSv1) GetActiveSessionsCount 

func (dS *DispatcherSessionSv1) GetActiveSessionsCount(args *utils.SessionFilter,
	reply *int) (err error)

func (*DispatcherSessionSv1) GetPassiveSessions 

func (dS *DispatcherSessionSv1) GetPassiveSessions(args *utils.SessionFilter,
	reply *[]*sessions.ExternalSession) (err error)

func (*DispatcherSessionSv1) GetPassiveSessionsCount 

func (dS *DispatcherSessionSv1) GetPassiveSessionsCount(args *utils.SessionFilter,
	reply *int) (err error)

func (*DispatcherSessionSv1) InitiateSession 

func (dS *DispatcherSessionSv1) InitiateSession(args *sessions.V1InitSessionArgs,
	reply *sessions.V1InitSessionReply) (err error)

InitiateSessionWithDigest implements SessionSv1InitiateSessionWithDigest

func (*DispatcherSessionSv1) InitiateSessionWithDigest 

func (dS *DispatcherSessionSv1) InitiateSessionWithDigest(args *sessions.V1InitSessionArgs,
	reply *sessions.V1InitReplyWithDigest) (err error)

InitiateSessionWithDigest implements SessionSv1InitiateSessionWithDigest

func (*DispatcherSessionSv1) Ping 

func (dS *DispatcherSessionSv1) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping implements SessionSv1Ping

func (*DispatcherSessionSv1) ProcessCDR 

func (dS *DispatcherSessionSv1) ProcessCDR(args *utils.CGREventWithArgDispatcher,
	reply *string) (err error)

ProcessCDR implements SessionSv1ProcessCDR

func (*DispatcherSessionSv1) ProcessEvent 

func (dS *DispatcherSessionSv1) ProcessEvent(args *sessions.V1ProcessEventArgs,
	reply *sessions.V1ProcessEventReply) (err error)

ProcessMessage implements SessionSv1ProcessMessage

func (*DispatcherSessionSv1) ProcessMessage 

func (dS *DispatcherSessionSv1) ProcessMessage(args *sessions.V1ProcessMessageArgs,
	reply *sessions.V1ProcessMessageReply) (err error)

ProcessMessage implements SessionSv1ProcessMessage

func (*DispatcherSessionSv1) ReplicateSessions 

func (dS *DispatcherSessionSv1) ReplicateSessions(args dispatchers.ArgsReplicateSessionsWithApiKey,
	reply *string) (err error)

func (*DispatcherSessionSv1) SetPassiveSession 

func (dS *DispatcherSessionSv1) SetPassiveSession(args *sessions.Session,
	reply *string) (err error)

func (*DispatcherSessionSv1) TerminateSession 

func (dS *DispatcherSessionSv1) TerminateSession(args *sessions.V1TerminateSessionArgs,
	reply *string) (err error)

TerminateSession implements SessionSv1TerminateSession

func (*DispatcherSessionSv1) UpdateSession 

func (dS *DispatcherSessionSv1) UpdateSession(args *sessions.V1UpdateSessionArgs,
	reply *sessions.V1UpdateSessionReply) (err error)

UpdateSession implements SessionSv1UpdateSession

type DispatcherStatSv1 

type DispatcherStatSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewDispatcherStatSv1 

func NewDispatcherStatSv1(dps *dispatchers.DispatcherService) *DispatcherStatSv1

func (*DispatcherStatSv1) GetQueueFloatMetrics 

func (dSts *DispatcherStatSv1) GetQueueFloatMetrics(args *utils.TenantIDWithArgDispatcher,
	reply *map[string]float64) error

func (*DispatcherStatSv1) GetQueueIDs 

func (dSts *DispatcherStatSv1) GetQueueIDs(args *utils.TenantWithArgDispatcher,
	reply *[]string) error

func (*DispatcherStatSv1) GetQueueStringMetrics 

func (dSts *DispatcherStatSv1) GetQueueStringMetrics(args *utils.TenantIDWithArgDispatcher,
	reply *map[string]string) error

GetQueueStringMetrics implements StatSv1GetQueueStringMetrics

func (*DispatcherStatSv1) GetStatQueuesForEvent 

func (dSts *DispatcherStatSv1) GetStatQueuesForEvent(args *engine.StatsArgsProcessEvent, reply *[]string) error

GetStatQueuesForEvent implements StatSv1GetStatQueuesForEvent

func (*DispatcherStatSv1) Ping 

func (dSts *DispatcherStatSv1) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping implements StatSv1Ping

func (*DispatcherStatSv1) ProcessEvent 

func (dSts *DispatcherStatSv1) ProcessEvent(args *engine.StatsArgsProcessEvent, reply *[]string) error

GetQueueStringMetrics implements StatSv1ProcessEvent

type DispatcherSupplierSv1 

type DispatcherSupplierSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewDispatcherSupplierSv1 

func NewDispatcherSupplierSv1(dps *dispatchers.DispatcherService) *DispatcherSupplierSv1

func (*DispatcherSupplierSv1) GetSupplierProfilesForEvent 

func (dSup *DispatcherSupplierSv1) GetSupplierProfilesForEvent(args *utils.CGREventWithArgDispatcher,
	reply *[]*engine.SupplierProfile) error

GetSuppliersProfiles returns a list of suppliers profiles that match for Event

func (*DispatcherSupplierSv1) GetSuppliers 

func (dSup *DispatcherSupplierSv1) GetSuppliers(args *engine.ArgsGetSuppliers,
	reply *engine.SortedSuppliers) error

GetSuppliers implements SupplierSv1GetSuppliers

func (*DispatcherSupplierSv1) Ping 

func (dSup *DispatcherSupplierSv1) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping implements SupplierSv1Ping

type DispatcherSv1 

type DispatcherSv1 struct {
	// contains filtered or unexported fields
}

func NewDispatcherSv1 

func NewDispatcherSv1(dS *dispatchers.DispatcherService) *DispatcherSv1

func (DispatcherSv1) Apier 

func (dSv1 DispatcherSv1) Apier(args *utils.MethodParameters, reply *any) (err error)

func (DispatcherSv1) GetProfileForEvent 

func (dSv1 DispatcherSv1) GetProfileForEvent(ev *dispatchers.DispatcherEvent,
	dPrfl *engine.DispatcherProfile) error

GetProfileForEvent returns the matching dispatcher profile for the provided event

type DispatcherThresholdSv1 

type DispatcherThresholdSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewDispatcherThresholdSv1 

func NewDispatcherThresholdSv1(dps *dispatchers.DispatcherService) *DispatcherThresholdSv1

func (*DispatcherThresholdSv1) GetThreshold 

func (dT *DispatcherThresholdSv1) GetThreshold(args *utils.TenantIDWithArgDispatcher,
	th *engine.Threshold) error

func (*DispatcherThresholdSv1) GetThresholdIDs 

func (dT *DispatcherThresholdSv1) GetThresholdIDs(args *utils.TenantWithArgDispatcher,
	tIDs *[]string) error

func (*DispatcherThresholdSv1) GetThresholdsForEvent 

func (dT *DispatcherThresholdSv1) GetThresholdsForEvent(tntID *engine.ArgsProcessEvent,
	t *engine.Thresholds) error

GetThresholdsForEvent implements ThresholdSv1GetThresholdsForEvent

func (*DispatcherThresholdSv1) Ping 

func (dT *DispatcherThresholdSv1) Ping(args *utils.CGREventWithArgDispatcher, reply *string) error

Ping implements ThresholdSv1Ping

func (*DispatcherThresholdSv1) ProcessEvent 

func (dT *DispatcherThresholdSv1) ProcessEvent(args *engine.ArgsProcessEvent,
	tIDs *[]string) error

ProcessEvent implements ThresholdSv1ProcessEvent

type DispatcherWithCache 

type DispatcherWithCache struct {
	*engine.DispatcherProfile
	Cache *string
}

type FilterWithCache 

type FilterWithCache struct {
	*engine.Filter
	Cache *string
}

type GuardianSv1 

type GuardianSv1 struct{}

func NewGuardianSv1 

func NewGuardianSv1() *GuardianSv1

func (*GuardianSv1) Call 

func (self *GuardianSv1) Call(ctx *context.Context, serviceMethod string,
	args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*GuardianSv1) Ping 

func (self *GuardianSv1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

Ping return pong if the service is active

func (*GuardianSv1) RemoteLock 

func (self *GuardianSv1) RemoteLock(attr dispatchers.AttrRemoteLockWithApiKey, reply *string) (err error)

RemoteLock will lock a key from remote

func (*GuardianSv1) RemoteUnlock 

func (self *GuardianSv1) RemoteUnlock(refID dispatchers.AttrRemoteUnlockWithApiKey, reply *[]string) (err error)

RemoteUnlock will unlock a key from remote based on reference ID

type GuardianSv1Interface 

type GuardianSv1Interface interface {
	RemoteLock(attr dispatchers.AttrRemoteLockWithApiKey, reply *string) (err error)
	RemoteUnlock(refID dispatchers.AttrRemoteUnlockWithApiKey, reply *[]string) (err error)
	Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error
}

type LoadTimeArgs 

type LoadTimeArgs struct {
	Timezone string
	Item     string
}

type LoaderSv1 

type LoaderSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from LoaderService

func NewLoaderSv1 

func NewLoaderSv1(ldrS *loaders.LoaderService) *LoaderSv1

func (*LoaderSv1) Call 

func (ldrSv1 *LoaderSv1) Call(ctx *context.Context, serviceMethod string,
	args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*LoaderSv1) Load 

func (ldrSv1 *LoaderSv1) Load(args *loaders.ArgsProcessFolder,
	rply *string) error

func (*LoaderSv1) Ping 

func (rsv1 *LoaderSv1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

func (*LoaderSv1) Remove 

func (ldrSv1 *LoaderSv1) Remove(args *loaders.ArgsProcessFolder,
	rply *string) error

type RALsV1 

type RALsV1 struct {
}

Exports RPC from RALs

func NewRALsV1 

func NewRALsV1() *RALsV1

func (*RALsV1) Call 

func (rsv1 *RALsV1) Call(ctx *context.Context, serviceMethod string, args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*RALsV1) GetRatingPlansCost 

func (rsv1 *RALsV1) GetRatingPlansCost(arg *utils.RatingPlanCostArg, reply *dispatchers.RatingPlanCost) error

GetRatingPlansCost returns EventCosts matching RatingPlanIDs

func (*RALsV1) Ping 

func (rsv1 *RALsV1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

type RALsV1Interface 

type RALsV1Interface interface {
	GetRatingPlansCost(arg *utils.RatingPlanCostArg, reply *dispatchers.RatingPlanCost) error
	Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error
}

type ReplicatorSv1 

type ReplicatorSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC

func NewReplicatorSv1 

func NewReplicatorSv1(dm *engine.DataManager) *ReplicatorSv1

func (*ReplicatorSv1) Call 

func (rplSv1 *ReplicatorSv1) Call(serviceMethod string, args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*ReplicatorSv1) GetAccount 

func (rplSv1 *ReplicatorSv1) GetAccount(id string, reply *engine.Account) error

GetAccount

func (*ReplicatorSv1) GetAccountActionPlans 

func (rplSv1 *ReplicatorSv1) GetAccountActionPlans(id string, reply *[]string) error

GetAccountActionPlans

func (*ReplicatorSv1) GetActionPlan 

func (rplSv1 *ReplicatorSv1) GetActionPlan(id string, reply *engine.ActionPlan) error

GetActions

func (*ReplicatorSv1) GetActionTriggers 

func (rplSv1 *ReplicatorSv1) GetActionTriggers(id string, reply engine.ActionTriggers) error

GetActionTriggers

func (*ReplicatorSv1) GetActions 

func (rplSv1 *ReplicatorSv1) GetActions(id string, reply *engine.Actions) error

GetActions

func (*ReplicatorSv1) GetAllActionPlans 

func (rplSv1 *ReplicatorSv1) GetAllActionPlans(_ string, reply *map[string]*engine.ActionPlan) error

GetAllActionPlans

func (*ReplicatorSv1) GetAttributeProfile 

func (rplSv1 *ReplicatorSv1) GetAttributeProfile(tntID *utils.TenantID, reply *engine.AttributeProfile) error

GetResourceProfile

func (*ReplicatorSv1) GetChargerProfile 

func (rplSv1 *ReplicatorSv1) GetChargerProfile(tntID *utils.TenantID, reply *engine.ChargerProfile) error

GetResourceProfile

func (*ReplicatorSv1) GetDestination 

func (rplSv1 *ReplicatorSv1) GetDestination(key string, reply *engine.Destination) error

GetDestination

func (*ReplicatorSv1) GetDispatcherHost 

func (rplSv1 *ReplicatorSv1) GetDispatcherHost(tntID *utils.TenantID, reply *engine.DispatcherHost) error

GetResourceProfile

func (*ReplicatorSv1) GetDispatcherProfile 

func (rplSv1 *ReplicatorSv1) GetDispatcherProfile(tntID *utils.TenantID, reply *engine.DispatcherProfile) error

GetResourceProfile

func (*ReplicatorSv1) GetFilter 

func (rplSv1 *ReplicatorSv1) GetFilter(tntID *utils.TenantID, reply *engine.Filter) error

GetFilter

func (*ReplicatorSv1) GetFilterIndexes 

func (rplSv1 *ReplicatorSv1) GetFilterIndexes(args *utils.GetFilterIndexesArg, reply *map[string]utils.StringMap) error

GetResourceProfile

func (*ReplicatorSv1) GetItemLoadIDs 

func (rplSv1 *ReplicatorSv1) GetItemLoadIDs(itemID string, reply *map[string]int64) error

GetResourceProfile

func (*ReplicatorSv1) GetRatingPlan 

func (rplSv1 *ReplicatorSv1) GetRatingPlan(id string, reply *engine.RatingPlan) error

GetAllActionPlans

func (*ReplicatorSv1) GetRatingProfile 

func (rplSv1 *ReplicatorSv1) GetRatingProfile(id string, reply *engine.RatingProfile) error

GetAllActionPlans

func (*ReplicatorSv1) GetResource 

func (rplSv1 *ReplicatorSv1) GetResource(tntID *utils.TenantID, reply *engine.Resource) error

GetResource

func (*ReplicatorSv1) GetResourceProfile 

func (rplSv1 *ReplicatorSv1) GetResourceProfile(tntID *utils.TenantID, reply *engine.ResourceProfile) error

GetResourceProfile

func (*ReplicatorSv1) GetReverseDestination 

func (rplSv1 *ReplicatorSv1) GetReverseDestination(key string, reply *[]string) error

GetDestination

func (*ReplicatorSv1) GetShareGroup 

func (rplSv1 *ReplicatorSv1) GetShareGroup(id string, reply *engine.SharedGroup) error

GetShareGroup

func (*ReplicatorSv1) GetStatQueue 

func (rplSv1 *ReplicatorSv1) GetStatQueue(tntID *utils.TenantID, reply *engine.StatQueue) error

GetStatQueue

func (*ReplicatorSv1) GetStatQueueProfile 

func (rplSv1 *ReplicatorSv1) GetStatQueueProfile(tntID *utils.TenantID, reply *engine.StatQueueProfile) error

GetStatQueueProfile

func (*ReplicatorSv1) GetSupplierProfile 

func (rplSv1 *ReplicatorSv1) GetSupplierProfile(tntID *utils.TenantID, reply *engine.SupplierProfile) error

GetResourceProfile

func (*ReplicatorSv1) GetThreshold 

func (rplSv1 *ReplicatorSv1) GetThreshold(tntID *utils.TenantID, reply *engine.Threshold) error

GetThreshold

func (*ReplicatorSv1) GetThresholdProfile 

func (rplSv1 *ReplicatorSv1) GetThresholdProfile(tntID *utils.TenantID, reply *engine.ThresholdProfile) error

GetThresholdProfile

func (*ReplicatorSv1) GetTiming 

func (rplSv1 *ReplicatorSv1) GetTiming(id string, reply *utils.TPTiming) error

GetTiming

func (*ReplicatorSv1) MatchFilterIndex 

func (rplSv1 *ReplicatorSv1) MatchFilterIndex(args *utils.MatchFilterIndexArg, reply *utils.StringMap) error

GetResourceProfile

func (*ReplicatorSv1) Ping 

func (rplSv1 *ReplicatorSv1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

func (*ReplicatorSv1) RemAccountActionPlans 

func (rplSv1 *ReplicatorSv1) RemAccountActionPlans(args *engine.RemAccountActionPlansArgs, reply *string) error

func (*ReplicatorSv1) RemoveAccount 

func (rplSv1 *ReplicatorSv1) RemoveAccount(id string, reply *string) error

func (*ReplicatorSv1) RemoveActionPlan 

func (rplSv1 *ReplicatorSv1) RemoveActionPlan(id string, reply *string) error

func (*ReplicatorSv1) RemoveActionTriggers 

func (rplSv1 *ReplicatorSv1) RemoveActionTriggers(id string, reply *string) error

func (*ReplicatorSv1) RemoveActions 

func (rplSv1 *ReplicatorSv1) RemoveActions(id string, reply *string) error

func (*ReplicatorSv1) RemoveAttributeProfile 

func (rplSv1 *ReplicatorSv1) RemoveAttributeProfile(args *utils.TenantID, reply *string) error

func (*ReplicatorSv1) RemoveChargerProfile 

func (rplSv1 *ReplicatorSv1) RemoveChargerProfile(args *utils.TenantID, reply *string) error

func (*ReplicatorSv1) RemoveDestination 

func (rplSv1 *ReplicatorSv1) RemoveDestination(id string, reply *string) error

func (*ReplicatorSv1) RemoveDispatcherHost 

func (rplSv1 *ReplicatorSv1) RemoveDispatcherHost(args *utils.TenantID, reply *string) error

func (*ReplicatorSv1) RemoveDispatcherProfile 

func (rplSv1 *ReplicatorSv1) RemoveDispatcherProfile(args *utils.TenantID, reply *string) error

func (*ReplicatorSv1) RemoveFilter 

func (rplSv1 *ReplicatorSv1) RemoveFilter(args *utils.TenantID, reply *string) error

func (*ReplicatorSv1) RemoveRatingPlan 

func (rplSv1 *ReplicatorSv1) RemoveRatingPlan(id string, reply *string) error

func (*ReplicatorSv1) RemoveRatingProfile 

func (rplSv1 *ReplicatorSv1) RemoveRatingProfile(id string, reply *string) error

func (*ReplicatorSv1) RemoveResource 

func (rplSv1 *ReplicatorSv1) RemoveResource(args *utils.TenantID, reply *string) error

func (*ReplicatorSv1) RemoveResourceProfile 

func (rplSv1 *ReplicatorSv1) RemoveResourceProfile(args *utils.TenantID, reply *string) error

func (*ReplicatorSv1) RemoveSharedGroup 

func (rplSv1 *ReplicatorSv1) RemoveSharedGroup(id string, reply *string) error

func (*ReplicatorSv1) RemoveStatQueue 

func (rplSv1 *ReplicatorSv1) RemoveStatQueue(args *utils.TenantID, reply *string) error

func (*ReplicatorSv1) RemoveStatQueueProfile 

func (rplSv1 *ReplicatorSv1) RemoveStatQueueProfile(args *utils.TenantID, reply *string) error

func (*ReplicatorSv1) RemoveSupplierProfile 

func (rplSv1 *ReplicatorSv1) RemoveSupplierProfile(args *utils.TenantID, reply *string) error

func (*ReplicatorSv1) RemoveThreshold 

func (rplSv1 *ReplicatorSv1) RemoveThreshold(args *utils.TenantID, reply *string) error

func (*ReplicatorSv1) RemoveThresholdProfile 

func (rplSv1 *ReplicatorSv1) RemoveThresholdProfile(args *utils.TenantID, reply *string) error

func (*ReplicatorSv1) RemoveTiming 

func (rplSv1 *ReplicatorSv1) RemoveTiming(id string, reply *string) error

func (*ReplicatorSv1) SetAccount 

func (rplSv1 *ReplicatorSv1) SetAccount(acc *engine.Account, reply *string) error

SetAccount

func (*ReplicatorSv1) SetAccountActionPlans 

func (rplSv1 *ReplicatorSv1) SetAccountActionPlans(args *engine.SetAccountActionPlansArg, reply *string) error

func (*ReplicatorSv1) SetActionPlan 

func (rplSv1 *ReplicatorSv1) SetActionPlan(args *engine.SetActionPlanArg, reply *string) error

func (*ReplicatorSv1) SetActionTriggers 

func (rplSv1 *ReplicatorSv1) SetActionTriggers(args *engine.SetActionTriggersArg, reply *string) error

func (*ReplicatorSv1) SetActions 

func (rplSv1 *ReplicatorSv1) SetActions(args *engine.SetActionsArgs, reply *string) error

func (*ReplicatorSv1) SetAttributeProfile 

func (rplSv1 *ReplicatorSv1) SetAttributeProfile(ap *engine.AttributeProfile, reply *string) error

func (*ReplicatorSv1) SetChargerProfile 

func (rplSv1 *ReplicatorSv1) SetChargerProfile(cp *engine.ChargerProfile, reply *string) error

func (*ReplicatorSv1) SetDestination 

func (rplSv1 *ReplicatorSv1) SetDestination(dst *engine.Destination, reply *string) error

SetDestination

func (*ReplicatorSv1) SetDispatcherHost 

func (rplSv1 *ReplicatorSv1) SetDispatcherHost(dpp *engine.DispatcherHost, reply *string) error

func (*ReplicatorSv1) SetDispatcherProfile 

func (rplSv1 *ReplicatorSv1) SetDispatcherProfile(dpp *engine.DispatcherProfile, reply *string) error

func (*ReplicatorSv1) SetFilter 

func (rplSv1 *ReplicatorSv1) SetFilter(fltr *engine.Filter, reply *string) error

SetDestination

func (*ReplicatorSv1) SetFilterIndexes 

func (rplSv1 *ReplicatorSv1) SetFilterIndexes(args *utils.SetFilterIndexesArg, reply *string) error

SetFilterIndexes

func (*ReplicatorSv1) SetLoadIDs 

func (rplSv1 *ReplicatorSv1) SetLoadIDs(loadIDs map[string]int64, reply *string) error

func (*ReplicatorSv1) SetRatingPlan 

func (rplSv1 *ReplicatorSv1) SetRatingPlan(rp *engine.RatingPlan, reply *string) error

func (*ReplicatorSv1) SetRatingProfile 

func (rplSv1 *ReplicatorSv1) SetRatingProfile(rp *engine.RatingProfile, reply *string) error

func (*ReplicatorSv1) SetResource 

func (rplSv1 *ReplicatorSv1) SetResource(rs *engine.Resource, reply *string) error

func (*ReplicatorSv1) SetResourceProfile 

func (rplSv1 *ReplicatorSv1) SetResourceProfile(rs *engine.ResourceProfile, reply *string) error

func (*ReplicatorSv1) SetReverseDestination 

func (rplSv1 *ReplicatorSv1) SetReverseDestination(dst *engine.Destination, reply *string) error

SetDestination

func (*ReplicatorSv1) SetSharedGroup 

func (rplSv1 *ReplicatorSv1) SetSharedGroup(shg *engine.SharedGroup, reply *string) error

func (*ReplicatorSv1) SetStatQueue 

func (rplSv1 *ReplicatorSv1) SetStatQueue(ssq *engine.StoredStatQueue, reply *string) error

SetDestination

func (*ReplicatorSv1) SetStatQueueProfile 

func (rplSv1 *ReplicatorSv1) SetStatQueueProfile(sq *engine.StatQueueProfile, reply *string) error

func (*ReplicatorSv1) SetSupplierProfile 

func (rplSv1 *ReplicatorSv1) SetSupplierProfile(sp *engine.SupplierProfile, reply *string) error

func (*ReplicatorSv1) SetThreshold 

func (rplSv1 *ReplicatorSv1) SetThreshold(th *engine.Threshold, reply *string) error

SetThreshold

func (*ReplicatorSv1) SetThresholdProfile 

func (rplSv1 *ReplicatorSv1) SetThresholdProfile(th *engine.ThresholdProfile, reply *string) error

SetThresholdProfile alters/creates a ThresholdProfile

func (*ReplicatorSv1) SetTiming 

func (rplSv1 *ReplicatorSv1) SetTiming(tm *utils.TPTiming, reply *string) error

type ResourceSv1 

type ResourceSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewResourceSv1 

func NewResourceSv1(rls *engine.ResourceService) *ResourceSv1

func (*ResourceSv1) AllocateResources 

func (rsv1 *ResourceSv1) AllocateResources(args utils.ArgRSv1ResourceUsage, reply *string) error

V1InitiateResourceUsage records usage for an event

func (*ResourceSv1) AuthorizeResources 

func (rsv1 *ResourceSv1) AuthorizeResources(args utils.ArgRSv1ResourceUsage, reply *string) error

AuthorizeResources checks if there are limits imposed for event

func (*ResourceSv1) Call 

func (rsv1 *ResourceSv1) Call(ctx *context.Context, serviceMethod string, args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*ResourceSv1) GetResource 

func (rsv1 *ResourceSv1) GetResource(args *utils.TenantID, reply *engine.Resource) error

GetResource returns a resource configuration

func (*ResourceSv1) GetResourcesForEvent 

func (rsv1 *ResourceSv1) GetResourcesForEvent(args utils.ArgRSv1ResourceUsage, reply *engine.Resources) error

GetResourcesForEvent returns Resources matching a specific event

func (*ResourceSv1) Ping 

func (rsv1 *ResourceSv1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

func (*ResourceSv1) ReleaseResources 

func (rsv1 *ResourceSv1) ReleaseResources(args utils.ArgRSv1ResourceUsage, reply *string) error

V1TerminateResourceUsage releases usage for an event

type ResourceSv1Interface 

type ResourceSv1Interface interface {
	GetResourcesForEvent(args utils.ArgRSv1ResourceUsage, reply *engine.Resources) error
	AuthorizeResources(args utils.ArgRSv1ResourceUsage, reply *string) error
	AllocateResources(args utils.ArgRSv1ResourceUsage, reply *string) error
	ReleaseResources(args utils.ArgRSv1ResourceUsage, reply *string) error
	Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error
}

type ResourceWithCache 

type ResourceWithCache struct {
	*engine.ResourceProfile
	Cache *string
}

type ResponderInterface 

type ResponderInterface interface {
	GetCost(arg *engine.CallDescriptorWithArgDispatcher, reply *engine.CallCost) (err error)
	Debit(arg *engine.CallDescriptorWithArgDispatcher, reply *engine.CallCost) (err error)
	MaxDebit(arg *engine.CallDescriptorWithArgDispatcher, reply *engine.CallCost) (err error)
	RefundIncrements(arg *engine.CallDescriptorWithArgDispatcher, reply *engine.Account) (err error)
	RefundRounding(arg *engine.CallDescriptorWithArgDispatcher, reply *engine.Account) (err error)
	GetMaxSessionTime(arg *engine.CallDescriptorWithArgDispatcher, reply *time.Duration) (err error)
	Shutdown(arg *utils.TenantWithArgDispatcher, reply *string) (err error)
	GetCostOnRatingPlans(arg *utils.GetCostOnRatingPlansArgs, reply *map[string]any) (err error)
	GetMaxSessionTimeOnAccounts(arg *utils.GetMaxSessionTimeOnAccountsArgs, reply *map[string]any) (err error)
	Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error
}

type RplExportedCDRs 

type RplExportedCDRs struct {
	ExportedPath              string            // Full path to the newly generated export file
	TotalRecords              int               // Number of CDRs to be exported
	TotalCost                 float64           // Sum of all costs in exported CDRs
	FirstOrderID, LastOrderID int64             // The order id of the last exported CDR
	ExportedCGRIDs            []string          // List of successfully exported cgrids in the file
	UnexportedCGRIDs          map[string]string // Map of errored CDRs, map key is cgrid, value will be the error string
}

RplExportedCDRs contain the reply of the ExportCDRs API

type SMGenericV1 

type SMGenericV1 struct {
	Ss *sessions.SessionS
}

Exports RPC from SMGeneric DEPRECATED, use SessionSv1 instead

func NewSMGenericV1 

func NewSMGenericV1(sS *sessions.SessionS) *SMGenericV1

func (*SMGenericV1) BiRPCV1GetMaxUsage 

func (smgv1 *SMGenericV1) BiRPCV1GetMaxUsage(clnt birpc.ClientConnector,
	ev map[string]any, maxUsage *float64) (err error)

/ Returns MaxUsage (for calls in seconds), -1 for no limit

func (*SMGenericV1) BiRPCV1InitiateSession 

func (smgv1 *SMGenericV1) BiRPCV1InitiateSession(clnt birpc.ClientConnector,
	ev map[string]any, maxUsage *float64) (err error)

Called on session start, returns the maximum number of seconds the session can last

func (*SMGenericV1) BiRPCV1ProcessCDR 

func (smgv1 *SMGenericV1) BiRPCV1ProcessCDR(clnt birpc.ClientConnector,
	ev map[string]any, reply *string) (err error)

Called on session end, should send the CDR to CDRS

func (*SMGenericV1) BiRPCV1TerminateSession 

func (smgv1 *SMGenericV1) BiRPCV1TerminateSession(clnt birpc.ClientConnector,
	ev map[string]any, reply *string) (err error)

Called on session end, should stop debit loop

func (*SMGenericV1) BiRPCV1UpdateSession 

func (smgv1 *SMGenericV1) BiRPCV1UpdateSession(clnt birpc.ClientConnector,
	ev map[string]any, maxUsage *float64) (err error)

Interim updates, returns remaining duration from the rater

func (*SMGenericV1) GetMaxUsage 

func (smgv1 *SMGenericV1) GetMaxUsage(ev map[string]any,
	maxUsage *float64) error

Returns MaxUsage (for calls in seconds), -1 for no limit

func (*SMGenericV1) Handlers 

func (smgv1 *SMGenericV1) Handlers() map[string]any

Publishes methods exported by SMGenericV1 as SMGenericV1 (so we can handle standard RPC methods via birpc socket)

func (*SMGenericV1) InitiateSession 

func (smgv1 *SMGenericV1) InitiateSession(ev map[string]any,
	maxUsage *float64) error

Called on session start, returns the maximum number of seconds the session can last

func (*SMGenericV1) ProcessCDR 

func (smgv1 *SMGenericV1) ProcessCDR(ev map[string]any,
	reply *string) error

Called on session end, should send the CDR to CDRS

func (*SMGenericV1) TerminateSession 

func (smgv1 *SMGenericV1) TerminateSession(ev map[string]any,
	reply *string) error

Called on session end, should stop debit loop

func (*SMGenericV1) UpdateSession 

func (smgv1 *SMGenericV1) UpdateSession(ev map[string]any,
	maxUsage *float64) error

Interim updates, returns remaining duration from the rater

type SchedulerGeter 

type SchedulerGeter interface {
	GetScheduler() *scheduler.Scheduler
}

SchedulerGeter used to avoid ciclic dependency

type SchedulerSv1 

type SchedulerSv1 struct {
	// contains filtered or unexported fields
}

SchedulerSv1 is the RPC object implementing scheduler APIs

func NewSchedulerSv1 

func NewSchedulerSv1(cgrcfg *config.CGRConfig) *SchedulerSv1

NewSchedulerSv1 returns the API for SchedulerS

func (*SchedulerSv1) Call 

func (schdSv1 *SchedulerSv1) Call(ctx *context.Context, serviceMethod string,
	args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*SchedulerSv1) Ping 

func (schdSv1 *SchedulerSv1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

Ping returns Pong

func (*SchedulerSv1) Reload 

func (schdSv1 *SchedulerSv1) Reload(arg *utils.CGREventWithArgDispatcher, reply *string) error

Reload reloads scheduler instructions

type SchedulerSv1Interface 

type SchedulerSv1Interface interface {
	Reload(arg *utils.CGREventWithArgDispatcher, reply *string) error
	Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error
}

type ServiceManagerV1 

type ServiceManagerV1 struct {
	// contains filtered or unexported fields
}

func NewServiceManagerV1 

func NewServiceManagerV1(sm *servmanager.ServiceManager) *ServiceManagerV1

func (*ServiceManagerV1) Call 

func (servManager *ServiceManagerV1) Call(serviceMethod string,
	args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*ServiceManagerV1) Ping 

func (servManager *ServiceManagerV1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

Ping return pong if the service is active

func (*ServiceManagerV1) ServiceStatus 

func (servManager *ServiceManagerV1) ServiceStatus(args dispatchers.ArgStartServiceWithApiKey, reply *string) (err error)

func (*ServiceManagerV1) StartService 

func (servManager *ServiceManagerV1) StartService(args dispatchers.ArgStartServiceWithApiKey, reply *string) (err error)

func (*ServiceManagerV1) StopService 

func (servManager *ServiceManagerV1) StopService(args dispatchers.ArgStartServiceWithApiKey, reply *string) (err error)

type ServiceManagerV1Interface 

type ServiceManagerV1Interface interface {
	StartService(args dispatchers.ArgStartServiceWithApiKey, reply *string) error
	StopService(args dispatchers.ArgStartServiceWithApiKey, reply *string) error
	ServiceStatus(args dispatchers.ArgStartServiceWithApiKey, reply *string) error
	Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error
}

type SessionSv1 

type SessionSv1 struct {
	Ss *sessions.SessionS
}

SessionSv1 exports RPC from SessionSv1

func NewSessionSv1 

func NewSessionSv1(sS *sessions.SessionS) *SessionSv1

func (*SessionSv1) ActivateSessions 

func (ssv1 *SessionSv1) ActivateSessions(args []string, reply *string) error

func (*SessionSv1) AuthorizeEvent 

func (ssv1 *SessionSv1) AuthorizeEvent(args *sessions.V1AuthorizeArgs,
	rply *sessions.V1AuthorizeReply) error

func (*SessionSv1) AuthorizeEventWithDigest 

func (ssv1 *SessionSv1) AuthorizeEventWithDigest(args *sessions.V1AuthorizeArgs,
	rply *sessions.V1AuthorizeReplyWithDigest) error

func (*SessionSv1) BiRPCV1Sleep added in v0.10.2 

func (ssv1 *SessionSv1) BiRPCV1Sleep(ctx *context.Context, args *utils.DurationArgs,
	reply *string) (err error)

func (*SessionSv1) BiRPCv1ActivateSessions 

func (ssv1 *SessionSv1) BiRPCv1ActivateSessions(ctx *context.Context,
	args []string, reply *string) (err error)

func (*SessionSv1) BiRPCv1AuthorizeEvent 

func (ssv1 *SessionSv1) BiRPCv1AuthorizeEvent(ctx *context.Context, args *sessions.V1AuthorizeArgs,
	rply *sessions.V1AuthorizeReply) (err error)

func (*SessionSv1) BiRPCv1AuthorizeEventWithDigest 

func (ssv1 *SessionSv1) BiRPCv1AuthorizeEventWithDigest(ctx *context.Context, args *sessions.V1AuthorizeArgs,
	rply *sessions.V1AuthorizeReplyWithDigest) (err error)

func (*SessionSv1) BiRPCv1DeactivateSessions 

func (ssv1 *SessionSv1) BiRPCv1DeactivateSessions(ctx *context.Context,
	args []string, reply *string) (err error)

func (*SessionSv1) BiRPCv1ForceDisconnect 

func (ssv1 *SessionSv1) BiRPCv1ForceDisconnect(ctx *context.Context, args *utils.SessionFilter,
	rply *string) (err error)

func (*SessionSv1) BiRPCv1GetActiveSessions 

func (ssv1 *SessionSv1) BiRPCv1GetActiveSessions(ctx *context.Context, args *utils.SessionFilter,
	rply *[]*sessions.ExternalSession) (err error)

func (*SessionSv1) BiRPCv1GetActiveSessionsCount 

func (ssv1 *SessionSv1) BiRPCv1GetActiveSessionsCount(ctx *context.Context, args *utils.SessionFilter,
	rply *int) (err error)

func (*SessionSv1) BiRPCv1GetPassiveSessions 

func (ssv1 *SessionSv1) BiRPCv1GetPassiveSessions(ctx *context.Context, args *utils.SessionFilter,
	rply *[]*sessions.ExternalSession) (err error)

func (*SessionSv1) BiRPCv1GetPassiveSessionsCount 

func (ssv1 *SessionSv1) BiRPCv1GetPassiveSessionsCount(ctx *context.Context, args *utils.SessionFilter,
	rply *int) (err error)

func (*SessionSv1) BiRPCv1InitiateSession 

func (ssv1 *SessionSv1) BiRPCv1InitiateSession(ctx *context.Context, args *sessions.V1InitSessionArgs,
	rply *sessions.V1InitSessionReply) (err error)

func (*SessionSv1) BiRPCv1InitiateSessionWithDigest 

func (ssv1 *SessionSv1) BiRPCv1InitiateSessionWithDigest(ctx *context.Context, args *sessions.V1InitSessionArgs,
	rply *sessions.V1InitReplyWithDigest) (err error)

func (*SessionSv1) BiRPCv1Ping added in v0.10.3 

func (ssv1 *SessionSv1) BiRPCv1Ping(ctx *context.Context, ign *utils.CGREventWithArgDispatcher,
	reply *string) (err error)

func (*SessionSv1) BiRPCv1ProcessCDR 

func (ssv1 *SessionSv1) BiRPCv1ProcessCDR(ctx *context.Context, cgrEv *utils.CGREventWithArgDispatcher,
	rply *string) (err error)

func (*SessionSv1) BiRPCv1ProcessEvent 

func (ssv1 *SessionSv1) BiRPCv1ProcessEvent(ctx *context.Context, args *sessions.V1ProcessEventArgs,
	rply *sessions.V1ProcessEventReply) (err error)

func (*SessionSv1) BiRPCv1ProcessMessage 

func (ssv1 *SessionSv1) BiRPCv1ProcessMessage(ctx *context.Context, args *sessions.V1ProcessMessageArgs,
	rply *sessions.V1ProcessMessageReply) (err error)

func (*SessionSv1) BiRPCv1RegisterInternalBiJSONConn 

func (ssv1 *SessionSv1) BiRPCv1RegisterInternalBiJSONConn(ctx *context.Context, args string,
	rply *string) (err error)

func (*SessionSv1) BiRPCv1ReplicateSessions 

func (ssv1 *SessionSv1) BiRPCv1ReplicateSessions(ctx *context.Context,
	args sessions.ArgsReplicateSessions, reply *string) (err error)

func (*SessionSv1) BiRPCv1SetPassiveSession 

func (ssv1 *SessionSv1) BiRPCv1SetPassiveSession(ctx *context.Context,
	args *sessions.Session, reply *string) (err error)

func (*SessionSv1) BiRPCv1SyncSessions 

func (ssv1 *SessionSv1) BiRPCv1SyncSessions(ctx *context.Context, args *string,
	rply *string) (err error)

func (*SessionSv1) BiRPCv1TerminateSession 

func (ssv1 *SessionSv1) BiRPCv1TerminateSession(ctx *context.Context, args *sessions.V1TerminateSessionArgs,
	rply *string) (err error)

func (*SessionSv1) BiRPCv1UpdateSession 

func (ssv1 *SessionSv1) BiRPCv1UpdateSession(ctx *context.Context, args *sessions.V1UpdateSessionArgs,
	rply *sessions.V1UpdateSessionReply) (err error)

func (*SessionSv1) Call 

func (ssv1 *SessionSv1) Call(serviceMethod string,
	args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*SessionSv1) DeactivateSessions 

func (ssv1 *SessionSv1) DeactivateSessions(args []string, reply *string) error

DeactivateSessions is called to deactivate a list/all active sessios

func (*SessionSv1) ForceDisconnect 

func (ssv1 *SessionSv1) ForceDisconnect(args *utils.SessionFilter,
	rply *string) error

func (*SessionSv1) GetActiveSessions 

func (ssv1 *SessionSv1) GetActiveSessions(args *utils.SessionFilter,
	rply *[]*sessions.ExternalSession) error

func (*SessionSv1) GetActiveSessionsCount 

func (ssv1 *SessionSv1) GetActiveSessionsCount(args *utils.SessionFilter,
	rply *int) error

func (*SessionSv1) GetPassiveSessions 

func (ssv1 *SessionSv1) GetPassiveSessions(args *utils.SessionFilter,
	rply *[]*sessions.ExternalSession) error

func (*SessionSv1) GetPassiveSessionsCount 

func (ssv1 *SessionSv1) GetPassiveSessionsCount(args *utils.SessionFilter,
	rply *int) error

func (*SessionSv1) InitiateSession 

func (ssv1 *SessionSv1) InitiateSession(args *sessions.V1InitSessionArgs,
	rply *sessions.V1InitSessionReply) error

func (*SessionSv1) InitiateSessionWithDigest 

func (ssv1 *SessionSv1) InitiateSessionWithDigest(args *sessions.V1InitSessionArgs,
	rply *sessions.V1InitReplyWithDigest) error

func (*SessionSv1) Ping 

func (ssv1 *SessionSv1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

func (*SessionSv1) ProcessCDR 

func (ssv1 *SessionSv1) ProcessCDR(cgrEv *utils.CGREventWithArgDispatcher, rply *string) error

func (*SessionSv1) ProcessEvent 

func (ssv1 *SessionSv1) ProcessEvent(args *sessions.V1ProcessEventArgs,
	rply *sessions.V1ProcessEventReply) error

func (*SessionSv1) ProcessMessage 

func (ssv1 *SessionSv1) ProcessMessage(args *sessions.V1ProcessMessageArgs,
	rply *sessions.V1ProcessMessageReply) error

func (*SessionSv1) ReplicateSessions 

func (ssv1 *SessionSv1) ReplicateSessions(args dispatchers.ArgsReplicateSessionsWithApiKey, rply *string) error

func (*SessionSv1) SetPassiveSession 

func (ssv1 *SessionSv1) SetPassiveSession(args *sessions.Session,
	reply *string) error

func (*SessionSv1) SyncSessions 

func (ssv1 *SessionSv1) SyncSessions(args *string,
	rply *string) error

func (*SessionSv1) TerminateSession 

func (ssv1 *SessionSv1) TerminateSession(args *sessions.V1TerminateSessionArgs,
	rply *string) error

func (*SessionSv1) UpdateSession 

func (ssv1 *SessionSv1) UpdateSession(args *sessions.V1UpdateSessionArgs,
	rply *sessions.V1UpdateSessionReply) error

type SessionSv1Interface 

type SessionSv1Interface interface {
	AuthorizeEvent(args *sessions.V1AuthorizeArgs, rply *sessions.V1AuthorizeReply) error
	AuthorizeEventWithDigest(args *sessions.V1AuthorizeArgs, rply *sessions.V1AuthorizeReplyWithDigest) error
	InitiateSession(args *sessions.V1InitSessionArgs, rply *sessions.V1InitSessionReply) error
	InitiateSessionWithDigest(args *sessions.V1InitSessionArgs, rply *sessions.V1InitReplyWithDigest) error
	UpdateSession(args *sessions.V1UpdateSessionArgs, rply *sessions.V1UpdateSessionReply) error
	// SyncSessions(args *string, rply *string) error
	TerminateSession(args *sessions.V1TerminateSessionArgs, rply *string) error
	ProcessCDR(cgrEv *utils.CGREventWithArgDispatcher, rply *string) error
	ProcessMessage(args *sessions.V1ProcessMessageArgs, rply *sessions.V1ProcessMessageReply) error
	ProcessEvent(args *sessions.V1ProcessEventArgs, rply *sessions.V1ProcessEventReply) error
	GetActiveSessions(args *utils.SessionFilter, rply *[]*sessions.ExternalSession) error
	GetActiveSessionsCount(args *utils.SessionFilter, rply *int) error
	ForceDisconnect(args *utils.SessionFilter, rply *string) error
	GetPassiveSessions(args *utils.SessionFilter, rply *[]*sessions.ExternalSession) error
	GetPassiveSessionsCount(args *utils.SessionFilter, rply *int) error
	Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error
	ReplicateSessions(args dispatchers.ArgsReplicateSessionsWithApiKey, rply *string) error
	SetPassiveSession(args *sessions.Session, reply *string) error
}

type SetVersionsArg 

type SetVersionsArg struct {
	Versions  engine.Versions
	Overwrite bool
}

type StatSv1 

type StatSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewStatSv1 

func NewStatSv1(sS *engine.StatService) *StatSv1

NewStatSV1 initializes StatSV1

func (*StatSv1) Call 

func (stsv1 *StatSv1) Call(ctx *context.Context, serviceMethod string, args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*StatSv1) GetQueueFloatMetrics 

func (stsv1 *StatSv1) GetQueueFloatMetrics(args *utils.TenantIDWithArgDispatcher, reply *map[string]float64) (err error)

GetQueueFloatMetrics returns the float metrics for a Queue

func (*StatSv1) GetQueueIDs 

func (stsv1 *StatSv1) GetQueueIDs(tenant *utils.TenantWithArgDispatcher, qIDs *[]string) error

GetQueueIDs returns list of queueIDs registered for a tenant

func (*StatSv1) GetQueueStringMetrics 

func (stsv1 *StatSv1) GetQueueStringMetrics(args *utils.TenantIDWithArgDispatcher, reply *map[string]string) (err error)

GetStringMetrics returns the string metrics for a Queue

func (*StatSv1) GetStatQueue added in v0.10.1 

func (stsv1 *StatSv1) GetStatQueue(args *utils.TenantIDWithArgDispatcher, reply *engine.StatQueue) (err error)

GetStatQueue returns a StatQueue object

func (*StatSv1) GetStatQueuesForEvent 

func (stsv1 *StatSv1) GetStatQueuesForEvent(args *engine.StatsArgsProcessEvent, reply *[]string) (err error)

GetQueueIDs returns the list of queues IDs in the system

func (*StatSv1) Ping 

func (stSv1 *StatSv1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

func (*StatSv1) ProcessEvent 

func (stsv1 *StatSv1) ProcessEvent(args *engine.StatsArgsProcessEvent, reply *[]string) error

ProcessEvent returns processes a new Event

type StatSv1Interface 

type StatSv1Interface interface {
	GetQueueIDs(tenant *utils.TenantWithArgDispatcher, qIDs *[]string) error
	ProcessEvent(args *engine.StatsArgsProcessEvent, reply *[]string) error
	GetStatQueuesForEvent(args *engine.StatsArgsProcessEvent, reply *[]string) (err error)
	GetQueueStringMetrics(args *utils.TenantIDWithArgDispatcher, reply *map[string]string) (err error)
	GetQueueFloatMetrics(args *utils.TenantIDWithArgDispatcher, reply *map[string]float64) (err error)
	Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error
}

type SupplierSv1 

type SupplierSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from SupplierS

func NewSupplierSv1 

func NewSupplierSv1(splS *engine.SupplierService) *SupplierSv1

func (*SupplierSv1) Call 

func (splv1 *SupplierSv1) Call(ctx *context.Context, serviceMethod string,
	args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*SupplierSv1) GetSupplierProfilesForEvent 

func (splv1 *SupplierSv1) GetSupplierProfilesForEvent(args *utils.CGREventWithArgDispatcher,
	reply *[]*engine.SupplierProfile) error

GetSuppliersProfiles returns a list of suppliers profiles that match for Event

func (*SupplierSv1) GetSuppliers 

func (splv1 *SupplierSv1) GetSuppliers(args *engine.ArgsGetSuppliers,
	reply *engine.SortedSuppliers) error

GetSuppliers returns sorted list of suppliers for Event

func (*SupplierSv1) Ping 

func (splv1 *SupplierSv1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

type SupplierSv1Interface 

type SupplierSv1Interface interface {
	GetSuppliers(args *engine.ArgsGetSuppliers, reply *engine.SortedSuppliers) error
	GetSupplierProfilesForEvent(args *utils.CGREventWithArgDispatcher, reply *[]*engine.SupplierProfile) error
	Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error
}

type SupplierWithCache 

type SupplierWithCache struct {
	*engine.SupplierProfile
	Cache *string
}

type ThresholdSv1 

type ThresholdSv1 struct {
	// contains filtered or unexported fields
}

Exports RPC from RLs

func NewThresholdSv1 

func NewThresholdSv1(tS *engine.ThresholdService) *ThresholdSv1

NewThresholdSV1 initializes ThresholdSV1

func (*ThresholdSv1) Call 

func (tSv1 *ThresholdSv1) Call(ctx *context.Context, serviceMethod string, args any, reply any) error

Call implements birpc.ClientConnector interface for internal RPC

func (*ThresholdSv1) GetThreshold 

func (tSv1 *ThresholdSv1) GetThreshold(tntID *utils.TenantIDWithArgDispatcher, t *engine.Threshold) error

GetThreshold queries a Threshold

func (*ThresholdSv1) GetThresholdIDs 

func (tSv1 *ThresholdSv1) GetThresholdIDs(tenant *utils.TenantWithArgDispatcher, tIDs *[]string) error

GetThresholdIDs returns list of threshold IDs registered for a tenant

func (*ThresholdSv1) GetThresholdsForEvent 

func (tSv1 *ThresholdSv1) GetThresholdsForEvent(args *engine.ArgsProcessEvent, reply *engine.Thresholds) error

GetThresholdsForEvent returns a list of thresholds matching an event

func (*ThresholdSv1) Ping 

func (tSv1 *ThresholdSv1) Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error

func (*ThresholdSv1) ProcessEvent 

func (tSv1 *ThresholdSv1) ProcessEvent(args *engine.ArgsProcessEvent, tIDs *[]string) error

ProcessEvent will process an Event

type ThresholdSv1Interface 

type ThresholdSv1Interface interface {
	GetThresholdIDs(tenant *utils.TenantWithArgDispatcher, tIDs *[]string) error
	GetThresholdsForEvent(args *engine.ArgsProcessEvent, reply *engine.Thresholds) error
	GetThreshold(tntID *utils.TenantIDWithArgDispatcher, t *engine.Threshold) error
	ProcessEvent(args *engine.ArgsProcessEvent, tIDs *[]string) error
	Ping(ign *utils.CGREventWithArgDispatcher, reply *string) error
}

type V1AttrSetActions 

type V1AttrSetActions struct {
	ActionsId string        // Actions id
	Overwrite bool          // If previously defined, will be overwritten
	Actions   []*V1TPAction // Set of actions this Actions profile will perform
}

Deprecated attrs

type V1TPAction 

type V1TPAction struct {
	Identifier      string   // Identifier mapped in the code
	BalanceId       string   // Balance identification string (account scope)
	BalanceUuid     string   // Balance identification string (global scope)
	BalanceType     string   // Type of balance the action will operate on
	Units           float64  // Number of units to add/deduct
	ExpiryTime      string   // Time when the units will expire
	Filter          string   // The condition on balances that is checked before the action
	TimingTags      string   // Timing when balance is active
	DestinationIds  string   // Destination profile id
	RatingSubject   string   // Reference a rate subject defined in RatingProfiles
	Categories      string   // category filter for balances
	SharedGroups    string   // Reference to a shared group
	BalanceWeight   *float64 // Balance weight
	ExtraParameters string
	BalanceBlocker  string
	BalanceDisabled string
	Weight          float64 // Action's weight
}

type V1TPActions 

type V1TPActions struct {
	TPid      string        // Tariff plan id
	ActionsId string        // Actions id
	Actions   []*V1TPAction // Set of actions this Actions profile will perform
}

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.