v1

package
Version: v0.10.2 Latest Latest
Warning

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

Go to latest
Published: Oct 8, 2020 License: GPL-3.0 Imports: 29 Imported by: 14

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(serviceMethod string,
	args interface{}, reply interface{}) error

Call implements rpcclient.ClientConnector interface for internal RPC

func (*APIerSv1) CallCache

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

CallCache caching the item based on cacheopt visible in APIerSv2

func (*APIerSv1) ComputeAccountActionPlans

func (apiv1 *APIerSv1) ComputeAccountActionPlans(ignr string, 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 *interface{}) error

GetAccount returns the account

func (*APIerSv1) GetAccountActionPlan

func (api *APIerSv1) GetAccountActionPlan(attrs utils.TenantAccount, reply *[]*AccountActionTiming) 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 *[]interface{}) 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) 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) 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) 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) GetReverseDestination

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

GetReverseDestination retrieves revese destination list for a prefix

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) 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) 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) 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(serviceMethod string,
	args interface{}, reply interface{}) error

Call implements rpcclient.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]interface{}
	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]interface{}
	ActionExtraData *map[string]interface{}
	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
}

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]interface{}
}

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(serviceMethod string,
	args interface{}, reply interface{}) error

Call implements rpcclient.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 maching 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 interface{}, reply interface{}) error

Call implements rpcclient.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(serviceMethod string,
	args interface{}, reply interface{}) error

Call implements rpcclient.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(serviceMethod string,
	args interface{}, reply interface{}) error

Call implements rpcclient.ClientConnector interface for internal RPC

func (*ConfigSv1) GetJSONSection

func (cSv1 *ConfigSv1) GetJSONSection(section *config.StringWithArgDispatcher, reply *map[string]interface{}) (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]interface{}) (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(serviceMethod string,
	args interface{}, reply interface{}) error

Call implements rpcclient.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 *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]interface{}) error

type CoreSv1Interface

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

type DispatcherAttributeSv1

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

Exports RPC from RLs

func (*DispatcherAttributeSv1) GetAttributeForEvent

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

GetAttributeForEvent implements AttributeSv1GetAttributeForEvent

func (*DispatcherAttributeSv1) Ping

Ping implements SupplierSv1Ping

func (*DispatcherAttributeSv1) ProcessEvent

ProcessEvent implements AttributeSv1ProcessEvent

type DispatcherCacheSv1

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

Exports RPC from CacheSv1

func (*DispatcherCacheSv1) Clear

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

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

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

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

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

RemoveItem removes the Item with ID from cache

type DispatcherChargerSv1

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

Exports RPC from RLs

func (*DispatcherChargerSv1) GetChargersForEvent

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

GetChargersForEvent implements ChargerSv1GetChargersForEvent

func (*DispatcherChargerSv1) Ping

Ping implements ChargerSv1Ping

func (*DispatcherChargerSv1) ProcessEvent

ProcessEvent implements ChargerSv1ProcessEvent

type DispatcherConfigSv1

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

Exports RPC from CDRsV1

func (*DispatcherConfigSv1) GetJSONSection

func (dS *DispatcherConfigSv1) GetJSONSection(args *config.StringWithArgDispatcher, reply *map[string]interface{}) (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 (*DispatcherCoreSv1) Ping

Ping used to detreminate if component is active

func (*DispatcherCoreSv1) Status

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

type DispatcherGuardianSv1

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

Exports RPC from CacheSv1

func (*DispatcherGuardianSv1) Ping

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 (*DispatcherRALsV1) GetRatingPlansCost

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

func (*DispatcherRALsV1) Ping

Ping used to detreminate if component is active

type DispatcherResourceSv1

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

Exports RPC from RLs

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

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 (*DispatcherResponder) Debit

func (*DispatcherResponder) GetCost

func (*DispatcherResponder) GetMaxSessionTime

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

func (*DispatcherResponder) MaxDebit

func (*DispatcherResponder) Ping

Ping used to detreminate 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 *float64) 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 (*DispatcherSCDRsV1) GetCDRs

func (*DispatcherSCDRsV1) GetCDRsCount

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

func (*DispatcherSCDRsV1) Ping

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 (*DispatcherSServiceManagerV1) Ping

Ping used to detreminate if component is active

func (*DispatcherSServiceManagerV1) ServiceStatus

func (*DispatcherSServiceManagerV1) StartService

func (*DispatcherSServiceManagerV1) StopService

type DispatcherSchedulerSv1

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

Exports RPC from SchedulerSv1

