engine

package

Go to main page

Versions in this module

v1

v1.0.0-dev

Jun 3, 2025

v0

v0.10.5

Jul 24, 2026

Changes in this version

type ActionPlan

+ func (apl *ActionPlan) CacheClone() any

type Actions

+ func (a Actions) CacheClone() any

+ type RedisResp struct

+ Err error

+ func (r *RedisResp) Bytes() ([]byte, error)

+ func (r *RedisResp) Int() (int, error)

+ func (r *RedisResp) Int64() (int64, error)

+ func (r *RedisResp) IsNil() bool

+ func (r *RedisResp) List() ([]string, error)

+ func (r *RedisResp) ListBytes() ([][]byte, error)

+ func (r *RedisResp) Map() (map[string]string, error)

+ func (r *RedisResp) Str() (string, error)

v0.10.4

Sep 24, 2024

v0.10.3

Aug 9, 2023

Changes in this version

+ func NewBiRPCService(val any) (srv *birpc.Service, err error)

+ func UpdateFilterIndexes(dm *DataManager, tnt string, oldFltr *Filter, newFltr *Filter) (err error)

+ func UpdateReplicationFilters(objType, objID, connID string)

+ type AccountActionPlanIHReply struct

+ BrokenReferences map[string][]string

+ MissingAccountActionPlans map[string][]string

+ func GetAccountActionPlansIndexHealth(dm *DataManager, objLimit, indexLimit int, objTTL, indexTTL time.Duration, ...) (rply *AccountActionPlanIHReply, err error)

type AccountSummary

+ func (as *AccountSummary) UpdateBalances(old *AccountSummary)

type CDR

+ func (cdr *CDR) AsMapStorage() (mp utils.MapStorage)

+ func (cdr *CDR) FieldAsFloat64(rsrPrs *config.RSRParser) (parsed float64, err error)

type ConnManager

+ func (cM *ConnManager) CallWithConnIDs(connIDs []string, subsHostIDs utils.StringSet, method string, arg, reply any) (err error)

+ func (cM *ConnManager) Reload()

type DataManager

+ func (dm *DataManager) RebuildReverseForPrefix(prefix string) (err error)

+ type FilterIHReply struct

+ BrokenIndexes map[string][]string

+ MissingFilters map[string][]string

+ MissingIndexes map[string][]string

+ MissingObjects []string

+ func GetFltrIdxHealth(dm *DataManager, fltrCache, fltrIdxCache, objCache *ltcache.Cache, ...) (rply *FilterIHReply, err error)

type FilterIndexer

+ func ComputeAttributeIndexes(dm *DataManager, tenant, context string, attrIDs *[]string, ...) (filterIndexer *FilterIndexer, err error)

+ func ComputeChargerIndexes(dm *DataManager, tenant string, cppIDs *[]string, transactionID string) (filterIndexer *FilterIndexer, err error)

+ func ComputeDispatcherIndexes(dm *DataManager, tenant, context string, dspIDs *[]string, ...) (filterIndexer *FilterIndexer, err error)

+ func ComputeResourceIndexes(dm *DataManager, tenant string, rsIDs *[]string, transactionID string) (filterIndexer *FilterIndexer, err error)

+ func ComputeStatIndexes(dm *DataManager, tenant string, stIDs *[]string, transactionID string) (filterIndexer *FilterIndexer, err error)

+ func ComputeSupplierIndexes(dm *DataManager, tenant string, sppIDs *[]string, transactionID string) (filterIndexer *FilterIndexer, err error)

+ func ComputeThresholdIndexes(dm *DataManager, tenant string, thIDs *[]string, transactionID string) (filterIndexer *FilterIndexer, err error)

+ func NewFilterIndexerWithIndexes(dm *DataManager, itemType, dbKeySuffix string, ...) *FilterIndexer

+ type IndexHealthArgsWith2Ch struct

+ IndexCacheLimit int

+ IndexCacheStaticTTL bool

+ IndexCacheTTL time.Duration

+ ObjectCacheLimit int

+ ObjectCacheStaticTTL bool

+ ObjectCacheTTL time.Duration

+ type IndexHealthArgsWith3Ch struct

+ FilterCacheLimit int

+ FilterCacheStaticTTL bool

+ FilterCacheTTL time.Duration

+ IndexCacheLimit int

+ IndexCacheStaticTTL bool

+ IndexCacheTTL time.Duration

+ ObjectCacheLimit int

+ ObjectCacheStaticTTL bool

+ ObjectCacheTTL time.Duration

type InternalDB

+ func (iDB *InternalDB) RemoveKeysForPrefix(prefix string) (err error)

type MongoStorage

+ func (ms *MongoStorage) RemoveKeysForPrefix(prefix string) error

type RedisStorage

+ func (rs *RedisStorage) RemoveKeysForPrefix(prefix string) (err error)

type Responder

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

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

+ type ReverseDestinationsIHReply struct

+ BrokenReferences map[string][]string

+ MissingReverseDestinations map[string][]string

+ func GetReverseDestinationsIndexHealth(dm *DataManager, objLimit, indexLimit int, objTTL, indexTTL time.Duration, ...) (rply *ReverseDestinationsIHReply, err error)

type Storage

+ RemoveKeysForPrefix func(string) error

v0.10.2

Oct 8, 2020

v0.10.1

May 12, 2020

Changes in this version

type SortedSupplier

+ func (ss *SortedSupplier) AsNavigableMap() (nm utils.NavigableMap2)

type StatQueue

+ func (sq *StatQueue) Lock()

+ func (sq *StatQueue) RLock()

+ func (sq *StatQueue) RUnlock()

+ func (sq *StatQueue) Unlock()

+ type StatQueueWithCache struct

+ Cache *string

type StatService

+ func (sS *StatService) V1GetStatQueue(args *utils.TenantIDWithArgDispatcher, reply *StatQueue) (err error)

v0.10.0

Feb 6, 2020

Changes in this version

+ const ColAAp

+ const ColAcc

+ const ColAct

+ const ColApl

+ const ColAtr

+ const ColAttr

+ const ColCDRs

+ const ColCpp

+ const ColDph

+ const ColDpp

+ const ColDst

+ const ColFlt

+ const ColLID

+ const ColLht

+ const ColRFI

+ const ColRds

+ const ColRes

+ const ColRpf

+ const ColRpl

+ const ColRsP

+ const ColShg

+ const ColSpp

+ const ColSqp

+ const ColSqs

+ const ColThs

+ const ColTmg

+ const ColTps

+ const ColTsk

+ const ColVer

+ const DB

+ const FALLBACK_SUBJECT

+ const FORMAT

+ const FS_ANSWER_TIME

+ const FS_CALL_DEST_NR

+ const FS_CDR_MAP

+ const FS_CDR_SOURCE

+ const FS_DURATION

+ const FS_HANGUP_TIME

+ const FS_PARK_TIME

+ const FS_PROGRESSMS

+ const FS_PROGRESS_MEDIAMSEC

+ const FS_SETUP_TIME

+ const FS_SIP_REQUSER

+ const FS_USERNAME

+ const FS_UUID

+ const FsIPv4

+ const FsUsername

+ const MINE_PREFIX

+ const MIN_PREFIX_MATCH

+ const RECURSION_MAX_DEPTH

+ const STATS_NA

+ const STRATEGY_HIGHEST

+ const STRATEGY_LOWEST

+ const STRATEGY_MINE_HIGHEST

+ const STRATEGY_MINE_LOWEST

+ const STRATEGY_MINE_RANDOM

+ const STRATEGY_RANDOM

+ var AccountActionsCSVContent = ...

+ var AccountLow = strings.ToLower(utils.Account)

+ var ActionPlansCSVContent = ...

+ var ActionTriggersCSVContent = ...

+ var ActionsCSVContent = ...

+ var AnswerTimeLow = strings.ToLower(utils.AnswerTime)

+ var AttributesCSVContent = ...

+ var CDRHostLow = strings.ToLower(utils.OriginHost)

+ var CDRSourceLow = strings.ToLower(utils.Source)

+ var CGRIDLow = strings.ToLower(utils.CGRID)

+ var Cache *ltcache.TransCache

+ var CategoryLow = strings.ToLower(utils.Category)

+ var ChargersCSVContent = ...

+ var CostDetailsLow = strings.ToLower(utils.CostDetails)

+ var CostLow = strings.ToLower(utils.COST)

+ var CostSourceLow = strings.ToLower(utils.CostSource)

+ var CreatedAtLow = strings.ToLower(utils.CreatedAt)

+ var DestinationLow = strings.ToLower(utils.Destination)

+ var DestinationRatesCSVContent = ...

+ var DestinationsCSVContent = ...

+ var DisconnectCauseLow = strings.ToLower(utils.DISCONNECT_CAUSE)

+ var DispatcherCSVContent = ...

+ var DispatcherHostCSVContent = ...

+ var FiltersCSVContent = ...

+ var OrderIDLow = strings.ToLower(utils.OrderID)

+ var OriginHostLow = strings.ToLower(utils.OriginHost)

+ var OriginIDLow = strings.ToLower(utils.OriginID)

+ var PDDLow = strings.ToLower(utils.PDD)

+ var RatesCSVContent = ...

+ var RatingPlansCSVContent = ...

+ var RatingProfilesCSVContent = ...

+ var RequestTypeLow = strings.ToLower(utils.RequestType)

+ var ResourcesCSVContent = ...

+ var RunIDLow = strings.ToLower(utils.RunID)

+ var SetupTimeLow = strings.ToLower(utils.SetupTime)

+ var SharedGroupsCSVContent = ...

+ var StatsCSVContent = ...

+ var SubjectLow = strings.ToLower(utils.Subject)

+ var SupplierLow = strings.ToLower(utils.SUPPLIER)

+ var SuppliersCSVContent = ...

+ var TenantLow = strings.ToLower(utils.Tenant)

+ var ThresholdsCSVContent = ...

+ var TimingsCSVContent = ...

+ var ToRLow = strings.ToLower(utils.ToR)

+ var UpdatedAtLow = strings.ToLower(utils.UpdatedAt)

+ var UsageLow = strings.ToLower(utils.Usage)

+ func CachedDestHasPrefix(destId, prefix string) bool

+ func CallScript(scriptPath string, subcommand string, waitMs int) error

+ func CheckVersions(storage Storage) error

+ func FilterToTPFilter(f *Filter) (tpFltr *utils.TPFilterProfile)

+ func ForceKillProcName(procName string, waitMs int) error

+ func GetDefaultEmptyCacheStats() map[string]*ltcache.CacheStats

+ func HttpJsonPost(url string, skipTLSVerify bool, content []byte) (respBody []byte, err error)

+ func InitCache(cfg config.CacheCfg)

+ func InitDataDb(cfg *config.CGRConfig) error

+ func InitStorDb(cfg *config.CGRConfig) error

+ func KillEngine(waitEngine int) error

+ func KillProcName(procName string, waitMs int) error

+ func LoadTariffPlanFromFolder(tpPath, timezone string, dm *DataManager, disable_reverse bool, ...) error

+ func MapTPAccountActions(s []*utils.TPAccountActions) (map[string]*utils.TPAccountActions, error)

+ func MapTPActionTimings(s []*utils.TPActionPlan) map[string][]*utils.TPActionTiming

+ func MapTPActionTriggers(s []*utils.TPActionTriggers) map[string][]*utils.TPActionTrigger

+ func MapTPActions(s []*utils.TPActions) map[string][]*utils.TPAction

+ func MapTPDestinationRates(s []*utils.TPDestinationRate) (map[string]*utils.TPDestinationRate, error)

+ func MapTPRates(s []*utils.TPRate) (map[string]*utils.TPRate, error)

+ func MapTPRatingPlanBindings(s []*utils.TPRatingPlan) map[string][]*utils.TPRatingPlanBinding

+ func MapTPRatingProfiles(s []*utils.TPRatingProfile) (map[string]*utils.TPRatingProfile, error)

+ func MapTPSharedGroup(s []*utils.TPSharedGroups) map[string][]*utils.TPSharedGroup

+ func MapTPTimings(tps []*utils.ApierTPTiming) (map[string]*utils.TPTiming, error)

+ func MatchingItemIDsForEvent(ev map[string]interface{}, stringFldIDs, prefixFldIDs *[]string, ...) (itemIDs utils.StringMap, err error)

+ func NewCsvFile() csvReaderCloser

+ func NewCsvString() csvReaderCloser

+ func NewRPCPool(dispatchStrategy string, keyPath, certPath, caPath string, ...) (*rpcclient.RPCPool, error)

+ func OverwriteDBVersions(storage Storage) (err error)

+ func PjsuaCallUri(acnt *PjsuaAccount, dstUri, outboundUri string, callDur time.Duration, ...) error

+ func SetCdrStorage(cStorage CdrStorage)

+ func SetConnManager(conMgr *ConnManager)

+ func SetDBVersions(storage Storage) (err error)

+ func SetDataStorage(dm2 *DataManager)

+ func SetFailedPostCacheTTL(ttl time.Duration)

+ func SetRoundingDecimals(rd int)

+ func SetRpSubjectPrefixMatching(flag bool)

+ func StartEngine(cfgPath string, waitEngine int) (*exec.Cmd, error)

+ func StartPjsuaListener(acnts []*PjsuaAccount, localPort, waitDur time.Duration) (*os.File, error)

+ func StopStartEngine(cfgPath string, waitEngine int) (*exec.Cmd, error)

+ func SureTaxProcessCdr(cdr *CDR) error

+ func TimeDecodeValue1(dc bsoncodec.DecodeContext, vr bsonrw.ValueReader, val reflect.Value) error

+ type AMQPPoster struct

+ func NewAMQPPoster(dialURL string, attempts int) (*AMQPPoster, error)

+ func (pstr *AMQPPoster) Close()

+ func (pstr *AMQPPoster) Post(content []byte, _ string) (err error)

+ type AMQPv1Poster struct

+ func (pstr *AMQPv1Poster) Close()

+ func (pstr *AMQPv1Poster) Post(content []byte, _ string) (err error)

+ type Account struct

+ ActionTriggers ActionTriggers

+ AllowNegative bool

+ BalanceMap map[string]Balances

+ Disabled bool

+ ID string

+ UnitCounters UnitCounters

+ UpdateTime time.Time

+ func (acc *Account) AsAccountSummary() *AccountSummary

+ func (acc *Account) AsNavigableMap(_ []*config.FCTemplate) (*config.NavigableMap, error)

+ func (acc *Account) AsOldStructure() interface{}

+ func (acc *Account) CleanExpiredStuff()

+ func (acc *Account) Clone() *Account

+ func (acc *Account) DebitConnectionFee(cc *CallCost, usefulMoneyBalances Balances, count bool, block bool) (bool, Balance)

+ func (acc *Account) ExecuteActionTriggers(a *Action)

+ func (acc *Account) GetBalanceWithID(blcType, blcID string) (blc *Balance)

+ func (acc *Account) GetDefaultMoneyBalance() *Balance

+ func (acc *Account) GetID() string

+ func (acc *Account) GetSharedGroups() (groups []string)

+ func (acc *Account) GetUniqueSharedGroupMembers(cd *CallDescriptor) (utils.StringMap, error)

+ func (acc *Account) InitCounters()

+ func (acc *Account) Publish()

+ func (acc *Account) ResetActionTriggers(a *Action)

+ func (acc *Account) SetRecurrent(a *Action, recurrent bool)

+ type AccountSummary struct

+ AllowNegative bool

+ BalanceSummaries BalanceSummaries

+ Disabled bool

+ ID string

+ Tenant string

+ func NewAccountSummaryFromJSON(jsn string) (acntSummary *AccountSummary, err error)

+ func (as *AccountSummary) Clone() (cln *AccountSummary)

+ func (as *AccountSummary) FieldAsInterface(fldPath []string) (val interface{}, err error)

+ type Accounting map[string]*BalanceCharge

+ func (cbs *Accounting) FieldAsInterface(fldPath []string) (val interface{}, err error)

+ func (cbs Accounting) Clone() (cln Accounting)

+ func (cbs Accounting) GetIDWithSet(cb *BalanceCharge) string

+ type Action struct

+ ActionType string

+ Balance *BalanceFilter

+ ExpirationString string

+ ExtraParameters string

+ Filter string

+ Id string

+ Weight float64

+ func (a *Action) Clone() (cln *Action)

+ type ActionPlan struct

+ AccountIDs utils.StringMap

+ ActionTimings []*ActionTiming

+ Id string

+ func (apl *ActionPlan) Clone() (interface{}, error)

+ func (apl *ActionPlan) RemoveAccountID(accID string) (found bool)

+ type ActionTiming struct

+ ActionsID string

+ ExtraData interface{}

+ Timing *RateInterval

+ Uuid string

+ Weight float64

+ func (at *ActionTiming) Clone() (cln *ActionTiming)

+ func (at *ActionTiming) Execute(successActions, failedActions chan *Action) (err error)

+ func (at *ActionTiming) GetAccountIDs() utils.StringMap

+ func (at *ActionTiming) GetActionPlanID() string

+ func (at *ActionTiming) GetNextStartTime(now time.Time) (t time.Time)

+ func (at *ActionTiming) GetNextStartTimeOld(now time.Time) (t time.Time)

+ func (at *ActionTiming) IsASAP() bool

+ func (at *ActionTiming) RemoveAccountID(acntID string) (found bool)

+ func (at *ActionTiming) ResetStartTimeCache()

+ func (at *ActionTiming) SetAccountIDs(accIDs utils.StringMap)

+ func (at *ActionTiming) SetActionPlanID(id string)

+ func (at *ActionTiming) SetActions(as Actions)

+ func (at *ActionTiming) Tasks() (tsks []*Task)

+ type ActionTimingPriorityList []*ActionTiming

+ func (atpl ActionTimingPriorityList) Len() int

+ func (atpl ActionTimingPriorityList) Less(i, j int) bool

+ func (atpl ActionTimingPriorityList) Sort()

+ func (atpl ActionTimingPriorityList) Swap(i, j int)

+ type ActionTimingWeightOnlyPriorityList []*ActionTiming

+ func (atpl ActionTimingWeightOnlyPriorityList) Len() int

+ func (atpl ActionTimingWeightOnlyPriorityList) Less(i, j int) bool

+ func (atpl ActionTimingWeightOnlyPriorityList) Sort()

+ func (atpl ActionTimingWeightOnlyPriorityList) Swap(i, j int)

+ type ActionTrigger struct

+ ActionsID string

+ ActivationDate time.Time

+ Balance *BalanceFilter

+ Executed bool

+ ExpirationDate time.Time

+ ID string

+ LastExecutionTime time.Time

+ MinQueuedItems int

+ MinSleep time.Duration

+ Recurrent bool

+ ThresholdType string

+ ThresholdValue float64

+ UniqueID string

+ Weight float64

+ func (at *ActionTrigger) Clone() *ActionTrigger

+ func (at *ActionTrigger) CreateBalance() *Balance

+ func (at *ActionTrigger) Equals(oat *ActionTrigger) bool

+ func (at *ActionTrigger) Execute(ub *Account) (err error)

+ func (at *ActionTrigger) IsActive(t time.Time) bool

+ func (at *ActionTrigger) IsExpired(t time.Time) bool

+ func (at *ActionTrigger) Match(a *Action) bool

+ type ActionTriggers []*ActionTrigger

+ func (atpl ActionTriggers) Clone() ActionTriggers

+ func (atpl ActionTriggers) Len() int

+ func (atpl ActionTriggers) Less(j, i int) bool

+ func (atpl ActionTriggers) Sort()

+ func (atpl ActionTriggers) Swap(i, j int)

+ type Actions []*Action

+ func (apl Actions) Clone() (interface{}, error)

+ func (apl Actions) Len() int

+ func (apl Actions) Less(j, i int) bool

+ func (apl Actions) Sort()

+ func (apl Actions) Swap(i, j int)

+ type ArgRateCDRs struct

+ Flags []string

+ type ArgV1ProcessEvent struct

+ Flags []string

+ type ArgsGetSuppliers struct

+ IgnoreErrors bool

+ MaxCost string

+ type ArgsProcessEvent struct

+ ThresholdIDs []string

+ type ArgsV2CDRSStoreSMCost struct

+ CheckDuplicate bool

+ Cost *V2SMCost

+ type AttrArgsProcessEvent struct

+ AttributeIDs []string

+ Context *string

+ ProcessRuns *int

+ type AttrCDRSStoreSMCost struct

+ CheckDuplicate bool

+ Cost *SMCost

+ type AttrSProcessEventReply struct

+ AlteredFields []string

+ CGREvent *utils.CGREvent

+ MatchedProfiles []string

+ func (attrReply *AttrSProcessEventReply) Digest() (rplyDigest string)

+ type Attribute struct

+ FilterIDs []string

+ Path string

+ Type string

+ Value config.RSRParsers

+ type AttributeProfile struct

+ ActivationInterval *utils.ActivationInterval

+ Attributes []*Attribute

+ Blocker bool

+ Contexts []string

+ FilterIDs []string

+ ID string

+ Tenant string

+ Weight float64

+ func APItoAttributeProfile(tpAttr *utils.TPAttributeProfile, timezone string) (attrPrf *AttributeProfile, err error)

+ func NewAttributeFromInline(tenant, inlnRule string) (attr *AttributeProfile, err error)

+ func (ap *AttributeProfile) Compile() error

+ func (ap *AttributeProfile) TenantID() string

+ type AttributeProfiles []*AttributeProfile

+ func (aps AttributeProfiles) Sort()

+ type AttributeService struct

+ func NewAttributeService(dm *DataManager, filterS *FilterS, cgrcfg *config.CGRConfig) (*AttributeService, error)

+ func (alS *AttributeService) ListenAndServe(exitChan chan bool) (err error)

+ func (alS *AttributeService) Shutdown() (err error)

+ func (alS *AttributeService) V1GetAttributeForEvent(args *AttrArgsProcessEvent, attrPrfl *AttributeProfile) (err error)

+ func (alS *AttributeService) V1ProcessEvent(args *AttrArgsProcessEvent, reply *AttrSProcessEventReply) (err error)

+ type BSONMarshaler struct

+ func (jm *BSONMarshaler) Marshal(v interface{}) ([]byte, error)

+ func (jm *BSONMarshaler) Unmarshal(data []byte, v interface{}) error

+ type Balance struct

+ Blocker bool

+ Categories utils.StringMap

+ DestinationIDs utils.StringMap

+ Disabled bool

+ ExpirationDate time.Time

+ Factor ValueFactor

+ ID string

+ RatingSubject string

+ SharedGroups utils.StringMap

+ TimingIDs utils.StringMap

+ Timings []*RITiming

+ Uuid string

+ Value float64

+ Weight float64

+ func (b *Balance) AddValue(amount float64)

+ func (b *Balance) AsBalanceSummary(typ string) *BalanceSummary

+ func (b *Balance) AsNavigableMap(_ []*config.FCTemplate) (*config.NavigableMap, error)

+ func (b *Balance) Clone() *Balance

+ func (b *Balance) Equal(o *Balance) bool

+ func (b *Balance) GetCost(cd *CallDescriptor, getStandardIfEmpty bool) (*CallCost, error)

+ func (b *Balance) GetMinutesForCredit(origCD *CallDescriptor, initialCredit float64) (duration time.Duration, credit float64)

+ func (b *Balance) GetValue() float64

+ func (b *Balance) HardMatchFilter(o *BalanceFilter, skipIds bool) bool

+ func (b *Balance) HasDestination() bool

+ func (b *Balance) IsActive() bool

+ func (b *Balance) IsActiveAt(t time.Time) bool

+ func (b *Balance) IsDefault() bool

+ func (b *Balance) IsExpiredAt(t time.Time) bool

+ func (b *Balance) MatchActionTrigger(at *ActionTrigger) bool

+ func (b *Balance) MatchCategory(category string) bool

+ func (b *Balance) MatchDestination(destinationID string) bool

+ func (b *Balance) MatchFilter(o *BalanceFilter, skipIds, skipExpiry bool) bool

