v1

package

Go to main page

Versions in this module

v0

v0.10.3

Aug 9, 2023

Changes in this version

type APIerSv1

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

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

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

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

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

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

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

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

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

type AttrRemoveRatingProfile

+ Cache *string

type DispatcherResponder

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

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

type ResponderInterface

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

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

type SessionSv1

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

v0.10.2

Oct 8, 2020

Changes in this version

type CoreSv1

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

+ type DurationArgs struct

+ DurationTime time.Duration

type SessionSv1

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

v0.10.1

May 12, 2020

Changes in this version

type StatSv1

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

v0.10.0

Feb 6, 2020

Changes in this version

+ func GetCacheOpt(apiOpt *string) string

+ type APIerSv1 struct

+ CdrDb engine.CdrStorage

+ Config *config.CGRConfig

+ ConnMgr *engine.ConnManager

+ DataManager *engine.DataManager

+ FilterS *engine.FilterS

+ Responder *engine.Responder

+ SchedulerService SchedulerGeter

+ StorDBChan chan engine.StorDB

+ StorDb engine.LoadStorage

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (api *APIerSv1) GetAccount(attr *utils.AttrGetAccount, reply *interface{}) error

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

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

+ func (api *APIerSv1) GetAccounts(attr utils.AttrGetAccounts, reply *[]interface{}) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (apiv1 *APIerSv1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type AccountActionTiming struct

+ ActionPlanId string

+ ActionsId string

+ NextExecTime time.Time

+ Uuid string

+ type AnalyzerSv1 struct

+ func NewAnalyzerSv1(aS *analyzers.AnalyzerService) *AnalyzerSv1

+ func (aSv1 *AnalyzerSv1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

+ type ArgExportCDRs struct

+ ExportArgs map[string]interface{}

+ Verbose bool

+ type ArgsReplyFailedPosts struct

+ FailedRequestsInDir *string

+ FailedRequestsOutDir *string

+ Modules []string

+ type AttrActionPlan struct

+ ActionsId string

+ MonthDays string

+ Months string

+ Time string

+ WeekDays string

+ Weight float64

+ Years string

+ type AttrAddAccountActionTriggers struct

+ Account string

+ ActionTriggerIDs []string

+ ActionTriggerOverwrite bool

+ ActivationDate string

+ Executed bool

+ Tenant string

+ type AttrAddActionTrigger struct

+ Account string

+ ActionTriggersId string

+ ActionsId string

+ BalanceDestinationIds string

+ BalanceExpiryTime string

+ BalanceId string

+ BalanceRatingSubject string

+ BalanceSharedGroup string

+ BalanceType string

+ BalanceWeight float64

+ Tenant string

+ ThresholdType string

+ ThresholdValue float64

+ Weight float64

+ type AttrAddBalance struct

+ Account string

+ ActionExtraData *map[string]interface{}

+ Balance map[string]interface{}

+ BalanceType string

+ Cdrlog bool

+ Overwrite bool

+ Tenant string

+ Value float64

+ type AttrDebitUsageWithOptions struct

+ AllowNegativeAccount bool

+ UsageRecord *engine.UsageRecordWithArgDispatcher

+ type AttrGetActionPlan struct

+ ID string

+ type AttrGetActionTriggers struct

+ GroupIDs []string

+ type AttrGetCost struct

+ AnswerTime string

+ Category string

+ Destination string

+ Subject string

+ Tenant string

+ Usage string

+ type AttrGetDataCost struct

+ AnswerTime string

+ Category string

+ Subject string

+ Tenant string

+ Usage time.Duration

+ type AttrGetFilterIndexes struct

+ Context string

+ FilterField string

+ FilterType string

+ FilterValue string

+ ItemType string

+ Tenant string

+ type AttrGetTPAccountActionIds struct

+ TPid string

+ type AttrGetTPAccountActions struct

+ AccountActionsId string

+ TPid string

+ type AttrGetTPAccountActionsByLoadId struct

+ LoadId string

+ TPid string

+ type AttrGetTPActionIds struct

+ TPid string

+ type AttrGetTPActionPlan struct

+ ID string

+ TPid string

+ type AttrGetTPActionPlanIds struct

+ TPid string

+ type AttrGetTPActionTriggerIds struct

+ TPid string

+ type AttrGetTPActionTriggers struct

+ ID string

+ TPid string

+ type AttrGetTPActions struct

+ ID string

+ TPid string

+ type AttrGetTPAttributeProfileIds struct

+ TPid string

+ type AttrGetTPChargerIds struct

+ TPid string

+ type AttrGetTPDestination struct

+ ID string

+ TPid string

+ type AttrGetTPDestinationIds struct

+ TPid string

+ type AttrGetTPDestinationRate struct

+ ID string

+ TPid string

+ type AttrGetTPDispatcherIds struct

+ TPid string

+ type AttrGetTPFilterProfileIds struct

+ TPid string

+ type AttrGetTPIds struct

+ type AttrGetTPRate struct

+ ID string

+ TPid string

+ type AttrGetTPRateIds struct

+ TPid string

+ type AttrGetTPRatingPlan struct

+ ID string

+ TPid string

+ type AttrGetTPRatingPlanIds struct

+ TPid string

+ type AttrGetTPRatingProfile struct

+ RatingProfileID string

+ TPid string

+ type AttrGetTPRatingProfileIds struct

+ TPid string

+ type AttrGetTPResourceIds struct

+ TPid string

+ type AttrGetTPSharedGroupIds struct

+ TPid string

+ type AttrGetTPSharedGroups struct

+ ID string

+ TPid string

+ type AttrGetTPStatIds struct

+ TPid string

+ Tenant string

+ type AttrGetTPSupplierProfileIDs struct

+ TPid string

+ type AttrGetTPThresholdIds struct

+ TPid string

+ Tenant string

+ type AttrGetTPTiming struct

+ ID string

+ TPid string

+ type AttrGetTPTimingIds struct

+ TPid string

+ type AttrImportTPZipFile struct

+ File []byte

+ TPid string

+ type AttrLoadDestination struct

+ ID string

+ TPid string

+ type AttrLoadRatingPlan struct

+ RatingPlanId string

+ TPid string

+ type AttrLoadSharedGroup struct

+ SharedGroupId string

+ TPid string

+ type AttrLoadTpFromStorDb struct

+ ArgDispatcher *utils.ArgDispatcher

+ Caching *string

+ DryRun bool

+ TPid string

+ Validate bool

+ type AttrRemFilterIndexes struct

+ Context string

+ ItemType string

+ Tenant string

+ type AttrRemTp struct

+ TPid string

+ type AttrRemoveAccountActionTriggers struct

+ Account string

+ GroupID string

+ Tenant string

+ UniqueID string

+ type AttrRemoveActionTiming struct

+ Account string

+ ActionPlanId string

+ ActionTimingId string

+ ReloadScheduler bool

+ Tenant string

+ type AttrRemoveActionTrigger struct

+ GroupID string

+ UniqueID string

+ type AttrRemoveActions struct

+ ActionIDs []string

+ type AttrRemoveDestination struct

+ DestinationIDs []string

+ Prefixes []string

+ type AttrRemoveRatingProfile struct

+ Category string

+ Subject string

+ Tenant string

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

+ type AttrResetAccountActionTriggers struct

+ Account string

+ Executed bool

+ GroupID string

+ Tenant string

+ UniqueID string

+ type AttrSetAccountActionTriggers struct

+ Account string

+ Tenant string

+ type AttrSetActionPlan struct

+ ActionPlan []*AttrActionPlan

+ Id string

+ Overwrite bool

+ ReloadScheduler bool

+ type AttrSetActionTrigger struct

+ ActionTrigger map[string]interface{}

+ GroupID string

+ UniqueID string

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

+ type AttrTPDestinationRateIds struct

+ TPid string

+ type AttributeSv1 struct

+ func NewAttributeSv1(attrS *engine.AttributeService) *AttributeSv1

+ func (alSv1 *AttributeSv1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

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

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

+ type AttributeSv1Interface interface

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

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

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

+ type AttributeWithCache struct

+ Cache *string

+ type AttrsExecuteScheduledActions struct

+ ActionPlanID string

+ TimeEnd time.Time

+ TimeStart time.Time

+ type CDRsV1 struct

+ CDRs *engine.CDRServer

+ func NewCDRsV1(CDRs *engine.CDRServer) *CDRsV1

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

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

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

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

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

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

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

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

+ type CDRsV1Interface interface

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

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

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

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

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

+ type CacheSv1 struct

+ func NewCacheSv1(cacheS *engine.CacheS) *CacheSv1

+ func (chSv1 *CacheSv1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

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

+ func (chSv1 *CacheSv1) GetCacheStats(args *utils.AttrCacheIDsWithArgDispatcher, ...) error

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

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

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

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

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

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

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

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

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

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

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

+ type CacheSv1Interface interface

+ Clear func(cacheIDs *utils.AttrCacheIDsWithArgDispatcher, reply *string) error

+ FlushCache func(args utils.AttrReloadCacheWithArgDispatcher, reply *string) error

+ GetCacheStats func(cacheIDs *utils.AttrCacheIDsWithArgDispatcher, ...) error

+ GetGroupItemIDs func(args *utils.ArgsGetGroupWithArgDispatcher, rply *[]string) error

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

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

+ HasGroup func(args *utils.ArgsGetGroupWithArgDispatcher, rply *bool) error

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

+ LoadCache func(args utils.AttrReloadCacheWithArgDispatcher, reply *string) error

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

+ PrecacheStatus func(cacheIDs *utils.AttrCacheIDsWithArgDispatcher, rply *map[string]string) error

+ ReloadCache func(attrs utils.AttrReloadCacheWithArgDispatcher, reply *string) error

+ RemoveGroup func(args *utils.ArgsGetGroupWithArgDispatcher, rply *string) error

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

+ type ChargerSv1 struct

+ func NewChargerSv1(cS *engine.ChargerService) *ChargerSv1

+ func (cSv1 *ChargerSv1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

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

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

+ type ChargerSv1Interface interface

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

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

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

+ type ChargerWithCache struct

+ Cache *string

+ type ConfigPathArg struct

+ ConfigPath string

+ type ConfigSv1 struct

+ func NewConfigSv1(cfg *config.CGRConfig) *ConfigSv1

+ func (cSv1 *ConfigSv1) Call(serviceMethod string, args interface{}, reply interface{}) error

+ func (cSv1 *ConfigSv1) GetJSONSection(section *config.StringWithArgDispatcher, reply *map[string]interface{}) (err error)

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

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

+ type ConfigSv1Interface interface

+ GetJSONSection func(section *config.StringWithArgDispatcher, reply *map[string]interface{}) (err error)

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

+ ReloadConfigFromPath func(section *config.ConfigReloadWithArgDispatcher, reply *string) (err error)

+ type CoreSv1 struct

+ func NewCoreSv1(cS *engine.CoreService) *CoreSv1

+ func (cS *CoreSv1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

+ func (cS *CoreSv1) Status(arg *utils.TenantWithArgDispatcher, reply *map[string]interface{}) error

+ type CoreSv1Interface interface

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

+ Status func(arg *utils.TenantWithArgDispatcher, reply *map[string]interface{}) error

+ type DispatcherAttributeSv1 struct

+ func NewDispatcherAttributeSv1(dps *dispatchers.DispatcherService) *DispatcherAttributeSv1

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

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

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

+ type DispatcherCacheSv1 struct

+ func NewDispatcherCacheSv1(dps *dispatchers.DispatcherService) *DispatcherCacheSv1

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

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

+ func (dS *DispatcherCacheSv1) GetCacheStats(args *utils.AttrCacheIDsWithArgDispatcher, ...) error

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

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

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

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

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

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

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

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

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

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

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

+ type DispatcherChargerSv1 struct

+ func NewDispatcherChargerSv1(dps *dispatchers.DispatcherService) *DispatcherChargerSv1

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

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

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

+ type DispatcherConfigSv1 struct

+ func NewDispatcherConfigSv1(dps *dispatchers.DispatcherService) *DispatcherConfigSv1

+ func (dS *DispatcherConfigSv1) GetJSONSection(args *config.StringWithArgDispatcher, reply *map[string]interface{}) (err error)

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

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

+ type DispatcherCoreSv1 struct

+ func NewDispatcherCoreSv1(dps *dispatchers.DispatcherService) *DispatcherCoreSv1

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

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

+ type DispatcherGuardianSv1 struct

+ func NewDispatcherGuardianSv1(dps *dispatchers.DispatcherService) *DispatcherGuardianSv1

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

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

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

+ type DispatcherHostWithCache struct

+ Cache *string

+ type DispatcherRALsV1 struct

+ func NewDispatcherRALsV1(dps *dispatchers.DispatcherService) *DispatcherRALsV1

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

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

+ type DispatcherResourceSv1 struct

+ func NewDispatcherResourceSv1(dps *dispatchers.DispatcherService) *DispatcherResourceSv1

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

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

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

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

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

+ type DispatcherResponder struct

+ func NewDispatcherResponder(dps *dispatchers.DispatcherService) *DispatcherResponder

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

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

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

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

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

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

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

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

+ type DispatcherSCDRsV1 struct

+ func NewDispatcherSCDRsV1(dps *dispatchers.DispatcherService) *DispatcherSCDRsV1

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

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

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

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

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

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

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

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

+ type DispatcherSServiceManagerV1 struct

+ func NewDispatcherSServiceManagerV1(dps *dispatchers.DispatcherService) *DispatcherSServiceManagerV1

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

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

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

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

+ type DispatcherSchedulerSv1 struct

+ func NewDispatcherSchedulerSv1(dps *dispatchers.DispatcherService) *DispatcherSchedulerSv1

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

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

+ type DispatcherSessionSv1 struct

+ func NewDispatcherSessionSv1(dps *dispatchers.DispatcherService) *DispatcherSessionSv1

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type DispatcherStatSv1 struct

+ func NewDispatcherStatSv1(dps *dispatchers.DispatcherService) *DispatcherStatSv1

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

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

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

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

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

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

+ type DispatcherSupplierSv1 struct

+ func NewDispatcherSupplierSv1(dps *dispatchers.DispatcherService) *DispatcherSupplierSv1

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

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

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

+ type DispatcherSv1 struct

+ func NewDispatcherSv1(dS *dispatchers.DispatcherService) *DispatcherSv1

+ func (dSv1 DispatcherSv1) Apier(args *utils.MethodParameters, reply *interface{}) (err error)

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

+ type DispatcherThresholdSv1 struct

+ func NewDispatcherThresholdSv1(dps *dispatchers.DispatcherService) *DispatcherThresholdSv1

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

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

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

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

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

+ type DispatcherWithCache struct

+ Cache *string

+ type FilterWithCache struct

+ Cache *string

+ type GuardianSv1 struct

+ func NewGuardianSv1() *GuardianSv1

+ func (self *GuardianSv1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

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

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

+ type GuardianSv1Interface interface

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

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

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

+ type LoadTimeArgs struct

+ Item string

+ Timezone string

+ type LoaderSv1 struct

+ func NewLoaderSv1(ldrS *loaders.LoaderService) *LoaderSv1

+ func (ldrSv1 *LoaderSv1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

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

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

+ type RALsV1 struct

+ func NewRALsV1() *RALsV1

+ func (rsv1 *RALsV1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

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

+ type RALsV1Interface interface

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

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

+ type ReplicatorSv1 struct

+ func NewReplicatorSv1(dm *engine.DataManager) *ReplicatorSv1

+ func (rplSv1 *ReplicatorSv1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type ResourceSv1 struct

+ func NewResourceSv1(rls *engine.ResourceService) *ResourceSv1

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

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

+ func (rsv1 *ResourceSv1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

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

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

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

+ type ResourceSv1Interface interface

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

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

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

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

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

+ type ResourceWithCache struct

+ Cache *string

+ type ResponderInterface interface

+ Debit func(arg *engine.CallDescriptorWithArgDispatcher, reply *engine.CallCost) (err error)

+ GetCost func(arg *engine.CallDescriptorWithArgDispatcher, reply *engine.CallCost) (err error)

+ GetMaxSessionTime func(arg *engine.CallDescriptorWithArgDispatcher, reply *time.Duration) (err error)

+ MaxDebit func(arg *engine.CallDescriptorWithArgDispatcher, reply *engine.CallCost) (err error)

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

+ RefundIncrements func(arg *engine.CallDescriptorWithArgDispatcher, reply *engine.Account) (err error)

+ RefundRounding func(arg *engine.CallDescriptorWithArgDispatcher, reply *float64) (err error)

+ Shutdown func(arg *utils.TenantWithArgDispatcher, reply *string) (err error)

+ type RplExportedCDRs struct

+ ExportedCGRIDs []string

+ ExportedPath string

+ FirstOrderID int64

+ LastOrderID int64

+ TotalCost float64

+ TotalRecords int

+ UnexportedCGRIDs map[string]string

+ type SMGenericV1 struct

+ Ss *sessions.SessionS

+ func NewSMGenericV1(sS *sessions.SessionS) *SMGenericV1

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

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

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

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

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

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

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

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

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

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

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

+ type SchedulerGeter interface

+ GetScheduler func() *scheduler.Scheduler

+ type SchedulerSv1 struct

+ func NewSchedulerSv1(cgrcfg *config.CGRConfig) *SchedulerSv1

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

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

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

+ type SchedulerSv1Interface interface

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

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

+ type ServiceManagerV1 struct

+ func NewServiceManagerV1(sm *servmanager.ServiceManager) *ServiceManagerV1

+ func (servManager *ServiceManagerV1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

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

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

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

+ type ServiceManagerV1Interface interface

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

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

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

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

+ type SessionSv1 struct

+ Ss *sessions.SessionS

+ func NewSessionSv1(sS *sessions.SessionS) *SessionSv1

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

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

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

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

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

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

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

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

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

+ func (ssv1 *SessionSv1) BiRPCv1GetActiveSessions(clnt *rpc2.Client, args *utils.SessionFilter, ...) error

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

+ func (ssv1 *SessionSv1) BiRPCv1GetPassiveSessions(clnt *rpc2.Client, args *utils.SessionFilter, ...) error

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type SessionSv1Interface interface

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type SetVersionsArg struct

+ Overwrite bool

+ Versions engine.Versions

+ type StatQueueWithCache struct

+ Cache *string

+ type StatSv1 struct

+ func NewStatSv1(sS *engine.StatService) *StatSv1

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

+ func (stsv1 *StatSv1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

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

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

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

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

+ type StatSv1Interface interface

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

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

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

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

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

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

+ type SupplierSv1 struct

+ func NewSupplierSv1(splS *engine.SupplierService) *SupplierSv1

+ func (splv1 *SupplierSv1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

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

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

+ type SupplierSv1Interface interface

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

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

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

+ type SupplierWithCache struct

+ Cache *string

+ type ThresholdSv1 struct

+ func NewThresholdSv1(tS *engine.ThresholdService) *ThresholdSv1

+ func (tSv1 *ThresholdSv1) Call(serviceMethod string, args interface{}, reply interface{}) error

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

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

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

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

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

+ type ThresholdSv1Interface interface

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

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

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

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

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

+ type V1AttrSetActions struct

+ Actions []*V1TPAction

+ ActionsId string

+ Overwrite bool

+ type V1TPAction struct

+ BalanceBlocker string

+ BalanceDisabled string

+ BalanceId string

+ BalanceType string

+ BalanceUuid string

+ BalanceWeight *float64

+ Categories string

+ DestinationIds string

+ ExpiryTime string

+ ExtraParameters string

+ Filter string

+ Identifier string

+ RatingSubject string

+ SharedGroups string

+ TimingTags string

+ Units float64

+ Weight float64

+ type V1TPActions struct

+ Actions []*V1TPAction

+ ActionsId string

+ TPid string

v0.9.1-rc3

Jan 15, 2014

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