func (*DispatcherSchedulerSv1) Ping

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 (*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

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

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

UpdateSession implements SessionSv1UpdateSession

type DispatcherStatSv1

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

Exports RPC from RLs

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 (*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

Ping implements SupplierSv1Ping

type DispatcherSv1

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

func (DispatcherSv1) Apier

func (dSv1 DispatcherSv1) Apier(args *utils.MethodParameters, reply *interface{}) (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 (*DispatcherThresholdSv1) GetThreshold

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

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 DurationArgs added in v0.10.2

type DurationArgs struct {
	DurationTime time.Duration
}

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(serviceMethod string,
	args interface{}, reply interface{}) error

Call implements rpcclient.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(serviceMethod string,
	args interface{}, reply interface{}) error

Call implements rpcclient.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(serviceMethod string, args interface{}, reply interface{}) error

Call implements rpcclient.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 interface{}, reply interface{}) error

Call implements rpcclient.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(serviceMethod string, args interface{}, reply interface{}) error

Call implements rpcclient.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 *float64) (err error)
	GetMaxSessionTime(arg *engine.CallDescriptorWithArgDispatcher, reply *time.Duration) (err error)
	Shutdown(arg *utils.TenantWithArgDispatcher, reply *string) (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 successfuly 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 *rpc2.Client,
	ev map[string]interface{}, maxUsage *float64) (err error)

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

func (*SMGenericV1) BiRPCV1InitiateSession

func (smgv1 *SMGenericV1) BiRPCV1InitiateSession(clnt *rpc2.Client,
	ev map[string]interface{}, 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 *rpc2.Client,
	ev map[string]interface{}, reply *string) (err error)

Called on session end, should send the CDR to CDRS

func (*SMGenericV1) BiRPCV1TerminateSession

func (smgv1 *SMGenericV1) BiRPCV1TerminateSession(clnt *rpc2.Client,
	ev map[string]interface{}, reply *string) (err error)

Called on session end, should stop debit loop

func (*SMGenericV1) BiRPCV1UpdateSession

func (smgv1 *SMGenericV1) BiRPCV1UpdateSession(clnt *rpc2.Client,
	ev map[string]interface{}, maxUsage *float64) (err error)

Interim updates, returns remaining duration from the rater

func (*SMGenericV1) GetMaxUsage

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

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

func (*SMGenericV1) Handlers

func (smgv1 *SMGenericV1) Handlers() map[string]interface{}

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]interface{},
	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]interface{},
	reply *string) error

Called on session end, should send the CDR to CDRS

func (*SMGenericV1) TerminateSession

func (smgv1 *SMGenericV1) TerminateSession(ev map[string]interface{},
	reply *string) error

Called on session end, should stop debit loop

func (*SMGenericV1) UpdateSession

func (smgv1 *SMGenericV1) UpdateSession(ev map[string]interface{},
	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 retuns the API for SchedulerS

func (*SchedulerSv1) Call

func (schdSv1 *SchedulerSv1) Call(serviceMethod string,
	args interface{}, reply interface{}) error

Call implements rpcclient.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 interface{}, reply interface{}) error

Call implements rpcclient.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) BiRPCPing

func (ssv1 *SessionSv1) BiRPCPing(clnt *rpc2.Client, ign *utils.CGREventWithArgDispatcher,
	reply *string) (err error)

func (*SessionSv1) BiRPCV1Sleep added in v0.10.2

func (ssv1 *SessionSv1) BiRPCV1Sleep(clnt *rpc2.Client, arg *DurationArgs,
	reply *string) (err error)

func (*SessionSv1) BiRPCv1ActivateSessions

func (ssv1 *SessionSv1) BiRPCv1ActivateSessions(clnt *rpc2.Client,
	args []string, reply *string) (err error)

func (*SessionSv1) BiRPCv1AuthorizeEvent

func (ssv1 *SessionSv1) BiRPCv1AuthorizeEvent(clnt *rpc2.Client, args *sessions.V1AuthorizeArgs,
	rply *sessions.V1AuthorizeReply) (err error)

func (*SessionSv1) BiRPCv1AuthorizeEventWithDigest

func (ssv1 *SessionSv1) BiRPCv1AuthorizeEventWithDigest(clnt *rpc2.Client, args *sessions.V1AuthorizeArgs,
	rply *sessions.V1AuthorizeReplyWithDigest) (err error)

func (*SessionSv1) BiRPCv1DeactivateSessions

func (ssv1 *SessionSv1) BiRPCv1DeactivateSessions(clnt *rpc2.Client,
	args []string, reply *string) (err error)

func (*SessionSv1) BiRPCv1ForceDisconnect