+ func (b *Balance) Publish()

+ func (b *Balance) SetDirty()

+ func (b *Balance) SetValue(amount float64)

+ func (b *Balance) SubstractValue(amount float64)

+ type BalanceCharge struct

+ AccountID string

+ BalanceUUID string

+ ExtraChargeID string

+ RatingID string

+ Units float64

+ func (bc *BalanceCharge) Clone() *BalanceCharge

+ func (bc *BalanceCharge) Equals(oBC *BalanceCharge) bool

+ func (bc *BalanceCharge) FieldAsInterface(fldPath []string) (val interface{}, err error)

+ type BalanceFilter struct

+ Blocker *bool

+ Categories *utils.StringMap

+ DestinationIDs *utils.StringMap

+ Disabled *bool

+ ExpirationDate *time.Time

+ Factor *ValueFactor

+ ID *string

+ RatingSubject *string

+ SharedGroups *utils.StringMap

+ TimingIDs *utils.StringMap

+ Timings []*RITiming

+ Type *string

+ Uuid *string

+ Value *utils.ValueFormula

+ Weight *float64

+ func NewBalanceFilter(filter map[string]interface{}, defaultTimezone string) (bf *BalanceFilter, err error)

+ func (bf *BalanceFilter) Clone() *BalanceFilter

+ func (bf *BalanceFilter) LoadFromBalance(b *Balance) *BalanceFilter

+ func (bf *BalanceFilter) ModifyBalance(b *Balance)

+ func (bp *BalanceFilter) CreateBalance() *Balance

+ func (bp *BalanceFilter) EmptyExpirationDate() bool

+ func (bp *BalanceFilter) Equal(o *BalanceFilter) bool

+ func (bp *BalanceFilter) GetBlocker() bool

+ func (bp *BalanceFilter) GetCategories() utils.StringMap

+ func (bp *BalanceFilter) GetDestinationIDs() utils.StringMap

+ func (bp *BalanceFilter) GetDisabled() bool

+ func (bp *BalanceFilter) GetExpirationDate() time.Time

+ func (bp *BalanceFilter) GetFactor() ValueFactor

+ func (bp *BalanceFilter) GetID() string

+ func (bp *BalanceFilter) GetRatingSubject() string

+ func (bp *BalanceFilter) GetSharedGroups() utils.StringMap

+ func (bp *BalanceFilter) GetTimingIDs() utils.StringMap

+ func (bp *BalanceFilter) GetType() string

+ func (bp *BalanceFilter) GetUuid() string

+ func (bp *BalanceFilter) GetValue() float64

+ func (bp *BalanceFilter) GetWeight() float64

+ func (bp *BalanceFilter) SetValue(v float64)

+ type BalanceSummaries []*BalanceSummary

+ func (bs BalanceSummaries) BalanceSummaryWithUUD(bsUUID string) (b *BalanceSummary)

+ type BalanceSummary struct

+ Disabled bool

+ ID string

+ Type string

+ UUID string

+ Value float64

+ func (bl *BalanceSummary) FieldAsInterface(fldPath []string) (val interface{}, err error)

+ type Balances []*Balance

+ func (bc Balances) Clone() Balances

+ func (bc Balances) Equal(o Balances) bool

+ func (bc Balances) GetBalance(uuid string) *Balance

+ func (bc Balances) GetTotalValue() (total float64)

+ func (bc Balances) HasBalance(balance *Balance) bool

+ func (bc Balances) Len() int

+ func (bc Balances) Less(j, i int) bool

+ func (bc Balances) SaveDirtyBalances(acc *Account)

+ func (bc Balances) Sort()

+ func (bc Balances) Swap(i, j int)

+ type BincMarshaler struct

+ func NewBincMarshaler() *BincMarshaler

+ func (bm *BincMarshaler) Marshal(v interface{}) (b []byte, err error)

+ func (bm *BincMarshaler) Unmarshal(data []byte, v interface{}) error

+ type CDR struct

+ Account string

+ AnswerTime time.Time

+ CGRID string

+ Category string

+ Cost float64

+ CostDetails *EventCost

+ CostSource string

+ Destination string

+ ExtraFields map[string]string

+ ExtraInfo string

+ OrderID int64

+ OriginHost string

+ OriginID string

+ Partial bool

+ PreRated bool

+ RequestType string

+ RunID string

+ SetupTime time.Time

+ Source string

+ Subject string

+ Tenant string

+ ToR string

+ Usage time.Duration

+ func NewCDRFromExternalCDR(extCdr *ExternalCDR, timezone string) (*CDR, error)

+ func NewCDRFromSQL(cdrSQL *CDRsql) (cdr *CDR, err error)

+ func NewCDRWithDefaults(cfg *config.CGRConfig) *CDR

+ func (cdr *CDR) AddDefaults(cfg *config.CGRConfig)

+ func (cdr *CDR) AsCDRsql() (cdrSQL *CDRsql)

+ func (cdr *CDR) AsCGREvent() *utils.CGREvent

+ func (cdr *CDR) AsExportMap(exportFields []*config.FCTemplate, httpSkipTLSCheck bool, groupedCDRs []*CDR, ...) (expMap map[string]string, err error)

+ func (cdr *CDR) AsExportRecord(exportFields []*config.FCTemplate, httpSkipTLSCheck bool, groupedCDRs []*CDR, ...) (expRecord []string, err error)

+ func (cdr *CDR) AsExternalCDR() *ExternalCDR

+ func (cdr *CDR) AsMapStringIface() (mp map[string]interface{})

+ func (cdr *CDR) Clone() *CDR

+ func (cdr *CDR) ComputeCGRID()

+ func (cdr *CDR) CostDetailsJson() string

+ func (cdr *CDR) FieldAsString(rsrPrs *config.RSRParser) (parsed string, err error)

+ func (cdr *CDR) FieldsAsString(rsrFlds config.RSRParsers) string

+ func (cdr *CDR) FormatCost(shiftDecimals, roundDecimals int) string

+ func (cdr *CDR) String() string

+ func (cdr *CDR) UpdateFromCGREvent(cgrEv *utils.CGREvent, fields []string) (err error)

+ type CDRExporter struct

+ func NewCDRExporter(cdrs []*CDR, exportTemplate *config.CdreCfg, ...) (*CDRExporter, error)

+ func (cdre *CDRExporter) ExportCDRs() (err error)

+ func (cdre *CDRExporter) FirstOrderID() int64

+ func (cdre *CDRExporter) LastOrderID() int64

+ func (cdre *CDRExporter) NegativeExports() map[string]string

+ func (cdre *CDRExporter) PositiveExports() []string

+ func (cdre *CDRExporter) TotalCost() float64

+ func (cdre *CDRExporter) TotalExportedCdrs() int

+ type CDRServer struct

+ func NewCDRServer(cgrCfg *config.CGRConfig, storDBChan chan StorDB, dm *DataManager, ...) *CDRServer

+ func (cdrS *CDRServer) Call(serviceMethod string, args interface{}, reply interface{}) error

+ func (cdrS *CDRServer) ListenAndServe(stopChan chan struct{}) (err error)

+ func (cdrS *CDRServer) RegisterHandlersToServer(server *utils.Server)

+ func (cdrS *CDRServer) V1CountCDRs(args *utils.RPCCDRsFilterWithArgDispatcher, cnt *int64) error

+ func (cdrS *CDRServer) V1GetCDRs(args utils.RPCCDRsFilterWithArgDispatcher, cdrs *[]*CDR) error

+ func (cdrS *CDRServer) V1ProcessCDR(cdr *CDRWithArgDispatcher, reply *string) (err error)

+ func (cdrS *CDRServer) V1ProcessEvent(arg *ArgV1ProcessEvent, reply *string) (err error)

+ func (cdrS *CDRServer) V1ProcessExternalCDR(eCDR *ExternalCDRWithArgDispatcher, reply *string) error

+ func (cdrS *CDRServer) V1RateCDRs(arg *ArgRateCDRs, reply *string) (err error)

+ func (cdrS *CDRServer) V1StoreSessionCost(attr *AttrCDRSStoreSMCost, reply *string) (err error)

+ func (cdrS *CDRServer) V2StoreSessionCost(args *ArgsV2CDRSStoreSMCost, reply *string) (err error)

+ type CDRWithArgDispatcher struct

+ type CDRsql struct

+ Account string

+ AnswerTime time.Time

+ Category string

+ Cgrid string

+ Cost float64

+ CostDetails string

+ CostSource string

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ Destination string

+ ExtraFields string

+ ExtraInfo string

+ ID int64

+ OriginHost string

+ OriginID string

+ RequestType string

+ RunID string

+ SetupTime time.Time

+ Source string

+ Subject string

+ TOR string

+ Tenant string

+ UpdatedAt time.Time

+ Usage int64

+ func (t CDRsql) AsMapStringInterface() (out map[string]interface{})

+ func (t CDRsql) TableName() string

+ type CGRSafEvent struct

+ Event *SafEvent

+ ID string

+ Tenant string

+ Time *time.Time

+ func NewCGRSafEventFromCGREvent(cgrEv *utils.CGREvent) *CGRSafEvent

+ func (cgrSafEv *CGRSafEvent) AsCGREvent() *utils.CGREvent

+ type CSVStorage struct

+ func NewCSVStorage(sep rune, destinationsFn, timingsFn, ratesFn, destinationratesFn, ... []string) *CSVStorage

+ func NewFileCSVStorage(sep rune, dataPath string, recursive bool) *CSVStorage

+ func NewGoogleCSVStorage(sep rune, spreadsheetId, cfgPath string) (*CSVStorage, error)

+ func NewStringCSVStorage(sep rune, destinationsFn, timingsFn, ratesFn, destinationratesFn, ... string) *CSVStorage

+ func (csvs *CSVStorage) GetTPAccountActions(filter *utils.TPAccountActions) ([]*utils.TPAccountActions, error)

+ func (csvs *CSVStorage) GetTPActionPlans(tpid, id string) ([]*utils.TPActionPlan, error)

+ func (csvs *CSVStorage) GetTPActionTriggers(tpid, id string) ([]*utils.TPActionTriggers, error)

+ func (csvs *CSVStorage) GetTPActions(tpid, id string) ([]*utils.TPActions, error)

+ func (csvs *CSVStorage) GetTPAttributes(tpid, tenant, id string) ([]*utils.TPAttributeProfile, error)

+ func (csvs *CSVStorage) GetTPChargers(tpid, tenant, id string) ([]*utils.TPChargerProfile, error)

+ func (csvs *CSVStorage) GetTPDestinationRates(tpid, id string, p *utils.Paginator) ([]*utils.TPDestinationRate, error)

+ func (csvs *CSVStorage) GetTPDestinations(tpid, id string) ([]*utils.TPDestination, error)

+ func (csvs *CSVStorage) GetTPDispatcherHosts(tpid, tenant, id string) ([]*utils.TPDispatcherHost, error)

+ func (csvs *CSVStorage) GetTPDispatcherProfiles(tpid, tenant, id string) ([]*utils.TPDispatcherProfile, error)

+ func (csvs *CSVStorage) GetTPFilters(tpid, tenant, id string) ([]*utils.TPFilterProfile, error)

+ func (csvs *CSVStorage) GetTPRates(tpid, id string) ([]*utils.TPRate, error)

+ func (csvs *CSVStorage) GetTPRatingPlans(tpid, id string, p *utils.Paginator) ([]*utils.TPRatingPlan, error)

+ func (csvs *CSVStorage) GetTPRatingProfiles(filter *utils.TPRatingProfile) ([]*utils.TPRatingProfile, error)

+ func (csvs *CSVStorage) GetTPResources(tpid, tenant, id string) ([]*utils.TPResourceProfile, error)

+ func (csvs *CSVStorage) GetTPSharedGroups(tpid, id string) ([]*utils.TPSharedGroups, error)

+ func (csvs *CSVStorage) GetTPStats(tpid, tenant, id string) ([]*utils.TPStatProfile, error)

+ func (csvs *CSVStorage) GetTPSuppliers(tpid, tenant, id string) ([]*utils.TPSupplierProfile, error)

+ func (csvs *CSVStorage) GetTPThresholds(tpid, tenant, id string) ([]*utils.TPThresholdProfile, error)

+ func (csvs *CSVStorage) GetTPTimings(tpid, id string) ([]*utils.ApierTPTiming, error)

+ func (csvs *CSVStorage) GetTpIds(colName string) ([]string, error)

+ func (csvs *CSVStorage) GetTpTableIds(tpid, table string, distinct utils.TPDistinctIds, filters map[string]string, ...) ([]string, error)

+ type CacheS struct

+ func NewCacheS(cfg *config.CGRConfig, dm *DataManager) (c *CacheS)

+ func (chS *CacheS) Call(serviceMethod string, args interface{}, reply interface{}) error

+ func (chS *CacheS) GetPrecacheChannel(chID string) chan struct{}

+ func (chS *CacheS) Precache() (err error)

+ func (chS *CacheS) V1Clear(args *utils.AttrCacheIDsWithArgDispatcher, reply *string) (err error)

+ func (chS *CacheS) V1FlushCache(args utils.AttrReloadCacheWithArgDispatcher, reply *string) (err error)

+ func (chS *CacheS) V1GetCacheStats(args *utils.AttrCacheIDsWithArgDispatcher, ...) (err error)

+ func (chS *CacheS) V1GetGroupItemIDs(args *utils.ArgsGetGroupWithArgDispatcher, rply *[]string) (err error)

+ func (chS *CacheS) V1GetItemExpiryTime(args *utils.ArgsGetCacheItemWithArgDispatcher, reply *time.Time) (err error)

+ func (chS *CacheS) V1GetItemIDs(args *utils.ArgsGetCacheItemIDsWithArgDispatcher, reply *[]string) (err error)

+ func (chS *CacheS) V1HasGroup(args *utils.ArgsGetGroupWithArgDispatcher, rply *bool) (err error)

+ func (chS *CacheS) V1HasItem(args *utils.ArgsGetCacheItemWithArgDispatcher, reply *bool) (err error)

+ func (chS *CacheS) V1LoadCache(args utils.AttrReloadCacheWithArgDispatcher, reply *string) (err error)

+ func (chS *CacheS) V1PrecacheStatus(args *utils.AttrCacheIDsWithArgDispatcher, rply *map[string]string) (err error)

+ func (chS *CacheS) V1ReloadCache(attrs utils.AttrReloadCacheWithArgDispatcher, reply *string) (err error)

+ func (chS *CacheS) V1RemoveGroup(args *utils.ArgsGetGroupWithArgDispatcher, rply *string) (err error)

+ func (chS *CacheS) V1RemoveItem(args *utils.ArgsGetCacheItemWithArgDispatcher, reply *string) (err error)

+ type CallCost struct

+ Account string

+ AccountSummary *AccountSummary

+ Category string

+ Cost float64

+ Destination string

+ RatedUsage float64

+ Subject string

+ Tenant string

+ Timespans TimeSpans

+ ToR string

+ func (cc *CallCost) AsJSON() string

+ func (cc *CallCost) CreateCallDescriptor() *CallDescriptor

+ func (cc *CallCost) GetConnectFee() float64

+ func (cc *CallCost) GetDuration() (td time.Duration)

+ func (cc *CallCost) GetEndTime() time.Time

+ func (cc *CallCost) GetLongestRounding() (roundingDecimals int, roundingMethod string)

+ func (cc *CallCost) GetRoundIncrements() (roundIncrements Increments)

+ func (cc *CallCost) GetStartTime() time.Time

+ func (cc *CallCost) IsPaid() bool

+ func (cc *CallCost) MatchCCFilter(bf *BalanceFilter) bool

+ func (cc *CallCost) Merge(other *CallCost)

+ func (cc *CallCost) Round()

+ func (cc *CallCost) ToDataCost() (*DataCost, error)

+ func (cc *CallCost) UpdateCost()

+ func (cc *CallCost) UpdateRatedUsage() time.Duration

+ type CallDescriptor struct

+ Account string

+ Category string

+ CgrID string

+ DenyNegativeAccount bool

+ Destination string

+ DryRun bool

+ DurationIndex time.Duration

+ ExtraFields map[string]string

+ FallbackSubject string

+ ForceDuration bool

+ Increments Increments

+ LoopIndex float64

+ MaxCostSoFar float64

+ MaxRate float64

+ MaxRateUnit time.Duration

+ PerformRounding bool

+ RatingInfos RatingInfos

+ RunID string

+ Subject string

+ Tenant string

+ TimeEnd time.Time

+ TimeStart time.Time

+ ToR string

+ func NewCallDescriptorFromCGREvent(cgrEv *utils.CGREvent, timezone string) (cd *CallDescriptor, err error)

+ func (cd *CallDescriptor) AccountSummary() *AccountSummary

+ func (cd *CallDescriptor) AddRatingInfo(ris ...*RatingInfo)

+ func (cd *CallDescriptor) AsCGREvent() *utils.CGREvent

+ func (cd *CallDescriptor) AsNavigableMap(tpl []*config.FCTemplate) (nM *config.NavigableMap, err error)

+ func (cd *CallDescriptor) Clone() *CallDescriptor

+ func (cd *CallDescriptor) CreateCallCost() *CallCost

+ func (cd *CallDescriptor) Debit() (cc *CallCost, err error)

+ func (cd *CallDescriptor) FieldAsInterface(fldPath []string) (fldVal interface{}, err error)

+ func (cd *CallDescriptor) FieldAsString(fldPath []string) (fldVal string, err error)

+ func (cd *CallDescriptor) GetAccountKey() string

+ func (cd *CallDescriptor) GetCost() (*CallCost, error)

+ func (cd *CallDescriptor) GetDuration() time.Duration

+ func (cd *CallDescriptor) GetKey(subject string) string

+ func (cd *CallDescriptor) GetMaxSessionDuration() (duration time.Duration, err error)

+ func (cd *CallDescriptor) LoadRatingPlans() (err error)

+ func (cd *CallDescriptor) MaxDebit() (cc *CallCost, err error)

+ func (cd *CallDescriptor) RefundIncrements() (acnt *Account, err error)

+ func (cd *CallDescriptor) RefundRounding() (err error)

+ func (cd *CallDescriptor) RemoteHost() net.Addr

+ func (cd *CallDescriptor) String() string

+ func (cd *CallDescriptor) UpdateFromCGREvent(cgrEv *utils.CGREvent, fields []string) (err error)

+ func (cd *CallDescriptor) ValidateCallData() error

+ type CallDescriptorWithArgDispatcher struct

+ type CdrStorage interface

+ GetCDRs func(*utils.CDRsFilter, bool) ([]*CDR, int64, error)

+ GetSMCosts func(cgrid, runid, originHost, originIDPrfx string) ([]*SMCost, error)

+ RemoveSMCost func(*SMCost) error

+ RemoveSMCosts func(qryFltr *utils.SMCostFilter) error

+ SetCDR func(*CDR, bool) error

+ SetSMCost func(smc *SMCost) error

+ type CgrCdr map[string]string

+ func NewCgrCdrFromHttpReq(req *http.Request, timezone string) (CgrCdr, error)

+ func (cgrCdr CgrCdr) AsCDR(timezone string) *CDR

+ type ChargedRates map[string]RateGroups

+ func (crs *ChargedRates) FieldAsInterface(fldPath []string) (val interface{}, err error)

+ func (crs ChargedRates) Clone() (cln ChargedRates)

+ func (crs ChargedRates) GetIDWithSet(rg RateGroups) string

+ type ChargedTiming struct

+ MonthDays utils.MonthDays

+ Months utils.Months

+ StartTime string

+ WeekDays utils.WeekDays

+ Years utils.Years

+ func (ct *ChargedTiming) Clone() (cln *ChargedTiming)

+ func (ct *ChargedTiming) Equals(oCT *ChargedTiming) bool

+ func (ct *ChargedTiming) FieldAsInterface(fldPath []string) (val interface{}, err error)

+ type ChargedTimings map[string]*ChargedTiming

+ func (cts *ChargedTimings) FieldAsInterface(fldPath []string) (val interface{}, err error)

+ func (cts ChargedTimings) Clone() (cln ChargedTimings)

+ func (cts ChargedTimings) GetIDWithSet(ct *ChargedTiming) string

+ type ChargerProfile struct

+ ActivationInterval *utils.ActivationInterval

+ AttributeIDs []string

+ FilterIDs []string

+ ID string

+ RunID string

+ Tenant string

+ Weight float64

+ func APItoChargerProfile(tpCPP *utils.TPChargerProfile, timezone string) (cpp *ChargerProfile, err error)

+ func (cP *ChargerProfile) TenantID() string

+ type ChargerProfiles []*ChargerProfile

+ func (cps ChargerProfiles) Sort()

+ type ChargerService struct

+ func NewChargerService(dm *DataManager, filterS *FilterS, cfg *config.CGRConfig, connMgr *ConnManager) (*ChargerService, error)

+ func (cS *ChargerService) ListenAndServe(exitChan chan bool) (err error)

+ func (cS *ChargerService) Shutdown() (err error)

+ func (cS *ChargerService) V1GetChargersForEvent(args *utils.CGREventWithArgDispatcher, rply *ChargerProfiles) (err error)

+ func (cS *ChargerService) V1ProcessEvent(args *utils.CGREventWithArgDispatcher, reply *[]*ChrgSProcessEventReply) (err error)

+ type ChargingIncrement struct

+ AccountingID string

+ CompressFactor int

+ Cost float64

+ Usage time.Duration

+ func (cIt *ChargingIncrement) Clone() (cln *ChargingIncrement)

+ func (cIt *ChargingIncrement) Equals(oCIt *ChargingIncrement) bool

+ func (cIt *ChargingIncrement) FieldAsInterface(fldPath []string) (val interface{}, err error)

+ func (cIt *ChargingIncrement) PartiallyEquals(oCIt *ChargingIncrement) bool

+ func (cIt *ChargingIncrement) TotalCost() float64

+ func (cIt *ChargingIncrement) TotalUsage() time.Duration

+ type ChargingInterval struct

+ CompressFactor int

+ Increments []*ChargingIncrement

+ RatingID string

+ func (cIl *ChargingInterval) Clone() (cln *ChargingInterval)

+ func (cIl *ChargingInterval) Cost() float64

+ func (cIl *ChargingInterval) EndTime(cIlST time.Time) (et time.Time)

+ func (cIl *ChargingInterval) EventCostUsageIndex() *time.Duration

+ func (cIl *ChargingInterval) PartiallyEquals(oCIl *ChargingInterval) bool

+ func (cIl *ChargingInterval) StartTime(ecST time.Time) (st time.Time)

+ func (cIl *ChargingInterval) TotalCost() float64

+ func (cIl *ChargingInterval) TotalUsage() (tu *time.Duration)

+ func (cIl *ChargingInterval) Usage() *time.Duration

+ type ChrgSProcessEventReply struct

+ AlteredFields []string

+ AttributeSProfiles []string

+ CGREvent *utils.CGREvent

+ ChargerSProfile string

+ type CodecMsgpackMarshaler struct

+ func NewCodecMsgpackMarshaler() *CodecMsgpackMarshaler

+ func (cmm *CodecMsgpackMarshaler) Marshal(v interface{}) (b []byte, err error)

+ func (cmm *CodecMsgpackMarshaler) Unmarshal(data []byte, v interface{}) error

+ type ConnManager struct

+ func NewConnManager(cfg *config.CGRConfig, rpcInternal map[string]chan rpcclient.ClientConnector) (cM *ConnManager)

+ func (cM *ConnManager) Call(connIDs []string, biRPCClient rpcclient.ClientConnector, method string, ...) (err error)

+ type CoreService struct

+ func NewCoreService() *CoreService

+ func (cS *CoreService) ListenAndServe(exitChan chan bool) (err error)

+ func (cS *CoreService) Shutdown() (err error)

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

+ type CounterFilter struct

+ Filter *BalanceFilter

+ Value float64

+ func (cfs *CounterFilter) Clone() *CounterFilter

+ type CounterFilters []*CounterFilter

+ func (cfs CounterFilters) HasCounter(cf *CounterFilter) bool

+ type DataCost struct

+ Account string

+ Category string

+ Cost float64

+ DataSpans []*DataSpan

+ Destination string

+ Subject string

+ Tenant string

+ ToR string

+ type DataDB interface

+ AddLoadHistory func(*utils.LoadInstance, int, string) error

+ GetAccountActionPlansDrv func(acntID string, skipCache bool, transactionID string) (apIDs []string, err error)

+ GetAccountDrv func(string) (*Account, error)

+ GetActionPlanDrv func(string, bool, string) (*ActionPlan, error)

+ GetActionTriggersDrv func(string) (ActionTriggers, error)

+ GetActionsDrv func(string) (Actions, error)

+ GetAllActionPlansDrv func() (map[string]*ActionPlan, error)

+ GetAttributeProfileDrv func(string, string) (*AttributeProfile, error)

+ GetChargerProfileDrv func(string, string) (*ChargerProfile, error)

+ GetDestinationDrv func(string, bool, string) (*Destination, error)

+ GetDispatcherHostDrv func(string, string) (*DispatcherHost, error)

+ GetDispatcherProfileDrv func(string, string) (*DispatcherProfile, error)

+ GetFilterDrv func(string, string) (*Filter, error)

+ GetFilterIndexesDrv func(cacheID, itemIDPrefix, filterType string, fldNameVal map[string]string) (indexes map[string]utils.StringMap, err error)

+ GetItemLoadIDsDrv func(itemIDPrefix string) (loadIDs map[string]int64, err error)

+ GetLoadHistory func(int, bool, string) ([]*utils.LoadInstance, error)

+ GetRatingPlanDrv func(string) (*RatingPlan, error)

+ GetRatingProfileDrv func(string) (*RatingProfile, error)

+ GetResourceDrv func(string, string) (*Resource, error)

+ GetResourceProfileDrv func(string, string) (*ResourceProfile, error)

+ GetReverseDestinationDrv func(string, bool, string) ([]string, error)

+ GetSharedGroupDrv func(string) (*SharedGroup, error)

+ GetStatQueueDrv func(tenant, id string) (sq *StatQueue, err error)

+ GetStatQueueProfileDrv func(tenant string, ID string) (sq *StatQueueProfile, err error)

+ GetSupplierProfileDrv func(string, string) (*SupplierProfile, error)

+ GetThresholdDrv func(string, string) (*Threshold, error)

+ GetThresholdProfileDrv func(tenant string, ID string) (tp *ThresholdProfile, err error)

+ GetTimingDrv func(string) (*utils.TPTiming, error)

+ HasDataDrv func(string, string, string) (bool, error)

+ MatchFilterIndexDrv func(cacheID, itemIDPrefix, filterType, fieldName, fieldVal string) (itemIDs utils.StringMap, err error)

+ PopTask func() (*Task, error)

+ PushTask func(*Task) error

+ RemAccountActionPlansDrv func(acntID string, apIDs []string) (err error)

+ RemStatQueueDrv func(tenant, id string) (err error)

+ RemStatQueueProfileDrv func(tenant, id string) (err error)

+ RemThresholdProfileDrv func(tenant, id string) (err error)

+ RemoveAccountDrv func(string) error

+ RemoveActionPlanDrv func(key string, transactionID string) error

+ RemoveActionTriggersDrv func(string) error

+ RemoveActionsDrv func(string) error

+ RemoveAttributeProfileDrv func(string, string) error

+ RemoveChargerProfileDrv func(string, string) error

+ RemoveDestinationDrv func(string, string) error

+ RemoveDispatcherHostDrv func(string, string) error

+ RemoveDispatcherProfileDrv func(string, string) error

+ RemoveFilterDrv func(string, string) error

+ RemoveFilterIndexesDrv func(cacheID, itemIDPrefix string) (err error)

+ RemoveLoadIDsDrv func() error

+ RemoveRatingPlanDrv func(key string) (err error)

+ RemoveRatingProfileDrv func(string) error

+ RemoveResourceDrv func(string, string) error

+ RemoveResourceProfileDrv func(string, string) error

+ RemoveSharedGroupDrv func(id string) (err error)

+ RemoveSupplierProfileDrv func(string, string) error

+ RemoveThresholdDrv func(string, string) error

+ RemoveTimingDrv func(string) error

+ SetAccountActionPlansDrv func(acntID string, apIDs []string, overwrite bool) (err error)

+ SetAccountDrv func(*Account) error

+ SetActionPlanDrv func(string, *ActionPlan, bool, string) error

+ SetActionTriggersDrv func(string, ActionTriggers) error

+ SetActionsDrv func(string, Actions) error

+ SetAttributeProfileDrv func(*AttributeProfile) error

+ SetChargerProfileDrv func(*ChargerProfile) error

+ SetDestinationDrv func(*Destination, string) error

+ SetDispatcherHostDrv func(*DispatcherHost) error

+ SetDispatcherProfileDrv func(*DispatcherProfile) error

+ SetFilterDrv func(*Filter) error

+ SetFilterIndexesDrv func(cacheID, itemIDPrefix string, indexes map[string]utils.StringMap, commit bool, ...) (err error)

+ SetLoadIDsDrv func(loadIDs map[string]int64) error

+ SetRatingPlanDrv func(*RatingPlan) error

+ SetRatingProfileDrv func(*RatingProfile) error

+ SetResourceDrv func(*Resource) error

+ SetResourceProfileDrv func(*ResourceProfile) error

+ SetReverseDestinationDrv func(*Destination, string) error

+ SetSharedGroupDrv func(*SharedGroup) error

+ SetStatQueueDrv func(ssq *StoredStatQueue, sq *StatQueue) (err error)

+ SetStatQueueProfileDrv func(sq *StatQueueProfile) (err error)

+ SetSupplierProfileDrv func(*SupplierProfile) error

+ SetThresholdDrv func(*Threshold) error

+ SetThresholdProfileDrv func(tp *ThresholdProfile) (err error)

+ SetTimingDrv func(*utils.TPTiming) error

+ UpdateReverseDestinationDrv func(*Destination, *Destination, string) error

+ func NewDataDBConn(dbType, host, port, name, user, pass, marshaler, sentinelName string, ...) (d DataDB, err error)

+ type DataIncrement struct

+ Amount float64

+ BalanceInfo *DebitInfo

+ CompressFactor int

+ Cost float64

+ type DataManager struct

+ func NewDataManager(dataDB DataDB, cacheCfg config.CacheCfg, connMgr *ConnManager) *DataManager

+ func (dm *DataManager) CacheDataFromDB(prfx string, ids []string, mustBeCached bool) (err error)

+ func (dm *DataManager) DataDB() DataDB

+ func (dm *DataManager) GetAccount(id string) (acc *Account, err error)

+ func (dm *DataManager) GetAccountActionPlans(acntID string, skipCache bool, transactionID string) (apIDs []string, err error)

+ func (dm *DataManager) GetActionPlan(key string, skipCache bool, transactionID string) (ats *ActionPlan, err error)

+ func (dm *DataManager) GetActionTriggers(id string, skipCache bool, transactionID string) (attrs ActionTriggers, err error)

+ func (dm *DataManager) GetActions(key string, skipCache bool, transactionID string) (as Actions, err error)

+ func (dm *DataManager) GetAllActionPlans() (ats map[string]*ActionPlan, err error)

+ func (dm *DataManager) GetAttributeProfile(tenant, id string, cacheRead, cacheWrite bool, transactionID string) (attrPrfl *AttributeProfile, err error)

+ func (dm *DataManager) GetChargerProfile(tenant, id string, cacheRead, cacheWrite bool, transactionID string) (cpp *ChargerProfile, err error)

+ func (dm *DataManager) GetDestination(key string, skipCache bool, transactionID string) (dest *Destination, err error)

+ func (dm *DataManager) GetDispatcherHost(tenant, id string, cacheRead, cacheWrite bool, transactionID string) (dH *DispatcherHost, err error)

+ func (dm *DataManager) GetDispatcherProfile(tenant, id string, cacheRead, cacheWrite bool, transactionID string) (dpp *DispatcherProfile, err error)

+ func (dm *DataManager) GetFilterIndexes(cacheID, itemIDPrefix, filterType string, fldNameVal map[string]string) (indexes map[string]utils.StringMap, err error)

+ func (dm *DataManager) GetItemLoadIDs(itemIDPrefix string, cacheWrite bool) (loadIDs map[string]int64, err error)

+ func (dm *DataManager) GetRatingPlan(key string, skipCache bool, transactionID string) (rp *RatingPlan, err error)

+ func (dm *DataManager) GetRatingProfile(key string, skipCache bool, transactionID string) (rpf *RatingProfile, err error)

+ func (dm *DataManager) GetResource(tenant, id string, cacheRead, cacheWrite bool, transactionID string) (rs *Resource, err error)

+ func (dm *DataManager) GetResourceProfile(tenant, id string, cacheRead, cacheWrite bool, transactionID string) (rp *ResourceProfile, err error)

+ func (dm *DataManager) GetReverseDestination(prefix string, skipCache bool, transactionID string) (ids []string, err error)

+ func (dm *DataManager) GetSharedGroup(key string, skipCache bool, transactionID string) (sg *SharedGroup, err error)

+ func (dm *DataManager) GetStatQueue(tenant, id string, cacheRead, cacheWrite bool, transactionID string) (sq *StatQueue, err error)

+ func (dm *DataManager) GetStatQueueProfile(tenant, id string, cacheRead, cacheWrite bool, transactionID string) (sqp *StatQueueProfile, err error)

+ func (dm *DataManager) GetSupplierProfile(tenant, id string, cacheRead, cacheWrite bool, transactionID string) (supp *SupplierProfile, err error)

+ func (dm *DataManager) GetThreshold(tenant, id string, cacheRead, cacheWrite bool, transactionID string) (th *Threshold, err error)

+ func (dm *DataManager) GetThresholdProfile(tenant, id string, cacheRead, cacheWrite bool, transactionID string) (th *ThresholdProfile, err error)

+ func (dm *DataManager) GetTiming(id string, skipCache bool, transactionID string) (t *utils.TPTiming, err error)

+ func (dm *DataManager) HasData(category, subject, tenant string) (has bool, err error)

+ func (dm *DataManager) LoadDataDBCache(...) (err error)

+ func (dm *DataManager) MatchFilterIndex(cacheID, itemIDPrefix, filterType, fieldName, fieldVal string) (itemIDs utils.StringMap, err error)

+ func (dm *DataManager) MatchFilterIndexFromKey(cacheID, key string) (err error)

+ func (dm *DataManager) PreloadCacheForPrefix(prefix string) error

+ func (dm *DataManager) Reconnect(marshaller string, newcfg *config.DataDbCfg) (err error)

+ func (dm *DataManager) RemAccountActionPlans(acntID string, apIDs []string) (err error)

+ func (dm *DataManager) RemoveAccount(id string) (err error)

+ func (dm *DataManager) RemoveActionPlan(key string, transactionID string) (err error)

+ func (dm *DataManager) RemoveActionTriggers(id, transactionID string) (err error)

+ func (dm *DataManager) RemoveActions(key, transactionID string) (err error)

+ func (dm *DataManager) RemoveAttributeProfile(tenant, id string, transactionID string, withIndex bool) (err error)

+ func (dm *DataManager) RemoveChargerProfile(tenant, id string, transactionID string, withIndex bool) (err error)

+ func (dm *DataManager) RemoveDestination(destID string, transactionID string) (err error)

+ func (dm *DataManager) RemoveDispatcherHost(tenant, id string, transactionID string) (err error)

+ func (dm *DataManager) RemoveDispatcherProfile(tenant, id string, transactionID string, withIndex bool) (err error)

+ func (dm *DataManager) RemoveFilter(tenant, id, transactionID string) (err error)

+ func (dm *DataManager) RemoveFilterIndexes(cacheID, itemIDPrefix string) (err error)

+ func (dm *DataManager) RemoveRatingPlan(key string, transactionID string) (err error)

+ func (dm *DataManager) RemoveRatingProfile(key string, transactionID string) (err error)

+ func (dm *DataManager) RemoveResource(tenant, id, transactionID string) (err error)

+ func (dm *DataManager) RemoveResourceProfile(tenant, id, transactionID string, withIndex bool) (err error)

+ func (dm *DataManager) RemoveSharedGroup(id, transactionID string) (err error)

+ func (dm *DataManager) RemoveStatQueue(tenant, id string, transactionID string) (err error)

+ func (dm *DataManager) RemoveStatQueueProfile(tenant, id, transactionID string, withIndex bool) (err error)

+ func (dm *DataManager) RemoveSupplierProfile(tenant, id, transactionID string, withIndex bool) (err error)

+ func (dm *DataManager) RemoveThreshold(tenant, id, transactionID string) (err error)

+ func (dm *DataManager) RemoveThresholdProfile(tenant, id, transactionID string, withIndex bool) (err error)

+ func (dm *DataManager) RemoveTiming(id, transactionID string) (err error)

+ func (dm *DataManager) SetAccount(acc *Account) (err error)

+ func (dm *DataManager) SetAccountActionPlans(acntID string, aPlIDs []string, overwrite bool) (err error)

+ func (dm *DataManager) SetActionPlan(key string, ats *ActionPlan, overwrite bool, transactionID string) (err error)

+ func (dm *DataManager) SetActionTriggers(key string, attr ActionTriggers, transactionID string) (err error)

+ func (dm *DataManager) SetActions(key string, as Actions, transactionID string) (err error)

+ func (dm *DataManager) SetAttributeProfile(ap *AttributeProfile, withIndex bool) (err error)

+ func (dm *DataManager) SetChargerProfile(cpp *ChargerProfile, withIndex bool) (err error)

+ func (dm *DataManager) SetDestination(dest *Destination, transactionID string) (err error)

+ func (dm *DataManager) SetDispatcherHost(dpp *DispatcherHost) (err error)

+ func (dm *DataManager) SetDispatcherProfile(dpp *DispatcherProfile, withIndex bool) (err error)

+ func (dm *DataManager) SetFilter(fltr *Filter) (err error)

+ func (dm *DataManager) SetFilterIndexes(cacheID, itemIDPrefix string, indexes map[string]utils.StringMap, commit bool, ...) (err error)

+ func (dm *DataManager) SetLoadIDs(loadIDs map[string]int64) (err error)

+ func (dm *DataManager) SetRatingPlan(rp *RatingPlan, transactionID string) (err error)

+ func (dm *DataManager) SetRatingProfile(rpf *RatingProfile, transactionID string) (err error)

+ func (dm *DataManager) SetResource(rs *Resource) (err error)

+ func (dm *DataManager) SetResourceProfile(rp *ResourceProfile, withIndex bool) (err error)

+ func (dm *DataManager) SetReverseDestination(dest *Destination, transactionID string) (err error)

+ func (dm *DataManager) SetSharedGroup(sg *SharedGroup, transactionID string) (err error)

+ func (dm *DataManager) SetStatQueue(sq *StatQueue) (err error)

+ func (dm *DataManager) SetStatQueueProfile(sqp *StatQueueProfile, withIndex bool) (err error)

+ func (dm *DataManager) SetSupplierProfile(supp *SupplierProfile, withIndex bool) (err error)

+ func (dm *DataManager) SetThreshold(th *Threshold) (err error)

+ func (dm *DataManager) SetThresholdProfile(th *ThresholdProfile, withIndex bool) (err error)

+ func (dm *DataManager) SetTiming(t *utils.TPTiming) (err error)

+ func (dm *DataManager) UpdateReverseDestination(oldDest, newDest *Destination, transactionID string) error

+ type DataSpan struct

+ Cost float64

+ DataEnd float64

+ DataIndex float64

+ DataStart float64

+ Increments []*DataIncrement

+ MatchedDestId string

+ MatchedPrefix string

+ MatchedSubject string

+ RateInterval *RateInterval

+ RatingPlanId string

+ type DebitInfo struct

+ AccountID string

+ Monetary *MonetaryInfo

+ Unit *UnitInfo

+ func (di *DebitInfo) Clone() *DebitInfo

+ func (di *DebitInfo) Equal(other *DebitInfo) bool

+ type Destination struct

+ Id string

+ Prefixes []string

+ func NewDestinationFromTPDestination(tpDst *utils.TPDestination) *Destination

+ func (d *Destination) AddPrefix(pfx string)

+ func (d *Destination) String() (result string)

+ type DispatcherHost struct

+ Conns []*config.RemoteHost

+ ID string

+ Tenant string

+ func APItoDispatcherHost(tpDPH *utils.TPDispatcherHost) (dpp *DispatcherHost)

+ func (dH *DispatcherHost) Call(serviceMethod string, args interface{}, reply interface{}) error

+ func (dH *DispatcherHost) TenantID() string

+ type DispatcherHostProfile struct

+ Blocker bool

+ FilterIDs []string

+ ID string

+ Params map[string]interface{}

+ Weight float64

+ func (dC *DispatcherHostProfile) Clone() (cln *DispatcherHostProfile)

+ type DispatcherHostProfiles []*DispatcherHostProfile

+ func (dHPrfls DispatcherHostProfiles) Clone() (cln DispatcherHostProfiles)

+ func (dHPrfls DispatcherHostProfiles) HostIDs() (hostIDs []string)

+ func (dHPrfls DispatcherHostProfiles) ReorderFromIndex(idx int)

+ func (dHPrfls DispatcherHostProfiles) Shuffle()

+ func (dHPrfls DispatcherHostProfiles) Sort()

+ type DispatcherProfile struct

+ ActivationInterval *utils.ActivationInterval

+ FilterIDs []string

+ Hosts DispatcherHostProfiles

+ ID string

+ Strategy string

+ StrategyParams map[string]interface{}

+ Subsystems []string

+ Tenant string

+ Weight float64

+ func APItoDispatcherProfile(tpDPP *utils.TPDispatcherProfile, timezone string) (dpp *DispatcherProfile, err error)

+ func (dP *DispatcherProfile) TenantID() string

+ type DispatcherProfiles []*DispatcherProfile

+ func (dps DispatcherProfiles) Sort()

+ type DurationWithCompress struct

+ CompressFactor int

+ Duration time.Duration

+ type EventCost struct

+ AccountSummary *AccountSummary

+ Accounting Accounting

+ CGRID string

+ Charges []*ChargingInterval

+ Cost *float64

+ Rates ChargedRates

+ Rating Rating

+ RatingFilters RatingFilters

+ RunID string

+ StartTime time.Time

+ Timings ChargedTimings

+ Usage *time.Duration

+ func IfaceAsEventCost(itm interface{}) (ec *EventCost, err error)

+ func NewBareEventCost() *EventCost

+ func NewEventCostFromCallCost(cc *CallCost, cgrID, runID string) (ec *EventCost)

+ func (ec *EventCost) AsCallCost(tor string) *CallCost

+ func (ec *EventCost) AsNavigableMap([]*config.FCTemplate) (*config.NavigableMap, error)

+ func (ec *EventCost) AsRefundIncrements(tor string) (cd *CallDescriptor)

+ func (ec *EventCost) Clone() (cln *EventCost)

+ func (ec *EventCost) Compute()

+ func (ec *EventCost) ComputeEventCostUsageIndexes()

+ func (ec *EventCost) FieldAsInterface(fldPath []string) (val interface{}, err error)

+ func (ec *EventCost) FieldAsString(fldPath []string) (string, error)

+ func (ec *EventCost) GetCost() float64

+ func (ec *EventCost) GetUsage() time.Duration

+ func (ec *EventCost) Merge(ecs ...*EventCost)

+ func (ec *EventCost) RemoteHost() net.Addr

+ func (ec *EventCost) RemoveStaleReferences()

+ func (ec *EventCost) ResetCounters()

+ func (ec *EventCost) String() string

+ func (ec *EventCost) SyncKeys(refEC *EventCost)

+ func (ec *EventCost) Trim(atUsage time.Duration) (srplusEC *EventCost, err error)

+ type ExportEvents struct

+ Events []interface{}

+ Format string

+ Path string

+ func NewExportEventsFromFile(filePath string) (expEv *ExportEvents, err error)

+ func (expEv *ExportEvents) AddEvent(ev interface{})

+ func (expEv *ExportEvents) FileName() string

+ func (expEv *ExportEvents) ReplayFailedPosts(attempts int) (failedEvents *ExportEvents, err error)

+ func (expEv *ExportEvents) SetModule(mod string)

+ func (expEv *ExportEvents) WriteToFile(filePath string) (err error)

+ type ExternalAttribute struct

+ FilterIDs []string

+ Path string

+ Type string

+ Value string

+ type ExternalAttributeProfile struct

+ ActivationInterval *utils.ActivationInterval

+ Attributes []*ExternalAttribute

+ Blocker bool

+ Contexts []string

+ FilterIDs []string

+ ID string

+ Tenant string

+ Weight float64

+ func (ext *ExternalAttributeProfile) AsAttributeProfile() (attr *AttributeProfile, err error)

+ type ExternalCDR struct

+ Account string

+ AnswerTime string

+ CGRID string

+ Category string

+ Cost float64

+ CostDetails string

+ CostSource string

+ Destination string

+ ExtraFields map[string]string

+ ExtraInfo string

+ OrderID int64

+ OriginHost string

+ OriginID string

+ PreRated bool

+ RequestType string

+ RunID string

+ SetupTime string

+ Source string

+ Subject string

+ Tenant string

+ ToR string

+ Usage string

+ type ExternalCDRWithArgDispatcher struct

+ type FSCdr struct

+ func NewFSCdr(body []byte, cgrCfg *config.CGRConfig) (*FSCdr, error)

+ func (fsCdr FSCdr) AsCDR(timezone string) *CDR

+ type Filter struct

+ ActivationInterval *utils.ActivationInterval

+ ID string

+ Rules []*FilterRule

+ Tenant string

+ func APItoFilter(tpTH *utils.TPFilterProfile, timezone string) (th *Filter, err error)

+ func GetFilter(dm *DataManager, tenant, id string, cacheRead, cacheWrite bool, ...) (fltr *Filter, err error)

+ func NewFilterFromInline(tenant, inlnRule string) (f *Filter, err error)

+ func (fltr *Filter) Compile() (err error)

+ func (fltr *Filter) TenantID() string

+ type FilterIndexer struct

+ func NewFilterIndexer(dm *DataManager, itemType, dbKeySuffix string) *FilterIndexer

+ func (rfi *FilterIndexer) IndexTPFilter(tpFltr *utils.TPFilterProfile, itemID string)

+ func (rfi *FilterIndexer) RemoveItemFromIndex(tenant, itemID string, oldFilters []string) (err error)

+ func (rfi *FilterIndexer) StoreIndexes(commit bool, transactionID string) (err error)

+ type FilterRule struct

+ Element string

+ Type string

+ Values []string

+ func NewFilterRule(rfType, fieldName string, vals []string) (*FilterRule, error)

+ func (fltr *FilterRule) CompileValues() (err error)

+ func (fltr *FilterRule) Pass(fieldNameDP config.DataProvider, fieldValuesDP []config.DataProvider) (result bool, err error)

+ type FilterS struct

+ func NewFilterS(cfg *config.CGRConfig, connMgr *ConnManager, dm *DataManager) (fS *FilterS)

+ func (fS *FilterS) Pass(tenant string, filterIDs []string, ev config.DataProvider) (pass bool, err error)

+ type GOBMarshaler struct

+ func (gm *GOBMarshaler) Marshal(v interface{}) (data []byte, err error)

+ func (gm *GOBMarshaler) Unmarshal(data []byte, v interface{}) error

+ type HTTPPoster struct

+ func NewHTTPPoster(skipTLSVerify bool, replyTimeout time.Duration, addr, contentType string, ...) (httposter *HTTPPoster, err error)

+ func (pstr *HTTPPoster) GetResponse(content interface{}) (respBody []byte, err error)

+ func (pstr *HTTPPoster) Post(content interface{}, key string) (err error)

+ type HighestBalancesSorter []*Balance

+ func (hbcs HighestBalancesSorter) Len() int

+ func (hbcs HighestBalancesSorter) Less(i, j int) bool

+ func (hbcs HighestBalancesSorter) Swap(i, j int)

+ type HightCostSorter struct

+ func NewHighestCostSorter(spS *SupplierService) *HightCostSorter

+ func (hcs *HightCostSorter) SortSuppliers(prflID string, suppls []*Supplier, ev *utils.CGREvent, ...) (sortedSuppls *SortedSuppliers, err error)

+ type Increment struct

+ BalanceInfo *DebitInfo

+ CompressFactor int

+ Cost float64

+ Duration time.Duration

+ func (incr *Increment) Clone() *Increment

+ func (incr *Increment) Equal(other *Increment) bool

+ func (incr *Increment) GetCompressFactor() int

+ func (incr *Increment) GetCost() float64

+ type Increments []*Increment

+ func (incs *Increments) Compress()

+ func (incs *Increments) Decompress()

+ func (incs Increments) Clone() (cln Increments)

+ func (incs Increments) Equal(other Increments) bool

+ func (incs Increments) GetTotalCost() float64

+ func (incs Increments) Length() (length int)

+ func (incs Increments) SharingSignature(other Increments) bool

+ type InternalDB struct

+ func NewInternalDB(stringIndexedFields, prefixIndexedFields []string, isDataDB bool, ...) (iDB *InternalDB)

+ func (iDB *InternalDB) AddLoadHistory(*utils.LoadInstance, int, string) error

+ func (iDB *InternalDB) Close()

+ func (iDB *InternalDB) Flush(_ string) error

+ func (iDB *InternalDB) GetAccountActionPlansDrv(acntID string, skipCache bool, transactionID string) (apIDs []string, err error)

+ func (iDB *InternalDB) GetAccountDrv(id string) (acc *Account, err error)

+ func (iDB *InternalDB) GetActionPlanDrv(key string, skipCache bool, transactionID string) (ats *ActionPlan, err error)

+ func (iDB *InternalDB) GetActionTriggersDrv(id string) (at ActionTriggers, err error)

+ func (iDB *InternalDB) GetActionsDrv(id string) (acts Actions, err error)

+ func (iDB *InternalDB) GetAllActionPlansDrv() (ats map[string]*ActionPlan, err error)

+ func (iDB *InternalDB) GetAttributeProfileDrv(tenant, id string) (attr *AttributeProfile, err error)

+ func (iDB *InternalDB) GetCDRs(filter *utils.CDRsFilter, remove bool) (cdrs []*CDR, count int64, err error)

+ func (iDB *InternalDB) GetChargerProfileDrv(tenant, id string) (ch *ChargerProfile, err error)

+ func (iDB *InternalDB) GetDestinationDrv(key string, skipCache bool, transactionID string) (dest *Destination, err error)

+ func (iDB *InternalDB) GetDispatcherHostDrv(tenant, id string) (dpp *DispatcherHost, err error)

+ func (iDB *InternalDB) GetDispatcherProfileDrv(tenant, id string) (dpp *DispatcherProfile, err error)

+ func (iDB *InternalDB) GetFilterDrv(tenant, id string) (fltr *Filter, err error)

+ func (iDB *InternalDB) GetFilterIndexesDrv(cacheID, itemIDPrefix, filterType string, fldNameVal map[string]string) (indexes map[string]utils.StringMap, err error)

+ func (iDB *InternalDB) GetItemLoadIDsDrv(itemIDPrefix string) (loadIDs map[string]int64, err error)

+ func (iDB *InternalDB) GetKeysForPrefix(prefix string) ([]string, error)

+ func (iDB *InternalDB) GetLoadHistory(int, bool, string) ([]*utils.LoadInstance, error)

+ func (iDB *InternalDB) GetRatingPlanDrv(id string) (rp *RatingPlan, err error)

+ func (iDB *InternalDB) GetRatingProfileDrv(id string) (rp *RatingProfile, err error)

+ func (iDB *InternalDB) GetResourceDrv(tenant, id string) (r *Resource, err error)

+ func (iDB *InternalDB) GetResourceProfileDrv(tenant, id string) (rp *ResourceProfile, err error)

+ func (iDB *InternalDB) GetReverseDestinationDrv(prefix string, skipCache bool, transactionID string) (ids []string, err error)

+ func (iDB *InternalDB) GetSMCosts(cgrid, runid, originHost, originIDPrfx string) (smCosts []*SMCost, err error)

+ func (iDB *InternalDB) GetSharedGroupDrv(id string) (sh *SharedGroup, err error)

+ func (iDB *InternalDB) GetStatQueueDrv(tenant, id string) (sq *StatQueue, err error)

+ func (iDB *InternalDB) GetStatQueueProfileDrv(tenant string, id string) (sq *StatQueueProfile, err error)

+ func (iDB *InternalDB) GetStorageType() string

+ func (iDB *InternalDB) GetSupplierProfileDrv(tenant, id string) (spp *SupplierProfile, err error)

+ func (iDB *InternalDB) GetTPAccountActions(filter *utils.TPAccountActions) (accounts []*utils.TPAccountActions, err error)

+ func (iDB *InternalDB) GetTPActionPlans(tpid, id string) (aPlans []*utils.TPActionPlan, err error)

+ func (iDB *InternalDB) GetTPActionTriggers(tpid, id string) (aTriggers []*utils.TPActionTriggers, err error)

+ func (iDB *InternalDB) GetTPActions(tpid, id string) (actions []*utils.TPActions, err error)

+ func (iDB *InternalDB) GetTPAttributes(tpid, tenant, id string) (attrs []*utils.TPAttributeProfile, err error)

+ func (iDB *InternalDB) GetTPChargers(tpid, tenant, id string) (cpps []*utils.TPChargerProfile, err error)

+ func (iDB *InternalDB) GetTPDestinationRates(tpid, id string, paginator *utils.Paginator) (dRates []*utils.TPDestinationRate, err error)

+ func (iDB *InternalDB) GetTPDestinations(tpid, id string) (dsts []*utils.TPDestination, err error)

+ func (iDB *InternalDB) GetTPDispatcherHosts(tpid, tenant, id string) (dpps []*utils.TPDispatcherHost, err error)

+ func (iDB *InternalDB) GetTPDispatcherProfiles(tpid, tenant, id string) (dpps []*utils.TPDispatcherProfile, err error)

+ func (iDB *InternalDB) GetTPFilters(tpid, tenant, id string) (fltrs []*utils.TPFilterProfile, err error)

+ func (iDB *InternalDB) GetTPRates(tpid, id string) (rates []*utils.TPRate, err error)

+ func (iDB *InternalDB) GetTPRatingPlans(tpid, id string, paginator *utils.Paginator) (rPlans []*utils.TPRatingPlan, err error)

+ func (iDB *InternalDB) GetTPRatingProfiles(filter *utils.TPRatingProfile) (rProfiles []*utils.TPRatingProfile, err error)

+ func (iDB *InternalDB) GetTPResources(tpid, tenant, id string) (resources []*utils.TPResourceProfile, err error)

+ func (iDB *InternalDB) GetTPSharedGroups(tpid, id string) (sGroups []*utils.TPSharedGroups, err error)

+ func (iDB *InternalDB) GetTPStats(tpid, tenant, id string) (stats []*utils.TPStatProfile, err error)

+ func (iDB *InternalDB) GetTPSuppliers(tpid, tenant, id string) (supps []*utils.TPSupplierProfile, err error)

+ func (iDB *InternalDB) GetTPThresholds(tpid, tenant, id string) (ths []*utils.TPThresholdProfile, err error)

+ func (iDB *InternalDB) GetTPTimings(tpid, id string) (timings []*utils.ApierTPTiming, err error)

+ func (iDB *InternalDB) GetThresholdDrv(tenant, id string) (th *Threshold, err error)

+ func (iDB *InternalDB) GetThresholdProfileDrv(tenant, id string) (tp *ThresholdProfile, err error)

+ func (iDB *InternalDB) GetTimingDrv(id string) (tmg *utils.TPTiming, err error)

+ func (iDB *InternalDB) GetTpIds(colName string) (ids []string, err error)

+ func (iDB *InternalDB) GetTpTableIds(tpid, table string, distinct utils.TPDistinctIds, filters map[string]string, ...) (ids []string, err error)

+ func (iDB *InternalDB) GetVersions(itm string) (vrs Versions, err error)

+ func (iDB *InternalDB) HasDataDrv(category, subject, tenant string) (bool, error)

+ func (iDB *InternalDB) IsDBEmpty() (resp bool, err error)

+ func (iDB *InternalDB) MatchFilterIndexDrv(cacheID, itemIDPrefix, filterType, fieldName, fieldVal string) (itemIDs utils.StringMap, err error)

+ func (iDB *InternalDB) PopTask() (t *Task, err error)

+ func (iDB *InternalDB) PushTask(t *Task) (err error)

+ func (iDB *InternalDB) RebuildReverseForPrefix(prefix string) (err error)

+ func (iDB *InternalDB) RemAccountActionPlansDrv(acntID string, apIDs []string) (err error)

+ func (iDB *InternalDB) RemStatQueueDrv(tenant, id string) (err error)

+ func (iDB *InternalDB) RemStatQueueProfileDrv(tenant, id string) (err error)

+ func (iDB *InternalDB) RemThresholdProfileDrv(tenant, id string) (err error)

+ func (iDB *InternalDB) RemTpData(table, tpid string, args map[string]string) (err error)

+ func (iDB *InternalDB) RemoveAccountDrv(id string) (err error)

+ func (iDB *InternalDB) RemoveActionPlanDrv(key string, transactionID string) (err error)

+ func (iDB *InternalDB) RemoveActionTriggersDrv(id string) (err error)

+ func (iDB *InternalDB) RemoveActionsDrv(id string) (err error)

+ func (iDB *InternalDB) RemoveAttributeProfileDrv(tenant, id string) (err error)

+ func (iDB *InternalDB) RemoveChargerProfileDrv(tenant, id string) (err error)

+ func (iDB *InternalDB) RemoveDestinationDrv(destID string, transactionID string) (err error)

+ func (iDB *InternalDB) RemoveDispatcherHostDrv(tenant, id string) (err error)

+ func (iDB *InternalDB) RemoveDispatcherProfileDrv(tenant, id string) (err error)

+ func (iDB *InternalDB) RemoveFilterDrv(tenant, id string) (err error)

+ func (iDB *InternalDB) RemoveFilterIndexesDrv(cacheID, itemIDPrefix string) (err error)

+ func (iDB *InternalDB) RemoveLoadIDsDrv() (err error)

+ func (iDB *InternalDB) RemoveRatingPlanDrv(id string) (err error)

+ func (iDB *InternalDB) RemoveRatingProfileDrv(id string) (err error)

+ func (iDB *InternalDB) RemoveResourceDrv(tenant, id string) (err error)

+ func (iDB *InternalDB) RemoveResourceProfileDrv(tenant, id string) (err error)

+ func (iDB *InternalDB) RemoveReverseForPrefix(prefix string) (err error)

+ func (iDB *InternalDB) RemoveSMCost(smc *SMCost) (err error)

+ func (iDB *InternalDB) RemoveSMCosts(qryFltr *utils.SMCostFilter) error

+ func (iDB *InternalDB) RemoveSharedGroupDrv(id string) (err error)

+ func (iDB *InternalDB) RemoveSupplierProfileDrv(tenant, id string) (err error)

+ func (iDB *InternalDB) RemoveThresholdDrv(tenant, id string) (err error)

+ func (iDB *InternalDB) RemoveTimingDrv(id string) (err error)

+ func (iDB *InternalDB) RemoveVersions(vrs Versions) (err error)

+ func (iDB *InternalDB) SelectDatabase(dbName string) (err error)

+ func (iDB *InternalDB) SetAccountActionPlansDrv(acntID string, apIDs []string, overwrite bool) (err error)

+ func (iDB *InternalDB) SetAccountDrv(acc *Account) (err error)

+ func (iDB *InternalDB) SetActionPlanDrv(key string, ats *ActionPlan, overwrite bool, transactionID string) (err error)

+ func (iDB *InternalDB) SetActionTriggersDrv(id string, at ActionTriggers) (err error)

+ func (iDB *InternalDB) SetActionsDrv(id string, acts Actions) (err error)

+ func (iDB *InternalDB) SetAttributeProfileDrv(attr *AttributeProfile) (err error)

+ func (iDB *InternalDB) SetCDR(cdr *CDR, allowUpdate bool) (err error)

+ func (iDB *InternalDB) SetChargerProfileDrv(chr *ChargerProfile) (err error)

+ func (iDB *InternalDB) SetDestinationDrv(dest *Destination, transactionID string) (err error)

+ func (iDB *InternalDB) SetDispatcherHostDrv(dpp *DispatcherHost) (err error)

+ func (iDB *InternalDB) SetDispatcherProfileDrv(dpp *DispatcherProfile) (err error)

+ func (iDB *InternalDB) SetFilterDrv(fltr *Filter) (err error)

+ func (iDB *InternalDB) SetFilterIndexesDrv(cacheID, itemIDPrefix string, indexes map[string]utils.StringMap, commit bool, ...) (err error)

+ func (iDB *InternalDB) SetLoadIDsDrv(loadIDs map[string]int64) (err error)

+ func (iDB *InternalDB) SetPrefixIndexedFields(prefixIndexedFields []string)

+ func (iDB *InternalDB) SetRatingPlanDrv(rp *RatingPlan) (err error)

+ func (iDB *InternalDB) SetRatingProfileDrv(rp *RatingProfile) (err error)

+ func (iDB *InternalDB) SetResourceDrv(r *Resource) (err error)

+ func (iDB *InternalDB) SetResourceProfileDrv(rp *ResourceProfile) (err error)

+ func (iDB *InternalDB) SetReverseDestinationDrv(dest *Destination, transactionID string) (err error)

+ func (iDB *InternalDB) SetSMCost(smCost *SMCost) (err error)

+ func (iDB *InternalDB) SetSharedGroupDrv(sh *SharedGroup) (err error)

+ func (iDB *InternalDB) SetStatQueueDrv(ssq *StoredStatQueue, sq *StatQueue) (err error)

+ func (iDB *InternalDB) SetStatQueueProfileDrv(sq *StatQueueProfile) (err error)

+ func (iDB *InternalDB) SetStringIndexedFields(stringIndexedFields []string)

+ func (iDB *InternalDB) SetSupplierProfileDrv(spp *SupplierProfile) (err error)

+ func (iDB *InternalDB) SetTPAccountActions(accActions []*utils.TPAccountActions) (err error)

+ func (iDB *InternalDB) SetTPActionPlans(aPlans []*utils.TPActionPlan) (err error)

+ func (iDB *InternalDB) SetTPActionTriggers(aTriggers []*utils.TPActionTriggers) (err error)

+ func (iDB *InternalDB) SetTPActions(acts []*utils.TPActions) (err error)

+ func (iDB *InternalDB) SetTPAttributes(attributes []*utils.TPAttributeProfile) (err error)

+ func (iDB *InternalDB) SetTPChargers(cpps []*utils.TPChargerProfile) (err error)

+ func (iDB *InternalDB) SetTPDestinationRates(dRates []*utils.TPDestinationRate) (err error)

+ func (iDB *InternalDB) SetTPDestinations(dests []*utils.TPDestination) (err error)

+ func (iDB *InternalDB) SetTPDispatcherHosts(dpps []*utils.TPDispatcherHost) (err error)

+ func (iDB *InternalDB) SetTPDispatcherProfiles(dpps []*utils.TPDispatcherProfile) (err error)

+ func (iDB *InternalDB) SetTPFilters(filters []*utils.TPFilterProfile) (err error)

+ func (iDB *InternalDB) SetTPRates(rates []*utils.TPRate) (err error)

+ func (iDB *InternalDB) SetTPRatingPlans(ratingPlans []*utils.TPRatingPlan) (err error)

+ func (iDB *InternalDB) SetTPRatingProfiles(ratingProfiles []*utils.TPRatingProfile) (err error)

+ func (iDB *InternalDB) SetTPResources(resources []*utils.TPResourceProfile) (err error)

+ func (iDB *InternalDB) SetTPSharedGroups(groups []*utils.TPSharedGroups) (err error)

+ func (iDB *InternalDB) SetTPStats(stats []*utils.TPStatProfile) (err error)

+ func (iDB *InternalDB) SetTPSuppliers(suppliers []*utils.TPSupplierProfile) (err error)

+ func (iDB *InternalDB) SetTPThresholds(thresholds []*utils.TPThresholdProfile) (err error)

+ func (iDB *InternalDB) SetTPTimings(timings []*utils.ApierTPTiming) (err error)

+ func (iDB *InternalDB) SetThresholdDrv(th *Threshold) (err error)

+ func (iDB *InternalDB) SetThresholdProfileDrv(tp *ThresholdProfile) (err error)

+ func (iDB *InternalDB) SetTimingDrv(timing *utils.TPTiming) (err error)

+ func (iDB *InternalDB) SetVersions(vrs Versions, overwrite bool) (err error)

+ func (iDB *InternalDB) UpdateReverseDestinationDrv(oldDest, newDest *Destination, transactionID string) error

+ type JSONBufMarshaler struct

+ func (jbm *JSONBufMarshaler) Marshal(v interface{}) (data []byte, err error)

+ func (jbm *JSONBufMarshaler) Unmarshal(data []byte, v interface{}) error

+ type JSONMarshaler struct

+ func (jm *JSONMarshaler) Marshal(v interface{}) ([]byte, error)

+ func (jm *JSONMarshaler) Unmarshal(data []byte, v interface{}) error

+ type KafkaPoster struct

+ func NewKafkaPoster(dialURL string, attempts int) (*KafkaPoster, error)

+ func (pstr *KafkaPoster) Close()

+ func (pstr *KafkaPoster) Post(content []byte, key string) (err error)

+ type LeastCostSorter struct

+ func NewLeastCostSorter(spS *SupplierService) *LeastCostSorter

+ func (lcs *LeastCostSorter) SortSuppliers(prflID string, suppls []*Supplier, ev *utils.CGREvent, ...) (sortedSuppls *SortedSuppliers, err error)

+ type LoadDistributionSorter struct

+ func NewLoadDistributionSorter(spS *SupplierService) *LoadDistributionSorter

+ func (ws *LoadDistributionSorter) SortSuppliers(prflID string, suppls []*Supplier, suplEv *utils.CGREvent, ...) (sortedSuppls *SortedSuppliers, err error)

+ type LoadReader interface

+ GetTPAccountActions func(*utils.TPAccountActions) ([]*utils.TPAccountActions, error)

+ GetTPActionPlans func(string, string) ([]*utils.TPActionPlan, error)

+ GetTPActionTriggers func(string, string) ([]*utils.TPActionTriggers, error)

+ GetTPActions func(string, string) ([]*utils.TPActions, error)

+ GetTPAttributes func(string, string, string) ([]*utils.TPAttributeProfile, error)

+ GetTPChargers func(string, string, string) ([]*utils.TPChargerProfile, error)

+ GetTPDestinationRates func(string, string, *utils.Paginator) ([]*utils.TPDestinationRate, error)

+ GetTPDestinations func(string, string) ([]*utils.TPDestination, error)

+ GetTPDispatcherHosts func(string, string, string) ([]*utils.TPDispatcherHost, error)

+ GetTPDispatcherProfiles func(string, string, string) ([]*utils.TPDispatcherProfile, error)

+ GetTPFilters func(string, string, string) ([]*utils.TPFilterProfile, error)

+ GetTPRates func(string, string) ([]*utils.TPRate, error)

+ GetTPRatingPlans func(string, string, *utils.Paginator) ([]*utils.TPRatingPlan, error)

+ GetTPRatingProfiles func(*utils.TPRatingProfile) ([]*utils.TPRatingProfile, error)

+ GetTPResources func(string, string, string) ([]*utils.TPResourceProfile, error)

+ GetTPSharedGroups func(string, string) ([]*utils.TPSharedGroups, error)

+ GetTPStats func(string, string, string) ([]*utils.TPStatProfile, error)

+ GetTPSuppliers func(string, string, string) ([]*utils.TPSupplierProfile, error)

+ GetTPThresholds func(string, string, string) ([]*utils.TPThresholdProfile, error)

+ GetTPTimings func(string, string) ([]*utils.ApierTPTiming, error)

+ GetTpIds func(string) ([]string, error)

+ GetTpTableIds func(string, string, utils.TPDistinctIds, map[string]string, ...) ([]string, error)

+ type LoadStorage interface

+ type LoadWriter interface

+ RemTpData func(string, string, map[string]string) error

+ SetTPAccountActions func([]*utils.TPAccountActions) error

+ SetTPActionPlans func([]*utils.TPActionPlan) error

+ SetTPActionTriggers func([]*utils.TPActionTriggers) error

+ SetTPActions func([]*utils.TPActions) error

+ SetTPAttributes func([]*utils.TPAttributeProfile) error

+ SetTPChargers func([]*utils.TPChargerProfile) error

+ SetTPDestinationRates func([]*utils.TPDestinationRate) error

+ SetTPDestinations func([]*utils.TPDestination) error

+ SetTPDispatcherHosts func([]*utils.TPDispatcherHost) error

+ SetTPDispatcherProfiles func([]*utils.TPDispatcherProfile) error

+ SetTPFilters func([]*utils.TPFilterProfile) error

+ SetTPRates func([]*utils.TPRate) error

+ SetTPRatingPlans func([]*utils.TPRatingPlan) error

+ SetTPRatingProfiles func([]*utils.TPRatingProfile) error

+ SetTPResources func([]*utils.TPResourceProfile) error

+ SetTPSharedGroups func([]*utils.TPSharedGroups) error

+ SetTPStats func([]*utils.TPStatProfile) error

+ SetTPSuppliers func([]*utils.TPSupplierProfile) error

+ SetTPThresholds func([]*utils.TPThresholdProfile) error

+ SetTPTimings func([]*utils.ApierTPTiming) error

+ type LowestBalancesSorter []*Balance

+ func (lbcs LowestBalancesSorter) Len() int

+ func (lbcs LowestBalancesSorter) Less(i, j int) bool

+ func (lbcs LowestBalancesSorter) Swap(i, j int)

+ type MapEvent map[string]interface

+ func (me MapEvent) AsCDR(cfg *config.CGRConfig, tnt, tmz string) (cdr *CDR, err error)

+ func (me MapEvent) AsMapString(ignoredFlds *utils.StringSet) (mp map[string]string)

+ func (me MapEvent) AsNavigableMap([]*config.FCTemplate) (*config.NavigableMap, error)

+ func (me MapEvent) Clone() (mp MapEvent)

+ func (me MapEvent) Data() map[string]interface{}

+ func (me MapEvent) FieldAsInterface(fldPath []string) (interface{}, error)

+ func (me MapEvent) FieldAsString(fldPath []string) (string, error)

+ func (me MapEvent) GetDuration(fldName string) (d time.Duration, err error)

+ func (me MapEvent) GetDurationIgnoreErrors(fldName string) (d time.Duration)

+ func (me MapEvent) GetDurationPtr(fldName string) (d *time.Duration, err error)

+ func (me MapEvent) GetDurationPtrIgnoreErrors(fldName string) (d *time.Duration)

+ func (me MapEvent) GetDurationPtrOrDefault(fldName string, dflt *time.Duration) (d *time.Duration, err error)

+ func (me MapEvent) GetString(fldName string) (out string, err error)

+ func (me MapEvent) GetStringIgnoreErrors(fldName string) (out string)

+ func (me MapEvent) GetTInt64(fldName string) (out int64, err error)

+ func (me MapEvent) GetTime(fldName string, timezone string) (t time.Time, err error)

+ func (me MapEvent) GetTimeIgnoreErrors(fldName string, tmz string) (t time.Time)

+ func (me MapEvent) GetTimePtr(fldName, tmz string) (t *time.Time, err error)

+ func (me MapEvent) GetTimePtrIgnoreErrors(fldName, tmz string) (t *time.Time)

+ func (me MapEvent) HasField(fldName string) (has bool)

+ func (me MapEvent) RemoteHost() net.Addr

+ func (me MapEvent) String() string

+ func NewMapEvent(mp map[string]interface{}) (me MapEvent)

+ type Marshaler interface

+ Marshal func(v interface{}) ([]byte, error)

+ Unmarshal func(data []byte, v interface{}) error

+ func NewMarshaler(mrshlerStr string) (ms Marshaler, err error)

+ type MetricWithFilters struct

+ FilterIDs []string

+ MetricID string

+ type MonetaryInfo struct

+ ID string

+ RateInterval *RateInterval

+ UUID string

+ Value float64

+ func (mi *MonetaryInfo) Clone() *MonetaryInfo

+ func (mi *MonetaryInfo) Equal(other *MonetaryInfo) bool

+ type MongoStorage struct

+ func NewMongoStorage(host, port, db, user, pass, storageType string, cdrsIndexes []string, ...) (ms *MongoStorage, err error)

+ func (ms *MongoStorage) AddLoadHistory(ldInst *utils.LoadInstance, loadHistSize int, transactionID string) error

+ func (ms *MongoStorage) Close()

+ func (ms *MongoStorage) DB() *mongo.Database

+ func (ms *MongoStorage) EnsureIndexes(cols ...string) (err error)

+ func (ms *MongoStorage) Flush(ignore string) (err error)

+ func (ms *MongoStorage) GetAccountActionPlansDrv(acntID string, skipCache bool, transactionID string) (aPlIDs []string, err error)

+ func (ms *MongoStorage) GetAccountDrv(key string) (result *Account, err error)

+ func (ms *MongoStorage) GetActionPlanDrv(key string, skipCache bool, transactionID string) (ats *ActionPlan, err error)

+ func (ms *MongoStorage) GetActionTriggersDrv(key string) (atrs ActionTriggers, err error)

+ func (ms *MongoStorage) GetActionsDrv(key string) (as Actions, err error)

+ func (ms *MongoStorage) GetAllActionPlansDrv() (ats map[string]*ActionPlan, err error)

+ func (ms *MongoStorage) GetAttributeProfileDrv(tenant, id string) (r *AttributeProfile, err error)

+ func (ms *MongoStorage) GetCDRs(qryFltr *utils.CDRsFilter, remove bool) ([]*CDR, int64, error)

+ func (ms *MongoStorage) GetChargerProfileDrv(tenant, id string) (r *ChargerProfile, err error)

+ func (ms *MongoStorage) GetContext() context.Context

+ func (ms *MongoStorage) GetDestinationDrv(key string, skipCache bool, transactionID string) (result *Destination, err error)

+ func (ms *MongoStorage) GetDispatcherHostDrv(tenant, id string) (r *DispatcherHost, err error)

+ func (ms *MongoStorage) GetDispatcherProfileDrv(tenant, id string) (r *DispatcherProfile, err error)

+ func (ms *MongoStorage) GetFilterDrv(tenant, id string) (r *Filter, err error)

+ func (ms *MongoStorage) GetFilterIndexesDrv(cacheID, itemIDPrefix, filterType string, fldNameVal map[string]string) (indexes map[string]utils.StringMap, err error)

+ func (ms *MongoStorage) GetItemLoadIDsDrv(itemIDPrefix string) (loadIDs map[string]int64, err error)

+ func (ms *MongoStorage) GetKeysForPrefix(prefix string) (result []string, err error)

+ func (ms *MongoStorage) GetLoadHistory(limit int, skipCache bool, transactionID string) (loadInsts []*utils.LoadInstance, err error)

+ func (ms *MongoStorage) GetRatingPlanDrv(key string) (rp *RatingPlan, err error)

+ func (ms *MongoStorage) GetRatingProfileDrv(key string) (rp *RatingProfile, err error)

+ func (ms *MongoStorage) GetResourceDrv(tenant, id string) (r *Resource, err error)

+ func (ms *MongoStorage) GetResourceProfileDrv(tenant, id string) (rp *ResourceProfile, err error)

+ func (ms *MongoStorage) GetReverseDestinationDrv(prefix string, skipCache bool, transactionID string) (ids []string, err error)

+ func (ms *MongoStorage) GetSMCosts(cgrid, runid, originHost, originIDPrefix string) (smcs []*SMCost, err error)

+ func (ms *MongoStorage) GetSharedGroupDrv(key string) (sg *SharedGroup, err error)

+ func (ms *MongoStorage) GetStatQueueDrv(tenant, id string) (sq *StatQueue, err error)

+ func (ms *MongoStorage) GetStatQueueProfileDrv(tenant string, id string) (sq *StatQueueProfile, err error)

+ func (ms *MongoStorage) GetStorageType() string

+ func (ms *MongoStorage) GetSupplierProfileDrv(tenant, id string) (r *SupplierProfile, err error)

+ func (ms *MongoStorage) GetTPAccountActions(tp *utils.TPAccountActions) ([]*utils.TPAccountActions, error)

+ func (ms *MongoStorage) GetTPActionPlans(tpid, id string) ([]*utils.TPActionPlan, error)

+ func (ms *MongoStorage) GetTPActionTriggers(tpid, id string) ([]*utils.TPActionTriggers, error)

+ func (ms *MongoStorage) GetTPActions(tpid, id string) ([]*utils.TPActions, error)

+ func (ms *MongoStorage) GetTPAttributes(tpid, tenant, id string) ([]*utils.TPAttributeProfile, error)

+ func (ms *MongoStorage) GetTPChargers(tpid, tenant, id string) ([]*utils.TPChargerProfile, error)

+ func (ms *MongoStorage) GetTPDestinationRates(tpid, id string, pag *utils.Paginator) ([]*utils.TPDestinationRate, error)

+ func (ms *MongoStorage) GetTPDestinations(tpid, id string) ([]*utils.TPDestination, error)

+ func (ms *MongoStorage) GetTPDispatcherHosts(tpid, tenant, id string) ([]*utils.TPDispatcherHost, error)

+ func (ms *MongoStorage) GetTPDispatcherProfiles(tpid, tenant, id string) ([]*utils.TPDispatcherProfile, error)

+ func (ms *MongoStorage) GetTPFilters(tpid, tenant, id string) ([]*utils.TPFilterProfile, error)

+ func (ms *MongoStorage) GetTPRates(tpid, id string) ([]*utils.TPRate, error)

+ func (ms *MongoStorage) GetTPRatingPlans(tpid, id string, pag *utils.Paginator) ([]*utils.TPRatingPlan, error)

+ func (ms *MongoStorage) GetTPRatingProfiles(tp *utils.TPRatingProfile) ([]*utils.TPRatingProfile, error)

+ func (ms *MongoStorage) GetTPResources(tpid, tenant, id string) ([]*utils.TPResourceProfile, error)

+ func (ms *MongoStorage) GetTPSharedGroups(tpid, id string) ([]*utils.TPSharedGroups, error)

+ func (ms *MongoStorage) GetTPStats(tpid, tenant, id string) ([]*utils.TPStatProfile, error)

+ func (ms *MongoStorage) GetTPSuppliers(tpid, tenant, id string) ([]*utils.TPSupplierProfile, error)

+ func (ms *MongoStorage) GetTPThresholds(tpid, tenant, id string) ([]*utils.TPThresholdProfile, error)

+ func (ms *MongoStorage) GetTPTimings(tpid, id string) ([]*utils.ApierTPTiming, error)

+ func (ms *MongoStorage) GetThresholdDrv(tenant, id string) (r *Threshold, err error)

+ func (ms *MongoStorage) GetThresholdProfileDrv(tenant, ID string) (tp *ThresholdProfile, err error)

+ func (ms *MongoStorage) GetTimingDrv(id string) (t *utils.TPTiming, err error)

+ func (ms *MongoStorage) GetTpIds(colName string) (tpids []string, err error)

+ func (ms *MongoStorage) GetTpTableIds(tpid, table string, distinct utils.TPDistinctIds, filter map[string]string, ...) ([]string, error)

+ func (ms *MongoStorage) GetVersions(itm string) (vrs Versions, err error)

+ func (ms *MongoStorage) HasDataDrv(category, subject, tenant string) (has bool, err error)

+ func (ms *MongoStorage) IsDBEmpty() (resp bool, err error)

+ func (ms *MongoStorage) IsDataDB() bool

+ func (ms *MongoStorage) MatchFilterIndexDrv(cacheID, itemIDPrefix, filterType, fldName, fldVal string) (itemIDs utils.StringMap, err error)

+ func (ms *MongoStorage) PopTask() (t *Task, err error)

+ func (ms *MongoStorage) PushTask(t *Task) error

+ func (ms *MongoStorage) RebuildReverseForPrefix(prefix string) (err error)

+ func (ms *MongoStorage) RemAccountActionPlansDrv(acntID string, aPlIDs []string) (err error)

+ func (ms *MongoStorage) RemStatQueueDrv(tenant, id string) (err error)

+ func (ms *MongoStorage) RemStatQueueProfileDrv(tenant, id string) (err error)

+ func (ms *MongoStorage) RemThresholdProfileDrv(tenant, id string) (err error)

+ func (ms *MongoStorage) RemTpData(table, tpid string, args map[string]string) error

+ func (ms *MongoStorage) RemoveAccountDrv(key string) (err error)

+ func (ms *MongoStorage) RemoveActionPlanDrv(key string, transactionID string) error

+ func (ms *MongoStorage) RemoveActionTriggersDrv(key string) error

+ func (ms *MongoStorage) RemoveActionsDrv(key string) error

+ func (ms *MongoStorage) RemoveAttributeProfileDrv(tenant, id string) (err error)

+ func (ms *MongoStorage) RemoveChargerProfileDrv(tenant, id string) (err error)

+ func (ms *MongoStorage) RemoveDestinationDrv(destID string, transactionID string) (err error)

+ func (ms *MongoStorage) RemoveDispatcherHostDrv(tenant, id string) (err error)

+ func (ms *MongoStorage) RemoveDispatcherProfileDrv(tenant, id string) (err error)

+ func (ms *MongoStorage) RemoveFilterDrv(tenant, id string) (err error)

+ func (ms *MongoStorage) RemoveFilterIndexesDrv(cacheID, itemIDPrefix string) (err error)

+ func (ms *MongoStorage) RemoveLoadIDsDrv() (err error)

+ func (ms *MongoStorage) RemoveRatingPlanDrv(key string) error

+ func (ms *MongoStorage) RemoveRatingProfileDrv(key string) error

+ func (ms *MongoStorage) RemoveResourceDrv(tenant, id string) (err error)

+ func (ms *MongoStorage) RemoveResourceProfileDrv(tenant, id string) (err error)

+ func (ms *MongoStorage) RemoveReverseForPrefix(prefix string) (err error)

+ func (ms *MongoStorage) RemoveSMCost(smc *SMCost) error

+ func (ms *MongoStorage) RemoveSMCosts(qryFltr *utils.SMCostFilter) error

+ func (ms *MongoStorage) RemoveSharedGroupDrv(id string) (err error)

+ func (ms *MongoStorage) RemoveSupplierProfileDrv(tenant, id string) (err error)

+ func (ms *MongoStorage) RemoveThresholdDrv(tenant, id string) (err error)

+ func (ms *MongoStorage) RemoveTimingDrv(id string) (err error)

+ func (ms *MongoStorage) RemoveVersions(vrs Versions) (err error)

+ func (ms *MongoStorage) SelectDatabase(dbName string) (err error)

+ func (ms *MongoStorage) SetAccountActionPlansDrv(acntID string, aPlIDs []string, overwrite bool) (err error)

+ func (ms *MongoStorage) SetAccountDrv(acc *Account) error

+ func (ms *MongoStorage) SetActionPlanDrv(key string, ats *ActionPlan, overwrite bool, transactionID string) (err error)

+ func (ms *MongoStorage) SetActionTriggersDrv(key string, atrs ActionTriggers) (err error)

+ func (ms *MongoStorage) SetActionsDrv(key string, as Actions) error

+ func (ms *MongoStorage) SetAttributeProfileDrv(r *AttributeProfile) (err error)

+ func (ms *MongoStorage) SetCDR(cdr *CDR, allowUpdate bool) error

+ func (ms *MongoStorage) SetChargerProfileDrv(r *ChargerProfile) (err error)

+ func (ms *MongoStorage) SetDestinationDrv(dest *Destination, transactionID string) (err error)

+ func (ms *MongoStorage) SetDispatcherHostDrv(r *DispatcherHost) (err error)

+ func (ms *MongoStorage) SetDispatcherProfileDrv(r *DispatcherProfile) (err error)

+ func (ms *MongoStorage) SetFilterDrv(r *Filter) (err error)

+ func (ms *MongoStorage) SetFilterIndexesDrv(cacheID, itemIDPrefix string, indexes map[string]utils.StringMap, commit bool, ...) (err error)

+ func (ms *MongoStorage) SetLoadIDsDrv(loadIDs map[string]int64) (err error)

+ func (ms *MongoStorage) SetRatingPlanDrv(rp *RatingPlan) error

+ func (ms *MongoStorage) SetRatingProfileDrv(rp *RatingProfile) (err error)

+ func (ms *MongoStorage) SetResourceDrv(r *Resource) (err error)

+ func (ms *MongoStorage) SetResourceProfileDrv(rp *ResourceProfile) (err error)

+ func (ms *MongoStorage) SetReverseDestinationDrv(dest *Destination, transactionID string) (err error)

+ func (ms *MongoStorage) SetSMCost(smc *SMCost) error

+ func (ms *MongoStorage) SetSharedGroupDrv(sg *SharedGroup) (err error)

+ func (ms *MongoStorage) SetStatQueueDrv(ssq *StoredStatQueue, sq *StatQueue) (err error)

+ func (ms *MongoStorage) SetStatQueueProfileDrv(sq *StatQueueProfile) (err error)

+ func (ms *MongoStorage) SetSupplierProfileDrv(r *SupplierProfile) (err error)

+ func (ms *MongoStorage) SetTPAccountActions(tps []*utils.TPAccountActions) error

+ func (ms *MongoStorage) SetTPActionPlans(tps []*utils.TPActionPlan) error

+ func (ms *MongoStorage) SetTPActionTriggers(tps []*utils.TPActionTriggers) error

+ func (ms *MongoStorage) SetTPActions(tps []*utils.TPActions) error

+ func (ms *MongoStorage) SetTPAttributes(tpSPs []*utils.TPAttributeProfile) (err error)

+ func (ms *MongoStorage) SetTPChargers(tpCPP []*utils.TPChargerProfile) (err error)

+ func (ms *MongoStorage) SetTPDestinationRates(tps []*utils.TPDestinationRate) error

+ func (ms *MongoStorage) SetTPDestinations(tpDsts []*utils.TPDestination) (err error)

+ func (ms *MongoStorage) SetTPDispatcherHosts(tpDPPs []*utils.TPDispatcherHost) (err error)

+ func (ms *MongoStorage) SetTPDispatcherProfiles(tpDPPs []*utils.TPDispatcherProfile) (err error)

+ func (ms *MongoStorage) SetTPFilters(tpTHs []*utils.TPFilterProfile) (err error)

+ func (ms *MongoStorage) SetTPRStats(tps []*utils.TPStatProfile) (err error)

+ func (ms *MongoStorage) SetTPRates(tps []*utils.TPRate) error

+ func (ms *MongoStorage) SetTPRatingPlans(tps []*utils.TPRatingPlan) error

+ func (ms *MongoStorage) SetTPRatingProfiles(tps []*utils.TPRatingProfile) error

+ func (ms *MongoStorage) SetTPResources(tpRLs []*utils.TPResourceProfile) (err error)

+ func (ms *MongoStorage) SetTPSharedGroups(tps []*utils.TPSharedGroups) error

+ func (ms *MongoStorage) SetTPStats(tpSTs []*utils.TPStatProfile) (err error)

+ func (ms *MongoStorage) SetTPSuppliers(tpSPs []*utils.TPSupplierProfile) (err error)

+ func (ms *MongoStorage) SetTPThresholds(tpTHs []*utils.TPThresholdProfile) (err error)

+ func (ms *MongoStorage) SetTPTimings(tps []*utils.ApierTPTiming) error

+ func (ms *MongoStorage) SetTTL(ttl time.Duration)

+ func (ms *MongoStorage) SetThresholdDrv(r *Threshold) (err error)

+ func (ms *MongoStorage) SetThresholdProfileDrv(tp *ThresholdProfile) (err error)

+ func (ms *MongoStorage) SetTimingDrv(t *utils.TPTiming) (err error)

+ func (ms *MongoStorage) SetVersions(vrs Versions, overwrite bool) (err error)

+ func (ms *MongoStorage) UpdateReverseDestinationDrv(oldDest, newDest *Destination, transactionID string) error

+ type MySQLStorage struct

+ func (self *MySQLStorage) GetStorageType() string

+ func (self *MySQLStorage) SetVersions(vrs Versions, overwrite bool) (err error)

+ type PjsuaAccount struct

+ Id string

+ Password string

+ Realm string

+ Registrar string

+ Username string

+ type Poster interface

+ Close func()

+ Post func(body []byte, key string) error

+ func NewAMQPv1Poster(dialURL string, attempts int) (Poster, error)

+ func NewS3Poster(dialURL string, attempts int) (Poster, error)

+ func NewSQSPoster(dialURL string, attempts int) (Poster, error)

+ type PosterCache struct

+ var PostersCache *PosterCache

+ func (pc *PosterCache) Close()

+ func (pc *PosterCache) GetAMQPPoster(dialURL string, attempts int) (pstr Poster, err error)

+ func (pc *PosterCache) GetAMQPv1Poster(dialURL string, attempts int) (pstr Poster, err error)

+ func (pc *PosterCache) GetKafkaPoster(dialURL string, attempts int) (pstr Poster, err error)

+ func (pc *PosterCache) GetS3Poster(dialURL string, attempts int) (pstr Poster, err error)

+ func (pc *PosterCache) GetSQSPoster(dialURL string, attempts int) (pstr Poster, err error)

+ func (pc *PosterCache) PostAMQP(dialURL string, attempts int, content []byte) error

+ func (pc *PosterCache) PostAMQPv1(dialURL string, attempts int, content []byte) error

+ func (pc *PosterCache) PostKafka(dialURL string, attempts int, content []byte, key string) error

+ func (pc *PosterCache) PostS3(dialURL string, attempts int, content []byte, key string) error

+ func (pc *PosterCache) PostSQS(dialURL string, attempts int, content []byte) error

+ type PostgresStorage struct

+ func (self *PostgresStorage) GetStorageType() string

+ func (self *PostgresStorage) SetVersions(vrs Versions, overwrite bool) (err error)

+ type QOSSupplierSorter struct

+ func NewQOSSupplierSorter(spS *SupplierService) *QOSSupplierSorter

+ func (qos *QOSSupplierSorter) SortSuppliers(prflID string, suppls []*Supplier, ev *utils.CGREvent, ...) (sortedSuppls *SortedSuppliers, err error)

+ type RIRate struct

+ ConnectFee float64

+ MaxCost float64

+ MaxCostStrategy string

+ Rates RateGroups

+ RoundingDecimals int

+ RoundingMethod string

+ func (rir *RIRate) Stringify() string

+ func (rit *RIRate) Clone() (cln *RIRate)

+ type RITiming struct

+ EndTime string

+ MonthDays utils.MonthDays

+ Months utils.Months

+ StartTime string

+ WeekDays utils.WeekDays

+ Years utils.Years

+ func (rit *RITiming) Clone() (cln *RITiming)

+ func (rit *RITiming) CronString() string

+ func (rit *RITiming) IsActive() bool

+ func (rit *RITiming) IsActiveAt(t time.Time) bool

+ func (rit *RITiming) IsBlank() bool

+ func (rit *RITiming) Stringify() string

+ type RPCClientSet struct

+ var IntRPC *RPCClientSet

+ func NewRPCClientSet() (s *RPCClientSet)

+ func (s *RPCClientSet) AddInternalRPCClient(name string, connChan chan rpcclient.ClientConnector)

+ func (s *RPCClientSet) AddRPCClient(name string, rpc *rpcclient.RPCClient)

+ func (s *RPCClientSet) AddRPCConnection(name, transport, addr string, tls bool, key_path, cert_path, ca_path string, ...) error

+ func (s *RPCClientSet) Call(method string, args interface{}, reply interface{}) error

+ func (s *RPCClientSet) GetInternalChanel() chan rpcclient.ClientConnector

+ type RPCRequest struct

+ Address string

+ Async bool

+ Attempts int

+ Method string

+ Params map[string]interface{}

+ Transport string

+ type RPRate struct

+ Rating string

+ Timing string

+ Weight float64

+ func (rpr *RPRate) Equal(orpr *RPRate) bool

+ type RPRateList []*RPRate

+ type RandomBalancesSorter []*Balance

+ func (rbcs *RandomBalancesSorter) Sort()

+ type Rate struct

+ GroupIntervalStart time.Duration

+ RateIncrement time.Duration

+ RateUnit time.Duration

+ Value float64

+ func (p *Rate) Equal(o *Rate) bool

+ func (r *Rate) Clone() (cln *Rate)

+ func (r *Rate) FieldAsInterface(fldPath []string) (val interface{}, err error)

+ func (r *Rate) Stringify() string

+ type RateGroups []*Rate

+ func (pg *RateGroups) AddRate(ps ...*Rate)

+ func (pg RateGroups) Clone() (cln RateGroups)

+ func (pg RateGroups) Equal(og RateGroups) bool

+ func (pg RateGroups) Equals(oRG RateGroups) bool

+ func (pg RateGroups) Len() int

+ func (pg RateGroups) Less(i, j int) bool

+ func (pg RateGroups) Sort()

+ func (pg RateGroups) Swap(i, j int)

+ type RateInterval struct

+ Rating *RIRate

+ Timing *RITiming

+ Weight float64

+ func GetRateInterval(rpl *utils.TPRatingPlanBinding, dr *utils.DestinationRate) (i *RateInterval)

+ func (i *RateInterval) Clone() (cln *RateInterval)

+ func (i *RateInterval) Contains(t time.Time, endTime bool) bool

+ func (i *RateInterval) Equal(o *RateInterval) bool

+ func (i *RateInterval) GetCost(duration, startSecond time.Duration) float64

+ func (i *RateInterval) GetRateParameters(startSecond time.Duration) (rate float64, rateIncrement, rateUnit time.Duration)

+ func (i *RateInterval) String_DISABLED() string

+ func (ri *RateInterval) GetMaxCost() (float64, string)

+ type RateIntervalList []*RateInterval

+ func (rl RateIntervalList) GetWeight() float64

+ type RateIntervalTimeSorter struct

+ func (il *RateIntervalTimeSorter) Len() int

+ func (il *RateIntervalTimeSorter) Less(j, i int) bool

+ func (il *RateIntervalTimeSorter) Sort() []*RateInterval

+ func (il *RateIntervalTimeSorter) Swap(i, j int)

+ type Rating map[string]*RatingUnit

+ func (crus *Rating) FieldAsInterface(fldPath []string) (val interface{}, err error)

+ func (crus Rating) Clone() (cln Rating)

+ func (crus Rating) GetIDWithSet(cru *RatingUnit) string

+ type RatingFilters map[string]RatingMatchedFilters

+ func (rfs *RatingFilters) FieldAsInterface(fldPath []string) (val interface{}, err error)

+ func (rfs RatingFilters) Clone() (cln RatingFilters)

+ func (rfs RatingFilters) GetIDWithSet(rmf RatingMatchedFilters) string

+ type RatingInfo struct

+ ActivationTime time.Time

+ FallbackKeys []string

+ MatchedDestId string

+ MatchedPrefix string

+ MatchedSubject string

+ RateIntervals RateIntervalList

+ RatingPlanId string

+ func (ri RatingInfo) SelectRatingIntevalsForTimespan(ts *TimeSpan) (result RateIntervalList)

+ type RatingInfos []*RatingInfo

+ func (ris RatingInfos) Len() int

+ func (ris RatingInfos) Less(i, j int) bool

+ func (ris RatingInfos) Sort()

+ func (ris RatingInfos) String() string

+ func (ris RatingInfos) Swap(i, j int)

+ type RatingMatchedFilters map[string]interface

+ func (rf *RatingMatchedFilters) FieldAsInterface(fldPath []string) (val interface{}, err error)

+ func (rf RatingMatchedFilters) Clone() (cln map[string]interface{})

+ func (rf RatingMatchedFilters) Equals(oRF RatingMatchedFilters) bool

+ type RatingPlan struct

+ DestinationRates map[string]RPRateList

+ Id string

+ Ratings map[string]*RIRate

+ Timings map[string]*RITiming

+ func (rp *RatingPlan) AddRateInterval(dId string, ris ...*RateInterval)

+ func (rp *RatingPlan) Equal(o *RatingPlan) bool

+ func (rp *RatingPlan) RateIntervalList(dId string) RateIntervalList

+ type RatingPlanActivation struct

+ ActivationTime time.Time

+ FallbackKeys []string

+ RatingPlanId string

+ func (rpa *RatingPlanActivation) Equal(orpa *RatingPlanActivation) bool

+ type RatingPlanActivations []*RatingPlanActivation

+ func (rpas RatingPlanActivations) GetActiveForCall(cd *CallDescriptor) RatingPlanActivations

+ func (rpas RatingPlanActivations) Len() int

+ func (rpas RatingPlanActivations) Less(i, j int) bool

+ func (rpas RatingPlanActivations) Sort()

+ func (rpas RatingPlanActivations) Swap(i, j int)

+ type RatingProfile struct

+ Id string

+ RatingPlanActivations RatingPlanActivations

+ func RatingProfileSubjectPrefixMatching(key string) (rp *RatingProfile, err error)

+ func (rpf *RatingProfile) GetRatingPlansForPrefix(cd *CallDescriptor) (err error)

+ type RatingUnit struct

+ ConnectFee float64

+ MaxCost float64

+ MaxCostStrategy string

+ RatesID string

+ RatingFiltersID string

+ RoundingDecimals int

+ RoundingMethod string

+ TimingID string

+ func (ru *RatingUnit) Clone() (cln *RatingUnit)

+ func (ru *RatingUnit) Equals(oRU *RatingUnit) bool

+ func (ru *RatingUnit) FieldAsInterface(fldPath []string) (val interface{}, err error)

+ type RawCdr interface

+ AsCDR func(string) *CDR

+ type RedisStorage struct

+ func NewRedisStorage(address string, db int, pass, mrshlerStr string, maxConns int, ...) (*RedisStorage, error)

+ func (rs *RedisStorage) AddLoadHistory(ldInst *utils.LoadInstance, loadHistSize int, transactionID string) error

+ func (rs *RedisStorage) Close()

+ func (rs *RedisStorage) Cmd(cmd string, args ...interface{}) *redis.Resp

+ func (rs *RedisStorage) Flush(ignore string) error

+ func (rs *RedisStorage) GetAccountActionPlansDrv(acntID string, skipCache bool, transactionID string) (aPlIDs []string, err error)

+ func (rs *RedisStorage) GetAccountDrv(key string) (*Account, error)

+ func (rs *RedisStorage) GetActionPlanDrv(key string, skipCache bool, transactionID string) (ats *ActionPlan, err error)

+ func (rs *RedisStorage) GetActionTriggersDrv(key string) (atrs ActionTriggers, err error)

+ func (rs *RedisStorage) GetActionsDrv(key string) (as Actions, err error)

+ func (rs *RedisStorage) GetAllActionPlansDrv() (ats map[string]*ActionPlan, err error)

+ func (rs *RedisStorage) GetAttributeProfileDrv(tenant, id string) (r *AttributeProfile, err error)

+ func (rs *RedisStorage) GetChargerProfileDrv(tenant, id string) (r *ChargerProfile, err error)

+ func (rs *RedisStorage) GetDestinationDrv(key string, skipCache bool, transactionID string) (dest *Destination, err error)

+ func (rs *RedisStorage) GetDispatcherHostDrv(tenant, id string) (r *DispatcherHost, err error)

+ func (rs *RedisStorage) GetDispatcherProfileDrv(tenant, id string) (r *DispatcherProfile, err error)

+ func (rs *RedisStorage) GetFilterDrv(tenant, id string) (r *Filter, err error)

+ func (rs *RedisStorage) GetFilterIndexesDrv(cacheID, itemIDPrefix, filterType string, fldNameVal map[string]string) (indexes map[string]utils.StringMap, err error)

+ func (rs *RedisStorage) GetItemLoadIDsDrv(itemIDPrefix string) (loadIDs map[string]int64, err error)

+ func (rs *RedisStorage) GetKeysForPrefix(prefix string) ([]string, error)

+ func (rs *RedisStorage) GetLoadHistory(limit int, skipCache bool, transactionID string) ([]*utils.LoadInstance, error)

+ func (rs *RedisStorage) GetRatingPlanDrv(key string) (rp *RatingPlan, err error)

+ func (rs *RedisStorage) GetRatingProfileDrv(key string) (rpf *RatingProfile, err error)

+ func (rs *RedisStorage) GetResourceDrv(tenant, id string) (r *Resource, err error)

+ func (rs *RedisStorage) GetResourceProfileDrv(tenant, id string) (rsp *ResourceProfile, err error)

+ func (rs *RedisStorage) GetReverseDestinationDrv(key string, skipCache bool, transactionID string) (ids []string, err error)

+ func (rs *RedisStorage) GetSharedGroupDrv(key string) (sg *SharedGroup, err error)

+ func (rs *RedisStorage) GetStatQueueDrv(tenant, id string) (sq *StatQueue, err error)

+ func (rs *RedisStorage) GetStatQueueProfileDrv(tenant string, id string) (sq *StatQueueProfile, err error)

+ func (rs *RedisStorage) GetStorageType() string

+ func (rs *RedisStorage) GetSupplierProfileDrv(tenant, id string) (r *SupplierProfile, err error)

+ func (rs *RedisStorage) GetThresholdDrv(tenant, id string) (r *Threshold, err error)

+ func (rs *RedisStorage) GetThresholdProfileDrv(tenant, ID string) (tp *ThresholdProfile, err error)

+ func (rs *RedisStorage) GetTimingDrv(id string) (t *utils.TPTiming, err error)

+ func (rs *RedisStorage) GetVersions(itm string) (vrs Versions, err error)

+ func (rs *RedisStorage) HasDataDrv(category, subject, tenant string) (bool, error)

+ func (rs *RedisStorage) IsDBEmpty() (resp bool, err error)

+ func (rs *RedisStorage) Marshaler() Marshaler

+ func (rs *RedisStorage) MatchFilterIndexDrv(cacheID, itemIDPrefix, filterType, fldName, fldVal string) (itemIDs utils.StringMap, err error)

+ func (rs *RedisStorage) PopTask() (t *Task, err error)

+ func (rs *RedisStorage) PushTask(t *Task) error

+ func (rs *RedisStorage) RebbuildActionPlanKeys() error

+ func (rs *RedisStorage) RebuildReverseForPrefix(prefix string) (err error)

+ func (rs *RedisStorage) RemAccountActionPlansDrv(acntID string, aPlIDs []string) (err error)

+ func (rs *RedisStorage) RemStatQueueDrv(tenant, id string) (err error)

+ func (rs *RedisStorage) RemStatQueueProfileDrv(tenant, id string) (err error)

+ func (rs *RedisStorage) RemThresholdProfileDrv(tenant, id string) (err error)

+ func (rs *RedisStorage) RemoveAccountDrv(key string) (err error)

+ func (rs *RedisStorage) RemoveActionPlanDrv(key string, transactionID string) error

+ func (rs *RedisStorage) RemoveActionTriggersDrv(key string) (err error)

+ func (rs *RedisStorage) RemoveActionsDrv(key string) (err error)

+ func (rs *RedisStorage) RemoveAttributeProfileDrv(tenant, id string) (err error)

+ func (rs *RedisStorage) RemoveChargerProfileDrv(tenant, id string) (err error)

+ func (rs *RedisStorage) RemoveDestinationDrv(destID, transactionID string) (err error)

+ func (rs *RedisStorage) RemoveDispatcherHostDrv(tenant, id string) (err error)

+ func (rs *RedisStorage) RemoveDispatcherProfileDrv(tenant, id string) (err error)

+ func (rs *RedisStorage) RemoveFilterDrv(tenant, id string) (err error)

+ func (rs *RedisStorage) RemoveFilterIndexesDrv(cacheID, itemIDPrefix string) (err error)

+ func (rs *RedisStorage) RemoveLoadIDsDrv() (err error)

+ func (rs *RedisStorage) RemoveRatingPlanDrv(key string) error

+ func (rs *RedisStorage) RemoveRatingProfileDrv(key string) error

+ func (rs *RedisStorage) RemoveResourceDrv(tenant, id string) (err error)

+ func (rs *RedisStorage) RemoveResourceProfileDrv(tenant, id string) (err error)

+ func (rs *RedisStorage) RemoveReverseForPrefix(prefix string) (err error)

+ func (rs *RedisStorage) RemoveSharedGroupDrv(id string) (err error)

+ func (rs *RedisStorage) RemoveSupplierProfileDrv(tenant, id string) (err error)

+ func (rs *RedisStorage) RemoveThresholdDrv(tenant, id string) (err error)

+ func (rs *RedisStorage) RemoveTimingDrv(id string) (err error)

+ func (rs *RedisStorage) RemoveVersions(vrs Versions) (err error)

+ func (rs *RedisStorage) SelectDatabase(dbName string) (err error)

+ func (rs *RedisStorage) SetAccountActionPlansDrv(acntID string, aPlIDs []string, overwrite bool) (err error)

+ func (rs *RedisStorage) SetAccountDrv(acc *Account) (err error)

+ func (rs *RedisStorage) SetActionPlanDrv(key string, ats *ActionPlan, overwrite bool, transactionID string) (err error)

+ func (rs *RedisStorage) SetActionTriggersDrv(key string, atrs ActionTriggers) (err error)

+ func (rs *RedisStorage) SetActionsDrv(key string, as Actions) (err error)

+ func (rs *RedisStorage) SetAttributeProfileDrv(r *AttributeProfile) (err error)

+ func (rs *RedisStorage) SetChargerProfileDrv(r *ChargerProfile) (err error)

+ func (rs *RedisStorage) SetDestinationDrv(dest *Destination, transactionID string) (err error)

+ func (rs *RedisStorage) SetDispatcherHostDrv(r *DispatcherHost) (err error)

+ func (rs *RedisStorage) SetDispatcherProfileDrv(r *DispatcherProfile) (err error)

+ func (rs *RedisStorage) SetFilterDrv(r *Filter) (err error)

+ func (rs *RedisStorage) SetFilterIndexesDrv(cacheID, itemIDPrefix string, indexes map[string]utils.StringMap, commit bool, ...) (err error)

+ func (rs *RedisStorage) SetLoadIDsDrv(loadIDs map[string]int64) error

+ func (rs *RedisStorage) SetRatingPlanDrv(rp *RatingPlan) (err error)

+ func (rs *RedisStorage) SetRatingProfileDrv(rpf *RatingProfile) (err error)

+ func (rs *RedisStorage) SetResourceDrv(r *Resource) (err error)

+ func (rs *RedisStorage) SetResourceProfileDrv(rsp *ResourceProfile) error

+ func (rs *RedisStorage) SetReverseDestinationDrv(dest *Destination, transactionID string) (err error)

+ func (rs *RedisStorage) SetSharedGroupDrv(sg *SharedGroup) (err error)

+ func (rs *RedisStorage) SetStatQueueDrv(ssq *StoredStatQueue, sq *StatQueue) (err error)

+ func (rs *RedisStorage) SetStatQueueProfileDrv(sq *StatQueueProfile) (err error)

+ func (rs *RedisStorage) SetSupplierProfileDrv(r *SupplierProfile) (err error)

+ func (rs *RedisStorage) SetThresholdDrv(r *Threshold) (err error)

+ func (rs *RedisStorage) SetThresholdProfileDrv(tp *ThresholdProfile) (err error)

+ func (rs *RedisStorage) SetTimingDrv(t *utils.TPTiming) error

+ func (rs *RedisStorage) SetVersions(vrs Versions, overwrite bool) (err error)

+ func (rs *RedisStorage) UpdateReverseDestinationDrv(oldDest, newDest *Destination, transactionID string) error

+ type RemAccountActionPlansArgs struct

+ AcntID string

+ ApIDs []string

+ type Resource struct

+ ID string

+ TTLIdx []string

+ Tenant string

+ Usages map[string]*ResourceUsage

+ func (r *Resource) TenantID() string

+ func (r *Resource) TotalUsage() (tU float64)

+ type ResourceAscendentSorter struct

+ func NewResourceAscendetSorter(spS *SupplierService) *ResourceAscendentSorter

+ func (ws *ResourceAscendentSorter) SortSuppliers(prflID string, suppls []*Supplier, suplEv *utils.CGREvent, ...) (sortedSuppls *SortedSuppliers, err error)

+ type ResourceDescendentSorter struct

+ func NewResourceDescendentSorter(spS *SupplierService) *ResourceDescendentSorter

+ func (ws *ResourceDescendentSorter) SortSuppliers(prflID string, suppls []*Supplier, suplEv *utils.CGREvent, ...) (sortedSuppls *SortedSuppliers, err error)

+ type ResourceProfile struct

+ ActivationInterval *utils.ActivationInterval

+ AllocationMessage string

+ Blocker bool

+ FilterIDs []string

+ ID string

+ Limit float64

+ Stored bool

+ Tenant string

+ ThresholdIDs []string

+ UsageTTL time.Duration

+ Weight float64

+ func APItoResource(tpRL *utils.TPResourceProfile, timezone string) (rp *ResourceProfile, err error)

+ func (rp *ResourceProfile) TenantID() string

+ type ResourceService struct

+ func NewResourceService(dm *DataManager, cgrcfg *config.CGRConfig, filterS *FilterS, ...) (*ResourceService, error)

+ func (rS *ResourceService) ListenAndServe(exitChan chan bool) error

+ func (rS *ResourceService) Reload()

+ func (rS *ResourceService) SetThresholdConnection(thdS rpcclient.ClientConnector)

+ func (rS *ResourceService) Shutdown() error

+ func (rS *ResourceService) StartLoop()

+ func (rS *ResourceService) StoreResource(r *Resource) (err error)

+ func (rS *ResourceService) V1AllocateResource(args utils.ArgRSv1ResourceUsage, reply *string) (err error)

+ func (rS *ResourceService) V1AuthorizeResources(args utils.ArgRSv1ResourceUsage, reply *string) (err error)

+ func (rS *ResourceService) V1GetResource(arg *utils.TenantID, reply *Resource) error

+ func (rS *ResourceService) V1ReleaseResource(args utils.ArgRSv1ResourceUsage, reply *string) (err error)

+ func (rS *ResourceService) V1ResourcesForEvent(args utils.ArgRSv1ResourceUsage, reply *Resources) (err error)

+ type ResourceUsage struct

+ ExpiryTime time.Time

+ ID string

+ Tenant string

+ Units float64

+ func (ru *ResourceUsage) Clone() (cln *ResourceUsage)

+ func (ru *ResourceUsage) TenantID() string

+ type Resources []*Resource

+ func (rs Resources) IDs() []string

+ func (rs Resources) Sort()

+ type Responder struct

+ ExitChan chan bool

+ MaxComputedUsage map[string]time.Duration

+ Timeout time.Duration

+ Timezone string

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

+ func (rs *Responder) Call(serviceMethod string, args interface{}, reply interface{}) error

+ func (rs *Responder) Debit(arg *CallDescriptorWithArgDispatcher, reply *CallCost) (err error)

+ func (rs *Responder) GetCost(arg *CallDescriptorWithArgDispatcher, reply *CallCost) (err error)

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

+ func (rs *Responder) MaxDebit(arg *CallDescriptorWithArgDispatcher, reply *CallCost) (err error)

+ func (rs *Responder) RefundIncrements(arg *CallDescriptorWithArgDispatcher, reply *Account) (err error)

+ func (rs *Responder) RefundRounding(arg *CallDescriptorWithArgDispatcher, reply *float64) (err error)

+ func (rs *Responder) SetMaxComputedUsage(mx map[string]time.Duration)

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

+ type S3Poster struct

+ func (pstr *S3Poster) Close()

+ func (pstr *S3Poster) Post(message []byte, key string) (err error)

+ type SMCost struct

+ CGRID string

+ CostDetails *EventCost

+ CostSource string

+ OriginHost string

+ OriginID string

+ RunID string

+ Usage time.Duration

+ type SQItem struct

+ EventID string

+ ExpiryTime *time.Time

+ type SQLImpl interface

+ type SQLStorage struct

+ Db *sql.DB

+ func NewMySQLStorage(host, port, name, user, password string, ...) (*SQLStorage, error)

+ func NewPostgresStorage(host, port, name, user, password, sslmode string, ...) (*SQLStorage, error)

+ func (rs *SQLStorage) SelectDatabase(dbName string) (err error)

+ func (self *SQLStorage) Close()

+ func (self *SQLStorage) CreateTablesFromScript(scriptPath string) error

+ func (self *SQLStorage) ExportGormDB() *gorm.DB

+ func (self *SQLStorage) Flush(scriptsPath string) (err error)

+ func (self *SQLStorage) GetCDRs(qryFltr *utils.CDRsFilter, remove bool) ([]*CDR, int64, error)

+ func (self *SQLStorage) GetKeysForPrefix(prefix string) ([]string, error)

+ func (self *SQLStorage) GetSMCosts(cgrid, runid, originHost, originIDPrefix string) ([]*SMCost, error)

+ func (self *SQLStorage) GetTPAccountActions(filter *utils.TPAccountActions) ([]*utils.TPAccountActions, error)

+ func (self *SQLStorage) GetTPActionPlans(tpid, id string) ([]*utils.TPActionPlan, error)

+ func (self *SQLStorage) GetTPActionTriggers(tpid, id string) ([]*utils.TPActionTriggers, error)

+ func (self *SQLStorage) GetTPActions(tpid, id string) ([]*utils.TPActions, error)

+ func (self *SQLStorage) GetTPAttributes(tpid, tenant, id string) ([]*utils.TPAttributeProfile, error)

+ func (self *SQLStorage) GetTPChargers(tpid, tenant, id string) ([]*utils.TPChargerProfile, error)

+ func (self *SQLStorage) GetTPDestinationRates(tpid, id string, pagination *utils.Paginator) ([]*utils.TPDestinationRate, error)

+ func (self *SQLStorage) GetTPDestinations(tpid, id string) (uTPDsts []*utils.TPDestination, err error)

+ func (self *SQLStorage) GetTPDispatcherHosts(tpid, tenant, id string) ([]*utils.TPDispatcherHost, error)

+ func (self *SQLStorage) GetTPDispatcherProfiles(tpid, tenant, id string) ([]*utils.TPDispatcherProfile, error)

+ func (self *SQLStorage) GetTPFilters(tpid, tenant, id string) ([]*utils.TPFilterProfile, error)

+ func (self *SQLStorage) GetTPRates(tpid, id string) ([]*utils.TPRate, error)

+ func (self *SQLStorage) GetTPRatingPlans(tpid, id string, pagination *utils.Paginator) ([]*utils.TPRatingPlan, error)

+ func (self *SQLStorage) GetTPRatingProfiles(filter *utils.TPRatingProfile) ([]*utils.TPRatingProfile, error)

+ func (self *SQLStorage) GetTPResources(tpid, tenant, id string) ([]*utils.TPResourceProfile, error)

+ func (self *SQLStorage) GetTPSharedGroups(tpid, id string) ([]*utils.TPSharedGroups, error)

+ func (self *SQLStorage) GetTPStats(tpid, tenant, id string) ([]*utils.TPStatProfile, error)

+ func (self *SQLStorage) GetTPSuppliers(tpid, tenant, id string) ([]*utils.TPSupplierProfile, error)

+ func (self *SQLStorage) GetTPThresholds(tpid, tenant, id string) ([]*utils.TPThresholdProfile, error)

+ func (self *SQLStorage) GetTPTimings(tpid, id string) ([]*utils.ApierTPTiming, error)

+ func (self *SQLStorage) GetTpIds(colName string) ([]string, error)

+ func (self *SQLStorage) GetTpTableIds(tpid, table string, distinct utils.TPDistinctIds, filters map[string]string, ...) ([]string, error)

+ func (self *SQLStorage) GetVersions(itm string) (vrs Versions, err error)

+ func (self *SQLStorage) IsDBEmpty() (resp bool, err error)

+ func (self *SQLStorage) RebuildReverseForPrefix(prefix string) error

+ func (self *SQLStorage) RemTpData(table, tpid string, args map[string]string) error

+ func (self *SQLStorage) RemoveSMCost(smc *SMCost) error

+ func (self *SQLStorage) RemoveSMCosts(qryFltr *utils.SMCostFilter) error

+ func (self *SQLStorage) RemoveVersions(vrs Versions) (err error)

+ func (self *SQLStorage) SetCDR(cdr *CDR, allowUpdate bool) error

+ func (self *SQLStorage) SetSMCost(smc *SMCost) error

+ func (self *SQLStorage) SetTPAccountActions(aas []*utils.TPAccountActions) error

+ func (self *SQLStorage) SetTPActionPlans(ats []*utils.TPActionPlan) error

+ func (self *SQLStorage) SetTPActionTriggers(ats []*utils.TPActionTriggers) error

+ func (self *SQLStorage) SetTPActions(acts []*utils.TPActions) error

+ func (self *SQLStorage) SetTPAttributes(tpAttrs []*utils.TPAttributeProfile) error

+ func (self *SQLStorage) SetTPChargers(tpCPPs []*utils.TPChargerProfile) error

+ func (self *SQLStorage) SetTPDestinationRates(drs []*utils.TPDestinationRate) error

+ func (self *SQLStorage) SetTPDestinations(dests []*utils.TPDestination) error

+ func (self *SQLStorage) SetTPDispatcherHosts(tpDPPs []*utils.TPDispatcherHost) error

+ func (self *SQLStorage) SetTPDispatcherProfiles(tpDPPs []*utils.TPDispatcherProfile) error

+ func (self *SQLStorage) SetTPFilters(ths []*utils.TPFilterProfile) error

+ func (self *SQLStorage) SetTPRates(rs []*utils.TPRate) error

+ func (self *SQLStorage) SetTPRatingPlans(rps []*utils.TPRatingPlan) error

+ func (self *SQLStorage) SetTPRatingProfiles(rpfs []*utils.TPRatingProfile) error

+ func (self *SQLStorage) SetTPResources(rls []*utils.TPResourceProfile) error

+ func (self *SQLStorage) SetTPSharedGroups(sgs []*utils.TPSharedGroups) error

+ func (self *SQLStorage) SetTPStats(sts []*utils.TPStatProfile) error

+ func (self *SQLStorage) SetTPSuppliers(tpSPs []*utils.TPSupplierProfile) error

+ func (self *SQLStorage) SetTPThresholds(ths []*utils.TPThresholdProfile) error

+ func (self *SQLStorage) SetTPTimings(timings []*utils.ApierTPTiming) error

+ type SQSPoster struct

+ func (pstr *SQSPoster) Close()

+ func (pstr *SQSPoster) Post(message []byte, _ string) (err error)

+ type STGroup struct

+ CustomerNumber string

+ InvoiceNumber string

+ StateCode string

+ TaxList []*STTaxItem

+ type STItemMessage struct

+ LineNumber string

+ Message string

+ ResponseCode string

+ type STRequest struct

+ BusinessUnit string

+ ClientNumber string

+ ClientTracking string

+ DataMonth string

+ DataYear string

+ IndustryExemption string

+ ItemList []*STRequestItem

+ ResponseGroup string

+ ResponseType string

+ ReturnFileCode string

+ TotalRevenue float64

+ ValidationKey string

+ type STRequestItem struct

+ BillToNumber string

+ CustomerNumber string

+ InvoiceNumber string

+ LineNumber string

+ OrigNumber string

+ P2PPlus4 string

+ P2PZipcode string

+ Plus4 string

+ RegulatoryCode string

+ Revenue float64

+ SalesTypeCode string

+ Seconds int64

+ TaxExemptionCodeList []string

+ TaxIncludedCode string

+ TaxSitusRule string

+ TermNumber string

+ TransDate string

+ TransTypeCode string

+ UnitType string

+ Units int64

+ Zipcode string

+ type STResponse struct

+ ClientTracking string

+ GroupList []*STGroup

+ HeaderMessage string

+ ItemMessages []*STItemMessage

+ ResponseCode string

+ Successful string

+ TotalTax string

+ TransId int

+ type STTaxItem struct

+ TaxAmount string

+ TaxTypeCode string

+ TaxTypeDesc string

+ type SafEvent struct

+ Me MapEvent

+ func NewSafEvent(mp map[string]interface{}) *SafEvent

+ func (se *SafEvent) AsCDR(cfg *config.CGRConfig, tnt, tmz string) (cdr *CDR, err error)

+ func (se *SafEvent) AsCGREvent(tnt string) (cgrEv *utils.CGREvent)

+ func (se *SafEvent) AsMapInterface() (mp map[string]interface{})

+ func (se *SafEvent) AsMapString(ignoredFlds *utils.StringSet) (mp map[string]string)

+ func (se *SafEvent) AsNavigableMap(fctemplate []*config.FCTemplate) (out *config.NavigableMap, err error)

+ func (se *SafEvent) Clone() (cln *SafEvent)

+ func (se *SafEvent) FieldAsInterface(fldPath []string) (out interface{}, err error)

+ func (se *SafEvent) FieldAsString(fldPath []string) (out string, err error)

+ func (se *SafEvent) Get(fldName string) (out interface{}, has bool)

+ func (se *SafEvent) GetDuration(fldName string) (d time.Duration, err error)

+ func (se *SafEvent) GetDurationIgnoreErrors(fldName string) (d time.Duration)

+ func (se *SafEvent) GetDurationOrDefault(fldName string, dflt time.Duration) (d time.Duration, err error)

+ func (se *SafEvent) GetDurationPtr(fldName string) (d *time.Duration, err error)

+ func (se *SafEvent) GetDurationPtrIgnoreErrors(fldName string) (d *time.Duration)

+ func (se *SafEvent) GetDurationPtrOrDefault(fldName string, dflt *time.Duration) (d *time.Duration, err error)

+ func (se *SafEvent) GetIgnoreErrors(fldName string) (out interface{})

+ func (se *SafEvent) GetMapInterface() (mp map[string]interface{})

+ func (se *SafEvent) GetSetString(fldName string, setVal string) (out string, err error)

+ func (se *SafEvent) GetString(fldName string) (out string, err error)

+ func (se *SafEvent) GetStringIgnoreErrors(fldName string) (out string)

+ func (se *SafEvent) GetTime(fldName string, tmz string) (t time.Time, err error)

+ func (se *SafEvent) GetTimeIgnoreErrors(fldName string, tmz string) (t time.Time)

+ func (se *SafEvent) HasField(fldName string) (has bool)

+ func (se *SafEvent) MapEvent() (mp MapEvent)

+ func (se *SafEvent) RemoteHost() (out net.Addr)

+ func (se *SafEvent) Remove(fldName string)

+ func (se *SafEvent) Set(fldName string, val interface{})

+ func (se *SafEvent) String() (out string)

+ func (se SafEvent) GetTInt64(fldName string) (out int64, err error)

+ type SessionCostsSQL struct

+ Cgrid string

+ CostDetails string

+ CostSource string

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ ID int64

+ OriginHost string

+ OriginID string

+ RunID string

+ Usage int64

+ func (t SessionCostsSQL) TableName() string

+ type SetAccountActionPlansArg struct

+ AcntID string

+ AplIDs []string

+ Overwrite bool

+ type SetActionPlanArg struct

+ Ats *ActionPlan

+ Key string

+ Overwrite bool

+ type SetActionTriggersArg struct

+ Attrs ActionTriggers

+ Key string

+ type SetActionsArgs struct

+ Acs Actions

+ Key string

+ type SharedGroup struct

+ AccountParameters map[string]*SharingParameters

+ Id string

+ MemberIds utils.StringMap

+ func (sg *SharedGroup) Clone() (sharedGroup *SharedGroup)

+ func (sg *SharedGroup) GetBalances(destination, category, balanceType string, ub *Account, aTime time.Time) (bc Balances)

+ func (sg *SharedGroup) SortBalancesByStrategy(myBalance *Balance, bc Balances) Balances

+ type SharingParameters struct

+ RatingSubject string

+ Strategy string

+ func (sp *SharingParameters) Clone() *SharingParameters

+ type SortedSupplier struct

+ SortingData map[string]interface{}

+ SupplierID string

+ SupplierParameters string

+ type SortedSuppliers struct

+ Count int

+ ProfileID string

+ SortedSuppliers []*SortedSupplier

+ Sorting string

+ func (sSpls *SortedSuppliers) AsNavigableMap() (nm *config.NavigableMap)

+ func (sSpls *SortedSuppliers) Digest() string

+ func (sSpls *SortedSuppliers) SortHighestCost()

+ func (sSpls *SortedSuppliers) SortLeastCost()

+ func (sSpls *SortedSuppliers) SortLoadDistribution()

+ func (sSpls *SortedSuppliers) SortQOS(params []string)

+ func (sSpls *SortedSuppliers) SortResourceAscendent()

+ func (sSpls *SortedSuppliers) SortResourceDescendent()

+ func (sSpls *SortedSuppliers) SortWeight()

+ func (sSpls *SortedSuppliers) SupplierIDs() (sIDs []string)

+ func (sSpls *SortedSuppliers) SuppliersWithParams() (sPs []string)

+ type StatACC struct

+ Count int64

+ Events map[string]*StatWithCompress

+ FilterIDs []string

+ MinItems int

+ Sum float64

+ func (acc *StatACC) AddEvent(ev *utils.CGREvent) (err error)

+ func (acc *StatACC) Compress(queueLen int64, defaultID string) (eventIDs []string)

+ func (acc *StatACC) GetCompressFactor(events map[string]int) map[string]int

+ func (acc *StatACC) GetFilterIDs() []string

+ func (acc *StatACC) GetFloat64Value() (v float64)

+ func (acc *StatACC) GetStringValue(fmtOpts string) (valStr string)

+ func (acc *StatACC) GetValue() (v interface{})

+ func (acc *StatACC) LoadMarshaled(ms Marshaler, marshaled []byte) (err error)

+ func (acc *StatACC) Marshal(ms Marshaler) (marshaled []byte, err error)

+ func (acc *StatACC) RemEvent(evID string) (err error)

+ type StatACD struct

+ Count int64

+ Events map[string]*DurationWithCompress

+ FilterIDs []string

+ MinItems int

+ Sum time.Duration

+ func (acd *StatACD) AddEvent(ev *utils.CGREvent) (err error)

+ func (acd *StatACD) Compress(queueLen int64, defaultID string) (eventIDs []string)

+ func (acd *StatACD) GetCompressFactor(events map[string]int) map[string]int

+ func (acd *StatACD) GetFilterIDs() []string

+ func (acd *StatACD) GetFloat64Value() (v float64)

+ func (acd *StatACD) GetStringValue(fmtOpts string) (valStr string)

+ func (acd *StatACD) GetValue() (v interface{})

+ func (acd *StatACD) LoadMarshaled(ms Marshaler, marshaled []byte) (err error)

+ func (acd *StatACD) Marshal(ms Marshaler) (marshaled []byte, err error)

+ func (acd *StatACD) RemEvent(evID string) (err error)

+ type StatASR struct

+ Answered float64

+ Count int64

+ Events map[string]*StatWithCompress

+ FilterIDs []string

+ MinItems int

+ func (asr *StatASR) AddEvent(ev *utils.CGREvent) (err error)

+ func (asr *StatASR) Compress(queueLen int64, defaultID string) (eventIDs []string)

+ func (asr *StatASR) GetCompressFactor(events map[string]int) map[string]int

+ func (asr *StatASR) GetFilterIDs() []string

+ func (asr *StatASR) GetFloat64Value() (val float64)

+ func (asr *StatASR) GetStringValue(fmtOpts string) (valStr string)

+ func (asr *StatASR) GetValue() (v interface{})

+ func (asr *StatASR) LoadMarshaled(ms Marshaler, marshaled []byte) (err error)

+ func (asr *StatASR) Marshal(ms Marshaler) (marshaled []byte, err error)

+ func (asr *StatASR) RemEvent(evID string) (err error)

+ type StatAverage struct

+ Count int64

+ Events map[string]*StatWithCompress

+ FieldName string

+ FilterIDs []string

+ MinItems int

+ Sum float64

+ func (avg *StatAverage) AddEvent(ev *utils.CGREvent) (err error)

+ func (avg *StatAverage) Compress(queueLen int64, defaultID string) (eventIDs []string)

+ func (avg *StatAverage) GetCompressFactor(events map[string]int) map[string]int

+ func (avg *StatAverage) GetFilterIDs() []string

+ func (avg *StatAverage) GetFloat64Value() (v float64)

+ func (avg *StatAverage) GetStringValue(fmtOpts string) (valStr string)

+ func (avg *StatAverage) GetValue() (v interface{})

+ func (avg *StatAverage) LoadMarshaled(ms Marshaler, marshaled []byte) (err error)

+ func (avg *StatAverage) Marshal(ms Marshaler) (marshaled []byte, err error)

+ func (avg *StatAverage) RemEvent(evID string) (err error)

+ type StatDDC struct

+ Count int64

+ Events map[string]map[string]int64

+ FieldValues map[string]map[string]struct{}

+ FilterIDs []string

+ MinItems int

+ func (ddc *StatDDC) AddEvent(ev *utils.CGREvent) (err error)

+ func (ddc *StatDDC) Compress(queueLen int64, defaultID string) (eventIDs []string)

+ func (ddc *StatDDC) GetCompressFactor(events map[string]int) map[string]int

+ func (ddc *StatDDC) GetFilterIDs() []string

+ func (ddc *StatDDC) GetFloat64Value() (v float64)

+ func (ddc *StatDDC) GetStringValue(fmtOpts string) (valStr string)

+ func (ddc *StatDDC) GetValue() (v interface{})

+ func (ddc *StatDDC) LoadMarshaled(ms Marshaler, marshaled []byte) (err error)

+ func (ddc *StatDDC) Marshal(ms Marshaler) (marshaled []byte, err error)

+ func (ddc *StatDDC) RemEvent(evID string) (err error)

+ type StatDistinct struct

+ Count int64

+ Events map[string]map[string]int64

+ FieldName string

+ FieldValues map[string]map[string]struct{}

+ FilterIDs []string

+ MinItems int

+ func (dst *StatDistinct) AddEvent(ev *utils.CGREvent) (err error)

+ func (dst *StatDistinct) Compress(queueLen int64, defaultID string) (eventIDs []string)

+ func (dst *StatDistinct) GetCompressFactor(events map[string]int) map[string]int

+ func (dst *StatDistinct) GetFilterIDs() []string

+ func (dst *StatDistinct) GetFloat64Value() (v float64)

+ func (dst *StatDistinct) GetStringValue(fmtOpts string) (valStr string)

+ func (dst *StatDistinct) GetValue() (v interface{})

+ func (dst *StatDistinct) LoadMarshaled(ms Marshaler, marshaled []byte) (err error)

+ func (dst *StatDistinct) Marshal(ms Marshaler) (marshaled []byte, err error)

+ func (dst *StatDistinct) RemEvent(evID string) (err error)

+ type StatMetric interface

+ AddEvent func(ev *utils.CGREvent) error

+ Compress func(queueLen int64, defaultID string) (eventIDs []string)

+ GetCompressFactor func(events map[string]int) map[string]int

+ GetFilterIDs func() (filterIDs []string)

+ GetFloat64Value func() (val float64)

+ GetStringValue func(fmtOpts string) (val string)

+ GetValue func() interface{}

+ LoadMarshaled func(ms Marshaler, marshaled []byte) (err error)

+ Marshal func(ms Marshaler) (marshaled []byte, err error)

+ RemEvent func(evTenantID string) error

+ func NewACC(minItems int, extraParams string, filterIDs []string) (StatMetric, error)

+ func NewACD(minItems int, extraParams string, filterIDs []string) (StatMetric, error)

+ func NewASR(minItems int, extraParams string, filterIDs []string) (StatMetric, error)

+ func NewDDC(minItems int, extraParams string, filterIDs []string) (StatMetric, error)

+ func NewPDD(minItems int, extraParams string, filterIDs []string) (StatMetric, error)

+ func NewStatAverage(minItems int, extraParams string, filterIDs []string) (StatMetric, error)

+ func NewStatDistinct(minItems int, extraParams string, filterIDs []string) (StatMetric, error)

+ func NewStatMetric(metricID string, minItems int, filterIDs []string) (sm StatMetric, err error)

+ func NewStatSum(minItems int, extraParams string, filterIDs []string) (StatMetric, error)

+ func NewTCC(minItems int, extraParams string, filterIDs []string) (StatMetric, error)

+ func NewTCD(minItems int, extraParams string, filterIDs []string) (StatMetric, error)

+ type StatPDD struct

+ Count int64

+ Events map[string]*DurationWithCompress

+ FilterIDs []string

+ MinItems int

+ Sum time.Duration

+ func (pdd *StatPDD) AddEvent(ev *utils.CGREvent) (err error)

+ func (pdd *StatPDD) Compress(queueLen int64, defaultID string) (eventIDs []string)

+ func (pdd *StatPDD) GetCompressFactor(events map[string]int) map[string]int

+ func (pdd *StatPDD) GetFilterIDs() []string

+ func (pdd *StatPDD) GetFloat64Value() (v float64)

+ func (pdd *StatPDD) GetStringValue(fmtOpts string) (valStr string)

+ func (pdd *StatPDD) GetValue() (v interface{})

+ func (pdd *StatPDD) LoadMarshaled(ms Marshaler, marshaled []byte) (err error)

+ func (pdd *StatPDD) Marshal(ms Marshaler) (marshaled []byte, err error)

+ func (pdd *StatPDD) RemEvent(evID string) (err error)

+ type StatQueue struct

+ ID string

+ MinItems int

+ SQItems []SQItem

+ SQMetrics map[string]StatMetric

+ Tenant string

+ func (sq *StatQueue) Compress(maxQL int64) bool

+ func (sq *StatQueue) Expand()

+ func (sq *StatQueue) ProcessEvent(ev *utils.CGREvent, filterS *FilterS) (err error)

+ func (sq *StatQueue) TenantID() string

+ type StatQueueProfile struct

+ ActivationInterval *utils.ActivationInterval

+ Blocker bool

+ FilterIDs []string

+ ID string

+ Metrics []*MetricWithFilters

+ MinItems int

+ QueueLength int

+ Stored bool

+ TTL time.Duration

+ Tenant string

+ ThresholdIDs []string

+ Weight float64

+ func APItoStats(tpST *utils.TPStatProfile, timezone string) (st *StatQueueProfile, err error)

+ func (sqp *StatQueueProfile) TenantID() string

+ type StatQueues []*StatQueue

+ func (sis StatQueues) Sort()

+ type StatService struct

+ func NewStatService(dm *DataManager, cgrcfg *config.CGRConfig, filterS *FilterS, ...) (ss *StatService, err error)

+ func (sS *StatService) ListenAndServe(exitChan chan bool) error

+ func (sS *StatService) Reload()

+ func (sS *StatService) Shutdown() error

+ func (sS *StatService) StartLoop()

+ func (sS *StatService) StoreStatQueue(sq *StatQueue) (err error)

+ func (sS *StatService) V1GetQueueFloatMetrics(args *utils.TenantID, reply *map[string]float64) (err error)

+ func (sS *StatService) V1GetQueueIDs(tenant string, qIDs *[]string) (err error)

+ func (sS *StatService) V1GetQueueStringMetrics(args *utils.TenantID, reply *map[string]string) (err error)

+ func (sS *StatService) V1GetStatQueuesForEvent(args *StatsArgsProcessEvent, reply *[]string) (err error)

+ func (sS *StatService) V1ProcessEvent(args *StatsArgsProcessEvent, reply *[]string) (err error)

+ func (ss *StatService) Call(serviceMethod string, args interface{}, reply interface{}) error

+ type StatSum struct

+ Count int64

+ Events map[string]*StatWithCompress

+ FieldName string

+ FilterIDs []string

+ MinItems int

+ Sum float64

+ func (sum *StatSum) AddEvent(ev *utils.CGREvent) (err error)

+ func (sum *StatSum) Compress(queueLen int64, defaultID string) (eventIDs []string)

+ func (sum *StatSum) GetCompressFactor(events map[string]int) map[string]int

+ func (sum *StatSum) GetFilterIDs() []string

+ func (sum *StatSum) GetFloat64Value() (v float64)

+ func (sum *StatSum) GetStringValue(fmtOpts string) (valStr string)

+ func (sum *StatSum) GetValue() (v interface{})

+ func (sum *StatSum) LoadMarshaled(ms Marshaler, marshaled []byte) (err error)

+ func (sum *StatSum) Marshal(ms Marshaler) (marshaled []byte, err error)

+ func (sum *StatSum) RemEvent(evID string) (err error)

+ type StatTCC struct

+ Count int64

+ Events map[string]*StatWithCompress

+ FilterIDs []string

+ MinItems int

+ Sum float64

+ func (tcc *StatTCC) AddEvent(ev *utils.CGREvent) (err error)

+ func (tcc *StatTCC) Compress(queueLen int64, defaultID string) (eventIDs []string)

+ func (tcc *StatTCC) GetCompressFactor(events map[string]int) map[string]int

+ func (tcc *StatTCC) GetFilterIDs() []string

+ func (tcc *StatTCC) GetFloat64Value() (v float64)

+ func (tcc *StatTCC) GetStringValue(fmtOpts string) (valStr string)

+ func (tcc *StatTCC) GetValue() (v interface{})

+ func (tcc *StatTCC) LoadMarshaled(ms Marshaler, marshaled []byte) (err error)

+ func (tcc *StatTCC) Marshal(ms Marshaler) (marshaled []byte, err error)

+ func (tcc *StatTCC) RemEvent(evID string) (err error)

+ type StatTCD struct

+ Count int64

+ Events map[string]*DurationWithCompress

+ FilterIDs []string

+ MinItems int

+ Sum time.Duration

+ func (tcd *StatTCD) AddEvent(ev *utils.CGREvent) (err error)

+ func (tcd *StatTCD) Compress(queueLen int64, defaultID string) (eventIDs []string)

+ func (tcd *StatTCD) GetCompressFactor(events map[string]int) map[string]int

+ func (tcd *StatTCD) GetFilterIDs() []string

+ func (tcd *StatTCD) GetFloat64Value() (v float64)

+ func (tcd *StatTCD) GetStringValue(fmtOpts string) (valStr string)

+ func (tcd *StatTCD) GetValue() (v interface{})

+ func (tcd *StatTCD) LoadMarshaled(ms Marshaler, marshaled []byte) (err error)

+ func (tcd *StatTCD) Marshal(ms Marshaler) (marshaled []byte, err error)

+ func (tcd *StatTCD) RemEvent(evID string) (err error)

+ type StatWithCompress struct

+ CompressFactor int

+ Stat float64

+ type StatsArgsProcessEvent struct

+ StatIDs []string

+ type StorDB interface

+ func NewStorDBConn(dbType, host, port, name, user, pass, sslmode string, ...) (db StorDB, err error)

+ type Storage interface

+ Close func()

+ Flush func(string) error

+ GetKeysForPrefix func(string) ([]string, error)

+ GetStorageType func() string

+ GetVersions func(itm string) (vrs Versions, err error)

+ IsDBEmpty func() (resp bool, err error)

+ RebuildReverseForPrefix func(string) error

+ RemoveReverseForPrefix func(string) error

+ RemoveVersions func(vrs Versions) (err error)

+ SelectDatabase func(dbName string) (err error)

+ SetVersions func(vrs Versions, overwrite bool) (err error)

+ type StoredStatQueue struct

+ Compressed bool

+ ID string

+ MinItems int

+ SQItems []SQItem

+ SQMetrics map[string][]byte

+ Tenant string

+ func NewStoredStatQueue(sq *StatQueue, ms Marshaler) (sSQ *StoredStatQueue, err error)

+ func (ssq *StoredStatQueue) AsStatQueue(ms Marshaler) (sq *StatQueue, err error)

+ func (ssq *StoredStatQueue) SqID() string

+ type Supplier struct

+ AccountIDs []string

+ Blocker bool

+ FilterIDs []string

+ ID string

+ RatingPlanIDs []string

+ ResourceIDs []string

+ StatIDs []string

+ SupplierParameters string

+ Weight float64

+ type SupplierProfile struct

+ ActivationInterval *utils.ActivationInterval

+ FilterIDs []string

+ ID string

+ Sorting string

+ SortingParameters []string

+ Suppliers []*Supplier

+ Tenant string

+ Weight float64

+ func APItoSupplierProfile(tpSPP *utils.TPSupplierProfile, timezone string) (spp *SupplierProfile, err error)

+ func (rp *SupplierProfile) TenantID() string

+ func (sp *SupplierProfile) Compile() error

+ type SupplierProfiles []*SupplierProfile

+ func (lps SupplierProfiles) Sort()

+ type SupplierService struct

+ func NewSupplierService(dm *DataManager, filterS *FilterS, cgrcfg *config.CGRConfig, ...) (spS *SupplierService, err error)

+ func (spS *SupplierService) ListenAndServe(exitChan chan bool) error

+ func (spS *SupplierService) Shutdown() error

+ func (spS *SupplierService) V1GetSupplierProfilesForEvent(args *utils.CGREventWithArgDispatcher, reply *[]*SupplierProfile) (err error)

+ func (spS *SupplierService) V1GetSuppliers(args *ArgsGetSuppliers, reply *SortedSuppliers) (err error)

+ type SupplierSortDispatcher map[string]SuppliersSorter

+ func NewSupplierSortDispatcher(lcrS *SupplierService) (ssd SupplierSortDispatcher, err error)

+ func (ssd SupplierSortDispatcher) SortSuppliers(prflID, strategy string, suppls []*Supplier, suplEv *utils.CGREvent, ...) (sortedSuppls *SortedSuppliers, err error)

+ type SupplierWithParams struct

+ SupplierName string

+ SupplierParams string

+ type SuppliersSorter interface

+ SortSuppliers func(string, []*Supplier, *utils.CGREvent, *optsGetSuppliers) (*SortedSuppliers, error)

+ type SureTaxRequest struct

+ Request string

+ func NewSureTaxRequest(cdr *CDR, stCfg *config.SureTaxCfg) (*SureTaxRequest, error)

+ type SureTaxResponse struct

+ D string

+ type TBLVersion struct

+ ID uint

+ Item string

+ Version int64

+ func (t TBLVersion) TableName() string

+ type TPAttribute struct

+ ActivationInterval string

+ AttributeFilterIDs string

+ Blocker bool

+ Contexts string

+ CreatedAt time.Time

+ FilterIDs string

+ ID string

+ PK uint

+ Path string

+ Tenant string

+ Tpid string

+ Type string

+ Value string

+ Weight float64

+ type TPAttributes []*TPAttribute

+ func APItoModelTPAttribute(th *utils.TPAttributeProfile) (mdls TPAttributes)

+ func (tps TPAttributes) AsTPAttributes() (result []*utils.TPAttributeProfile)

+ type TPCSVImporter struct

+ DirPath string

+ ImportId string

+ Sep rune

+ StorDb LoadWriter

+ TPid string

+ Verbose bool

+ func (self *TPCSVImporter) Run() error

+ type TPCharger struct

+ ActivationInterval string

+ AttributeIDs string

+ CreatedAt time.Time

+ FilterIDs string

+ ID string

+ PK uint

+ RunID string

+ Tenant string

+ Tpid string

+ Weight float64

+ type TPChargers []*TPCharger

+ func APItoModelTPCharger(tpCPP *utils.TPChargerProfile) (mdls TPChargers)

+ func (tps TPChargers) AsTPChargers() (result []*utils.TPChargerProfile)

+ type TPDispatcherHost struct

+ Address string

+ CreatedAt time.Time

+ ID string

+ PK uint

+ TLS bool

+ Tenant string

+ Tpid string

+ Transport string

+ type TPDispatcherHosts []*TPDispatcherHost

+ func APItoModelTPDispatcherHost(tpDPH *utils.TPDispatcherHost) (mdls TPDispatcherHosts)

+ func (tps TPDispatcherHosts) AsTPDispatcherHosts() (result []*utils.TPDispatcherHost)

+ type TPDispatcherProfile struct

+ ActivationInterval string

+ ConnBlocker bool

+ ConnFilterIDs string

+ ConnID string

+ ConnParameters string

+ ConnWeight float64

+ CreatedAt time.Time

+ FilterIDs string

+ ID string

+ PK uint

+ Strategy string

+ StrategyParameters string

+ Subsystems string

+ Tenant string

+ Tpid string

+ Weight float64

+ type TPDispatcherProfiles []*TPDispatcherProfile

+ func APItoModelTPDispatcherProfile(tpDPP *utils.TPDispatcherProfile) (mdls TPDispatcherProfiles)

+ func (tps TPDispatcherProfiles) AsTPDispatcherProfiles() (result []*utils.TPDispatcherProfile)

+ type TPExporter struct

+ func NewTPExporter(storDb LoadStorage, tpID, expPath, fileFormat, sep string, compress bool) (*TPExporter, error)

+ func (self *TPExporter) ExportStats() *utils.ExportedTPStats

+ func (self *TPExporter) GetCacheBuffer() *bytes.Buffer

+ func (self *TPExporter) Run() error

+ type TPLoader struct

+ type TPReader interface

+ Read func() (interface{}, error)

+ type Task struct

+ AccountID string

+ ActionsID string

+ Uuid string

+ func (t *Task) AsNavigableMap(_ []*config.FCTemplate) (nm *config.NavigableMap, err error)

+ func (t *Task) Execute() error

+ func (t *Task) FieldAsInterface(fldPath []string) (iface interface{}, err error)

+ func (t *Task) FieldAsString(fldPath []string) (s string, err error)

+ func (t *Task) RemoteHost() (rh net.Addr)

+ func (t *Task) String() string

+ type TenantRatingSubject struct

+ Subject string

+ Tenant string

+ type Threshold struct

+ Hits int

+ ID string

+ Snooze time.Time

+ Tenant string

+ func (t *Threshold) ProcessEvent(args *ArgsProcessEvent, dm *DataManager) (err error)

+ func (t *Threshold) TenantID() string

+ type ThresholdProfile struct

+ ActionIDs []string

+ ActivationInterval *utils.ActivationInterval

+ Async bool

+ Blocker bool

+ FilterIDs []string

+ ID string

+ MaxHits int

+ MinHits int

+ MinSleep time.Duration

+ Tenant string

+ Weight float64

+ func APItoThresholdProfile(tpTH *utils.TPThresholdProfile, timezone string) (th *ThresholdProfile, err error)

+ func (tp *ThresholdProfile) TenantID() string

+ type ThresholdService struct

+ func NewThresholdService(dm *DataManager, cgrcfg *config.CGRConfig, filterS *FilterS) (tS *ThresholdService, err error)

+ func (tS *ThresholdService) ListenAndServe(exitChan chan bool) error

+ func (tS *ThresholdService) Reload()

+ func (tS *ThresholdService) Shutdown() error

+ func (tS *ThresholdService) StartLoop()

+ func (tS *ThresholdService) StoreThreshold(t *Threshold) (err error)

+ func (tS *ThresholdService) V1GetThreshold(tntID *utils.TenantID, t *Threshold) (err error)

+ func (tS *ThresholdService) V1GetThresholdIDs(tenant string, tIDs *[]string) (err error)

+ func (tS *ThresholdService) V1GetThresholdsForEvent(args *ArgsProcessEvent, reply *Thresholds) (err error)

+ func (tS *ThresholdService) V1ProcessEvent(args *ArgsProcessEvent, reply *[]string) (err error)

+ type ThresholdWithCache struct

+ Cache *string

+ type Thresholds []*Threshold

+ func (ts Thresholds) Sort()

+ type TimeSpan struct

+ CompressFactor int

+ Cost float64

+ DurationIndex time.Duration

+ Increments Increments

+ MatchedDestId string

+ MatchedPrefix string

+ MatchedSubject string

+ RateInterval *RateInterval

+ RatingPlanId string

+ RoundIncrement *Increment

+ TimeEnd time.Time

+ TimeStart time.Time

+ func (ts *TimeSpan) AddIncrement(inc *Increment)

+ func (ts *TimeSpan) CalculateCost() float64

+ func (ts *TimeSpan) Contains(t time.Time) bool

+ func (ts *TimeSpan) Equal(other *TimeSpan) bool

+ func (ts *TimeSpan) GetCompressFactor() int

+ func (ts *TimeSpan) GetDuration() time.Duration

+ func (ts *TimeSpan) GetGroupEnd() time.Duration

+ func (ts *TimeSpan) GetGroupStart() time.Duration

+ func (ts *TimeSpan) GetTimeStartForIncrement(index int) time.Time

+ func (ts *TimeSpan) GetUnitCost() float64

+ func (ts *TimeSpan) GetUnitDuration() time.Duration

+ func (ts *TimeSpan) IsPaid() (bool, int)

+ func (ts *TimeSpan) Merge(other *TimeSpan) bool

+ func (ts *TimeSpan) RoundToDuration(duration time.Duration)

+ func (ts *TimeSpan) SetNewDurationIndex(nts *TimeSpan)

+ func (ts *TimeSpan) SetRateInterval(interval *RateInterval)

+ func (ts *TimeSpan) SharingSignature(other *TimeSpan) bool

+ func (ts *TimeSpan) SplitByDay() (newTs *TimeSpan)

+ func (ts *TimeSpan) SplitByDuration(duration time.Duration) *TimeSpan

+ func (ts *TimeSpan) SplitByIncrement(index int) *TimeSpan

+ func (ts *TimeSpan) SplitByRateInterval(i *RateInterval, data bool) (nts *TimeSpan)

+ func (ts *TimeSpan) SplitByRatingPlan(rp *RatingInfo) (newTs *TimeSpan)

+ type TimeSpans []*TimeSpan

+ func (timespans *TimeSpans) OverlapWithTimeSpans(paidTs TimeSpans, newTs *TimeSpan, index int) bool

+ func (timespans *TimeSpans) RemoveOverlapedFromIndex(index int)

+ func (tss *TimeSpans) Compress()

+ func (tss *TimeSpans) Decompress()

+ func (tss *TimeSpans) Merge()

+ type TpAccountAction struct

+ Account string

+ ActionPlanTag string

+ ActionTriggersTag string

+ AllowNegative bool

+ CreatedAt time.Time

+ Disabled bool

+ Id int64

+ Loadid string

+ Tenant string

+ Tpid string

+ func APItoModelAccountAction(aa *utils.TPAccountActions) *TpAccountAction

+ func (aa *TpAccountAction) GetAccountActionId() string

+ func (aa *TpAccountAction) SetAccountActionId(id string) error

+ type TpAccountActions []TpAccountAction

+ func APItoModelAccountActions(aas []*utils.TPAccountActions) (result TpAccountActions)

+ func (tps TpAccountActions) AsMapTPAccountActions() (map[string]*utils.TPAccountActions, error)

+ func (tps TpAccountActions) AsTPAccountActions() (result []*utils.TPAccountActions, err error)

+ type TpAction struct

+ Action string

+ BalanceBlocker string

+ BalanceDisabled string

+ BalanceTag string

+ BalanceType string

+ BalanceWeight string

+ Categories string

+ CreatedAt time.Time

+ DestinationTags string

+ ExpiryTime string

+ ExtraParameters string

+ Filter string

+ Id int64

+ RatingSubject string

+ SharedGroups string

+ Tag string

+ TimingTags string

+ Tpid string

+ Units string

+ Weight float64

+ type TpActionPlan struct

+ ActionsTag string

+ CreatedAt time.Time

+ Id int64

+ Tag string

+ TimingTag string

+ Tpid string

+ Weight float64

+ type TpActionPlans []TpActionPlan

+ func APItoModelActionPlan(a *utils.TPActionPlan) (result TpActionPlans)

+ func APItoModelActionPlans(aps []*utils.TPActionPlan) (result TpActionPlans)

+ func (tps TpActionPlans) AsMapTPActionPlans() (map[string]*utils.TPActionPlan, error)

+ func (tps TpActionPlans) AsTPActionPlans() (result []*utils.TPActionPlan, err error)

+ type TpActionTrigger struct

+ ActionsTag string

+ ActivationTime string

+ BalanceBlocker string

+ BalanceCategories string

+ BalanceDestinationTags string

+ BalanceDisabled string

+ BalanceExpiryTime string

+ BalanceRatingSubject string

+ BalanceSharedGroups string

+ BalanceTag string

+ BalanceTimingTags string

+ BalanceType string

+ BalanceWeight string

+ CreatedAt time.Time

+ ExpiryTime string

+ Id int64

+ MinSleep string

+ Recurrent bool

+ Tag string

+ ThresholdType string

+ ThresholdValue float64

+ Tpid string

+ UniqueId string

+ Weight float64

+ type TpActionTriggers []TpActionTrigger

+ func APItoModelActionTrigger(ats *utils.TPActionTriggers) (result TpActionTriggers)

+ func APItoModelActionTriggers(ts []*utils.TPActionTriggers) (result TpActionTriggers)

+ func (tps TpActionTriggers) AsMapTPActionTriggers() (map[string]*utils.TPActionTriggers, error)

+ func (tps TpActionTriggers) AsTPActionTriggers() (result []*utils.TPActionTriggers, err error)

+ type TpActions []TpAction

+ func APItoModelAction(as *utils.TPActions) (result TpActions)

+ func APItoModelActions(as []*utils.TPActions) (result TpActions)

+ func (tps TpActions) AsMapTPActions() (map[string]*utils.TPActions, error)

+ func (tps TpActions) AsTPActions() (result []*utils.TPActions, err error)

+ type TpDestination struct

+ CreatedAt time.Time

+ Id int64

+ Prefix string

+ Tag string

+ Tpid string

+ type TpDestinationRate struct

+ CreatedAt time.Time

+ DestinationsTag string

+ Id int64

+ MaxCost float64

+ MaxCostStrategy string

+ RatesTag string

+ RoundingDecimals int

+ RoundingMethod string

+ Tag string

+ Tpid string

+ type TpDestinationRates []TpDestinationRate

+ func APItoModelDestinationRate(d *utils.TPDestinationRate) (result TpDestinationRates)

+ func APItoModelDestinationRates(drs []*utils.TPDestinationRate) (result TpDestinationRates)

+ func (tps TpDestinationRates) AsMapDestinationRates() (map[string]*utils.TPDestinationRate, error)

+ func (tps TpDestinationRates) AsTPDestinationRates() (result []*utils.TPDestinationRate, err error)

+ type TpDestinations []TpDestination

+ func APItoModelDestination(d *utils.TPDestination) (result TpDestinations)

+ func (tps TpDestinations) AsMapDestinations() (map[string]*Destination, error)

+ func (tps TpDestinations) AsTPDestinations() (result []*utils.TPDestination)

+ type TpFilter struct

+ ActivationInterval string

+ CreatedAt time.Time

+ Element string

+ ID string

+ PK uint

+ Tenant string

+ Tpid string

+ Type string

+ Values string

+ type TpFilterS []*TpFilter

+ func APItoModelTPFilter(th *utils.TPFilterProfile) (mdls TpFilterS)

+ func (tps TpFilterS) AsTPFilter() (result []*utils.TPFilterProfile)

+ type TpRate struct

+ ConnectFee float64

+ CreatedAt time.Time

+ GroupIntervalStart string

+ Id int64

+ Rate float64

+ RateIncrement string

+ RateUnit string

+ Tag string

+ Tpid string

+ type TpRates []TpRate

+ func APItoModelRate(r *utils.TPRate) (result TpRates)

+ func APItoModelRates(rs []*utils.TPRate) (result TpRates)

+ func (tps TpRates) AsMapRates() (map[string]*utils.TPRate, error)

+ func (tps TpRates) AsTPRates() (result []*utils.TPRate, err error)

+ type TpRatingPlan struct

+ CreatedAt time.Time

+ DestratesTag string

+ Id int64

+ Tag string

+ TimingTag string

+ Tpid string

+ Weight float64

+ type TpRatingPlans []TpRatingPlan

+ func APItoModelRatingPlan(rp *utils.TPRatingPlan) (result TpRatingPlans)

+ func APItoModelRatingPlans(rps []*utils.TPRatingPlan) (result TpRatingPlans)

+ func (tps TpRatingPlans) AsMapTPRatingPlans() (map[string]*utils.TPRatingPlan, error)

+ func (tps TpRatingPlans) AsTPRatingPlans() (result []*utils.TPRatingPlan, err error)

+ type TpRatingProfile struct

+ ActivationTime string

+ Category string

+ CreatedAt time.Time

+ FallbackSubjects string

+ Id int64

+ Loadid string

+ RatingPlanTag string

+ Subject string

+ Tenant string

+ Tpid string

+ func (rpf *TpRatingProfile) GetRatingProfileId() string

+ func (rpf *TpRatingProfile) SetRatingProfileId(id string) error

+ type TpRatingProfiles []TpRatingProfile

+ func APItoModelRatingProfile(rp *utils.TPRatingProfile) (result TpRatingProfiles)

+ func APItoModelRatingProfiles(rps []*utils.TPRatingProfile) (result TpRatingProfiles)

+ func (tps TpRatingProfiles) AsMapTPRatingProfiles() (map[string]*utils.TPRatingProfile, error)

+ func (tps TpRatingProfiles) AsTPRatingProfiles() (result []*utils.TPRatingProfile, err error)

+ type TpReader struct

+ func NewTpReader(db DataDB, lr LoadReader, tpid, timezone string, ...) (*TpReader, error)

+ func (tpr *TpReader) GetLoadedIds(categ string) ([]string, error)

+ func (tpr *TpReader) Init()

+ func (tpr *TpReader) IsValid() bool

+ func (tpr *TpReader) LoadAccountActions() (err error)

+ func (tpr *TpReader) LoadAccountActionsFiltered(qriedAA *utils.TPAccountActions) error

+ func (tpr *TpReader) LoadActionPlans() (err error)

+ func (tpr *TpReader) LoadActionTriggers() (err error)

+ func (tpr *TpReader) LoadActions() (err error)

+ func (tpr *TpReader) LoadAll() (err error)

+ func (tpr *TpReader) LoadAttributeProfiles() error

+ func (tpr *TpReader) LoadAttributeProfilesFiltered(tag string) (err error)

+ func (tpr *TpReader) LoadChargerProfiles() error

+ func (tpr *TpReader) LoadChargerProfilesFiltered(tag string) (err error)

+ func (tpr *TpReader) LoadDestinationRates() (err error)

+ func (tpr *TpReader) LoadDestinations() (err error)

+ func (tpr *TpReader) LoadDestinationsFiltered(tag string) (bool, error)

+ func (tpr *TpReader) LoadDispatcherHosts() error

+ func (tpr *TpReader) LoadDispatcherHostsFiltered(tag string) (err error)

+ func (tpr *TpReader) LoadDispatcherProfiles() error

+ func (tpr *TpReader) LoadDispatcherProfilesFiltered(tag string) (err error)

+ func (tpr *TpReader) LoadFilters() error

+ func (tpr *TpReader) LoadFiltersFiltered(tag string) error

+ func (tpr *TpReader) LoadRates() (err error)

+ func (tpr *TpReader) LoadRatingPlans() (err error)

+ func (tpr *TpReader) LoadRatingPlansFiltered(tag string) (bool, error)

+ func (tpr *TpReader) LoadRatingProfiles() (err error)

+ func (tpr *TpReader) LoadRatingProfilesFiltered(qriedRpf *utils.TPRatingProfile) error

+ func (tpr *TpReader) LoadResourceProfiles() error

+ func (tpr *TpReader) LoadResourceProfilesFiltered(tag string) (err error)

+ func (tpr *TpReader) LoadSharedGroups() error

+ func (tpr *TpReader) LoadSharedGroupsFiltered(tag string, save bool) (err error)

+ func (tpr *TpReader) LoadStats() error

+ func (tpr *TpReader) LoadStatsFiltered(tag string) (err error)

+ func (tpr *TpReader) LoadSupplierProfiles() error

+ func (tpr *TpReader) LoadSupplierProfilesFiltered(tag string) (err error)

+ func (tpr *TpReader) LoadThresholds() error

+ func (tpr *TpReader) LoadThresholdsFiltered(tag string) (err error)

+ func (tpr *TpReader) LoadTimings() (err error)

+ func (tpr *TpReader) ReloadCache(caching string, verbose bool, argDispatcher *utils.ArgDispatcher) (err error)

+ func (tpr *TpReader) ReloadScheduler(verbose bool) (err error)

+ func (tpr *TpReader) RemoveFromDatabase(verbose, disable_reverse bool) (err error)

+ func (tpr *TpReader) ShowStatistics()

+ func (tpr *TpReader) WriteToDatabase(verbose, disable_reverse bool) (err error)

+ type TpResource struct

+ ActivationInterval string

+ AllocationMessage string

+ Blocker bool

+ CreatedAt time.Time

+ FilterIDs string

+ ID string

+ Limit string

+ PK uint

+ Stored bool

+ Tenant string

+ ThresholdIDs string

+ Tpid string

+ UsageTTL string

+ Weight float64

+ type TpResources []*TpResource

+ func APItoModelResource(rl *utils.TPResourceProfile) (mdls TpResources)

+ func (tps TpResources) AsTPResources() (result []*utils.TPResourceProfile)

+ type TpSharedGroup struct

+ Account string

+ CreatedAt time.Time

+ Id int64

+ RatingSubject string

+ Strategy string

+ Tag string

+ Tpid string

+ type TpSharedGroups []TpSharedGroup

+ func APItoModelSharedGroup(sgs *utils.TPSharedGroups) (result TpSharedGroups)

+ func APItoModelSharedGroups(sgs []*utils.TPSharedGroups) (result TpSharedGroups)

+ func (tps TpSharedGroups) AsMapTPSharedGroups() (map[string]*utils.TPSharedGroups, error)

+ func (tps TpSharedGroups) AsTPSharedGroups() (result []*utils.TPSharedGroups, err error)

+ type TpStat struct

+ ActivationInterval string

+ Blocker bool

+ CreatedAt time.Time

+ FilterIDs string

+ ID string

+ MetricFilterIDs string

+ MetricIDs string

+ MinItems int

+ PK uint

+ QueueLength int

+ Stored bool

+ TTL string

+ Tenant string

+ ThresholdIDs string

+ Tpid string

+ Weight float64

+ type TpStats []*TpStat

+ func APItoModelStats(st *utils.TPStatProfile) (mdls TpStats)

+ func (models TpStats) AsTPStats() (result []*utils.TPStatProfile)

+ type TpSupplier struct

+ ActivationInterval string

+ CreatedAt time.Time

+ FilterIDs string

+ ID string

+ PK uint

+ Sorting string

+ SortingParameters string

+ SupplierAccountIDs string

+ SupplierBlocker bool

+ SupplierFilterIDs string

+ SupplierID string

+ SupplierParameters string

+ SupplierRatingplanIDs string

+ SupplierResourceIDs string

+ SupplierStatIDs string

+ SupplierWeight float64

+ Tenant string

+ Tpid string

+ Weight float64

+ type TpSuppliers []*TpSupplier

+ func APItoModelTPSuppliers(st *utils.TPSupplierProfile) (mdls TpSuppliers)

+ func (tps TpSuppliers) AsTPSuppliers() (result []*utils.TPSupplierProfile)

+ type TpThreshold struct

+ ActionIDs string

+ ActivationInterval string

+ Async bool

+ Blocker bool

+ CreatedAt time.Time

+ FilterIDs string

+ ID string

+ MaxHits int

+ MinHits int

+ MinSleep string

+ PK uint

+ Tenant string

+ Tpid string

+ Weight float64

+ type TpThresholds []*TpThreshold

+ func APItoModelTPThreshold(th *utils.TPThresholdProfile) (mdls TpThresholds)

+ func (tps TpThresholds) AsTPThreshold() (result []*utils.TPThresholdProfile)

+ type TpTiming struct

+ CreatedAt time.Time

+ Id int64

+ MonthDays string

+ Months string

+ Tag string

+ Time string

+ Tpid string

+ WeekDays string

+ Years string

+ func APItoModelTiming(t *utils.ApierTPTiming) (result TpTiming)

+ type TpTimings []TpTiming

+ func APItoModelTimings(ts []*utils.ApierTPTiming) (result TpTimings)

+ func (tps TpTimings) AsMapTPTimings() (map[string]*utils.ApierTPTiming, error)

+ func (tps TpTimings) AsTPTimings() (result []*utils.ApierTPTiming)

+ type UnitCounter struct

+ CounterType string

+ Counters CounterFilters

+ func (uc *UnitCounter) Clone() (newUnit *UnitCounter)

+ func (uc *UnitCounter) CopyCounterValues(oldUc *UnitCounter) bool

+ type UnitCounters map[string][]*UnitCounter

+ func (ucs UnitCounters) Clone() UnitCounters

+ type UnitInfo struct

+ Consumed float64

+ DestinationID string

+ ID string

+ RateInterval *RateInterval

+ ToR string

+ UUID string

+ Value float64

+ func (ui *UnitInfo) Clone() *UnitInfo

+ func (ui *UnitInfo) Equal(other *UnitInfo) bool

+ type UsageRecord struct

+ Account string

+ AnswerTime string

+ Category string

+ Destination string

+ ExtraFields map[string]string

+ RequestType string

+ SetupTime string

+ Subject string

+ Tenant string

+ ToR string

+ Usage string

+ func (self *UsageRecord) AsCDR(timezone string) (*CDR, error)

+ func (self *UsageRecord) AsCallDescriptor(timezone string, denyNegative bool) (*CallDescriptor, error)

+ func (self *UsageRecord) GetId() string

+ type UsageRecordWithArgDispatcher struct

+ type V2SMCost struct

+ CGRID string

+ CostDetails *EventCost

+ CostSource string

+ OriginHost string

+ OriginID string

+ RunID string

+ Usage time.Duration

+ type ValueFactor map[string]float64

+ func (f ValueFactor) GetValue(tor string) float64

+ type Versions map[string]int64

+ func CurrentAllDBVersions() Versions

+ func CurrentDBVersions(storType string, isDataDB bool) Versions

+ func CurrentDataDBVersions() Versions

+ func CurrentStorDBVersions() Versions

+ func (vers Versions) Compare(curent Versions, storType string, isDataDB bool) string

+ type WeightSorter struct

+ func NewWeightSorter(spS *SupplierService) *WeightSorter

+ func (ws *WeightSorter) SortSuppliers(prflID string, suppls []*Supplier, suplEv *utils.CGREvent, ...) (sortedSuppls *SortedSuppliers, err error)

v0.9.1-rc3

Jan 15, 2014

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