func (ssv1 *SessionSv1) BiRPCv1ForceDisconnect(clnt *rpc2.Client, args *utils.SessionFilter,
	rply *string) (err error)

func (*SessionSv1) BiRPCv1GetActiveSessions

func (ssv1 *SessionSv1) BiRPCv1GetActiveSessions(clnt *rpc2.Client, args *utils.SessionFilter,
	rply *[]*sessions.ExternalSession) (err error)

func (*SessionSv1) BiRPCv1GetActiveSessionsCount

func (ssv1 *SessionSv1) BiRPCv1GetActiveSessionsCount(clnt *rpc2.Client, args *utils.SessionFilter,
	rply *int) (err error)

func (*SessionSv1) BiRPCv1GetPassiveSessions

func (ssv1 *SessionSv1) BiRPCv1GetPassiveSessions(clnt *rpc2.Client, args *utils.SessionFilter,
	rply *[]*sessions.ExternalSession) (err error)

func (*SessionSv1) BiRPCv1GetPassiveSessionsCount

func (ssv1 *SessionSv1) BiRPCv1GetPassiveSessionsCount(clnt *rpc2.Client, args *utils.SessionFilter,
	rply *int) (err error)

func (*SessionSv1) BiRPCv1InitiateSession

func (ssv1 *SessionSv1) BiRPCv1InitiateSession(clnt *rpc2.Client, args *sessions.V1InitSessionArgs,
	rply *sessions.V1InitSessionReply) (err error)

func (*SessionSv1) BiRPCv1InitiateSessionWithDigest

func (ssv1 *SessionSv1) BiRPCv1InitiateSessionWithDigest(clnt *rpc2.Client, args *sessions.V1InitSessionArgs,
	rply *sessions.V1InitReplyWithDigest) (err error)

func (*SessionSv1) BiRPCv1ProcessCDR

func (ssv1 *SessionSv1) BiRPCv1ProcessCDR(clnt *rpc2.Client, cgrEv *utils.CGREventWithArgDispatcher,
	rply *string) (err error)

func (*SessionSv1) BiRPCv1ProcessEvent

func (ssv1 *SessionSv1) BiRPCv1ProcessEvent(clnt *rpc2.Client, args *sessions.V1ProcessEventArgs,
	rply *sessions.V1ProcessEventReply) (err error)

func (*SessionSv1) BiRPCv1ProcessMessage

func (ssv1 *SessionSv1) BiRPCv1ProcessMessage(clnt *rpc2.Client, args *sessions.V1ProcessMessageArgs,
	rply *sessions.V1ProcessMessageReply) (err error)

func (*SessionSv1) BiRPCv1RegisterInternalBiJSONConn

func (ssv1 *SessionSv1) BiRPCv1RegisterInternalBiJSONConn(clnt *rpc2.Client, args string,
	rply *string) (err error)

func (*SessionSv1) BiRPCv1ReplicateSessions

func (ssv1 *SessionSv1) BiRPCv1ReplicateSessions(clnt *rpc2.Client,
	args sessions.ArgsReplicateSessions, reply *string) (err error)

func (*SessionSv1) BiRPCv1SetPassiveSession

func (ssv1 *SessionSv1) BiRPCv1SetPassiveSession(clnt *rpc2.Client,
	args *sessions.Session, reply *string) (err error)

func (*SessionSv1) BiRPCv1SyncSessions

func (ssv1 *SessionSv1) BiRPCv1SyncSessions(clnt *rpc2.Client, args *string,
	rply *string) (err error)

func (*SessionSv1) BiRPCv1TerminateSession

func (ssv1 *SessionSv1) BiRPCv1TerminateSession(clnt *rpc2.Client, args *sessions.V1TerminateSessionArgs,
	rply *string) (err error)

func (*SessionSv1) BiRPCv1UpdateSession

func (ssv1 *SessionSv1) BiRPCv1UpdateSession(clnt *rpc2.Client, args *sessions.V1UpdateSessionArgs,
	rply *sessions.V1UpdateSessionReply) (err error)

func (*SessionSv1) Call

func (ssv1 *SessionSv1) Call(serviceMethod string,
	args interface{}, reply interface{}) error

Call implements rpcclient.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) Handlers

func (ssv1 *SessionSv1) Handlers() map[string]interface{}

Bidirectional JSON methods following

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(serviceMethod string, args interface{}, reply interface{}) error

Call implements rpcclient.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(serviceMethod string,
	args interface{}, reply interface{}) error

Call implements rpcclient.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(serviceMethod string, args interface{}, reply interface{}) error

Call implements rpcclient.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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL