diff --git a/config/config_defaults.go b/config/config_defaults.go index 08343ad2f..eecd9c80a 100755 --- a/config/config_defaults.go +++ b/config/config_defaults.go @@ -659,11 +659,11 @@ const CGRATES_CFG_JSON = ` "dispatcher":{ "enabled": false, // starts DispatcherS service: . "rals_conns": [], // address where to reach the RALs for dispatcherS <*internal> - "resources_conns": [], // address where to reach the ResourceS <""|*internal|127.0.0.1:2013> - "thresholds_conns": [], // address where to reach the ThresholdS <""|*internal|127.0.0.1:2013> - "stats_conns": [], // address where to reach the StatS <""|*internal|127.0.0.1:2013> - "suppliers_conns": [], // address where to reach the SupplierS <""|*internal|127.0.0.1:2013> - "attributes_conns": [], // address where to reach the AttributeS <""|*internal|127.0.0.1:2013> + "resources_conns": [], // address where to reach the ResourceS <""|127.0.0.1:2013> + "thresholds_conns": [], // address where to reach the ThresholdS <""|127.0.0.1:2013> + "stats_conns": [], // address where to reach the StatS <""|127.0.0.1:2013> + "suppliers_conns": [], // address where to reach the SupplierS <""|127.0.0.1:2013> + "attributes_conns": [], // address where to reach the AttributeS <""|127.0.0.1:2013> "sessions_conns": [], // connection towards SessionService "dispatching_strategy":"*first", // strategy for dispatching <*first|*random|*next|*broadcast> }, diff --git a/engine/storage_map.go b/engine/storage_map_datadb.go similarity index 100% rename from engine/storage_map.go rename to engine/storage_map_datadb.go diff --git a/engine/storage_map_stordb.go b/engine/storage_map_stordb.go new file mode 100755 index 000000000..40cb2f164 --- /dev/null +++ b/engine/storage_map_stordb.go @@ -0,0 +1,183 @@ +/* +Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments +Copyright (C) ITsysCOM GmbH + +This program is free software: you can redistribute it and/or modify +it under the terms of the GNU General Public License as published by +the Free Software Foundation, either version 3 of the License, or +(at your option) any later version. + +This program is distributed in the hope that it will be useful, +but WITHOUT ANY WARRANTY; without even the implied warranty of +MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +GNU General Public License for more details. + +You should have received a copy of the GNU General Public License +along with this program. If not, see +*/ + +package engine + +import ( + "github.com/cgrates/cgrates/utils" +) + +//implement LoadReader interface +func (ms *MapStorage) GetTpIds(colName string) (ids []string, err error) { + return +} +func (ms *MapStorage) GetTpTableIds(tpid, table string, distinct utils.TPDistinctIds, + filters map[string]string, paginator *utils.Paginator) (ids []string, err error) { + return +} +func (ms *MapStorage) GetTPTimings(tpid, id string) (timings []*utils.ApierTPTiming, err error) { + return +} +func (ms *MapStorage) GetTPDestinations(tpid, id string) (dsts []*utils.TPDestination, err error) { + return +} +func (ms *MapStorage) GetTPRates(tpid, id string) (rates []*utils.TPRate, err error) { + return +} +func (ms *MapStorage) GetTPDestinationRates(tpid, id string, + paginator *utils.Paginator) (dRates []*utils.TPDestinationRate, err error) { + return +} +func (ms *MapStorage) GetTPRatingPlans(string, string, *utils.Paginator) (rPlans []*utils.TPRatingPlan, err error) { + return +} +func (ms *MapStorage) GetTPRatingProfiles(filter *utils.TPRatingProfile) (rProfiles []*utils.TPRatingProfile, err error) { + return +} +func (ms *MapStorage) GetTPSharedGroups(tpid, id string) (sGroups []*utils.TPSharedGroups, err error) { + return +} +func (ms *MapStorage) GetTPCdrStats(tpid, id string) (stats []*utils.TPCdrStats, err error) { + return +} +func (ms *MapStorage) GetTPLCRs(filter *utils.TPLcrRules) (lcrs []*utils.TPLcrRules, err error) { + return +} +func (ms *MapStorage) GetTPUsers(filter *utils.TPUsers) (users []*utils.TPUsers, err error) { + return +} +func (ms *MapStorage) GetTPAliases(filter *utils.TPAliases) (aliases []*utils.TPAliases, err error) { + return +} +func (ms *MapStorage) GetTPDerivedChargers(*utils.TPDerivedChargers) (dCharges []*utils.TPDerivedChargers, err error) { + return +} +func (ms *MapStorage) GetTPActions(tpid, id string) (actions []*utils.TPActions, err error) { + return +} +func (ms *MapStorage) GetTPActionPlans(tpid, id string) (aPlans []*utils.TPActionPlan, err error) { + return +} +func (ms *MapStorage) GetTPActionTriggers(tpid, id string) (aTriggers []*utils.TPActionTriggers, err error) { + return +} +func (ms *MapStorage) GetTPAccountActions(filter *utils.TPAccountActions) (accounts []*utils.TPAccountActions, err error) { + return +} +func (ms *MapStorage) GetTPResources(tpid, id string) (resources []*utils.TPResource, err error) { + return +} +func (ms *MapStorage) GetTPStats(tpid, id string) (stats []*utils.TPStats, err error) { + return +} +func (ms *MapStorage) GetTPThresholds(tpid, id string) (ths []*utils.TPThreshold, err error) { + return +} +func (ms *MapStorage) GetTPFilters(tpid, id string) (fltrs []*utils.TPFilterProfile, err error) { + return +} +func (ms *MapStorage) GetTPSuppliers(tpid, id string) (supps []*utils.TPSupplierProfile, err error) { + return +} +func (ms *MapStorage) GetTPAttributes(tpid, id string) (attrs []*utils.TPAttributeProfile, err error) { + return +} + +//implement LoadWriter interface +func (ms *MapStorage) RemTpData(table, tpid string, args map[string]string) (err error) { + return +} +func (ms *MapStorage) SetTPTimings(timings []*utils.ApierTPTiming) (err error) { + return +} +func (ms *MapStorage) SetTPDestinations(dests []*utils.TPDestination) (err error) { + return +} +func (ms *MapStorage) SetTPRates(rates []*utils.TPRate) (err error) { + return +} +func (ms *MapStorage) SetTPDestinationRates(dRates []*utils.TPDestinationRate) (err error) { + return +} +func (ms *MapStorage) SetTPRatingPlans(ratingPlans []*utils.TPRatingPlan) (err error) { + return +} +func (ms *MapStorage) SetTPRatingProfiles(ratingProfiles []*utils.TPRatingProfile) (err error) { + return +} +func (ms *MapStorage) SetTPSharedGroups(groups []*utils.TPSharedGroups) (err error) { + return +} +func (ms *MapStorage) SetTPCdrStats(cdrStats []*utils.TPCdrStats) (err error) { + return +} +func (ms *MapStorage) SetTPUsers(users []*utils.TPUsers) (err error) { + return +} +func (ms *MapStorage) SetTPAliases(aliases []*utils.TPAliases) (err error) { + return +} +func (ms *MapStorage) SetTPDerivedChargers(dc []*utils.TPDerivedChargers) (err error) { + return +} +func (ms *MapStorage) SetTPLCRs(lcrs []*utils.TPLcrRules) (err error) { + return +} +func (ms *MapStorage) SetTPActions(acts []*utils.TPActions) (err error) { + return +} +func (ms *MapStorage) SetTPActionPlans(aPlans []*utils.TPActionPlan) (err error) { + return +} +func (ms *MapStorage) SetTPActionTriggers(aTriggers []*utils.TPActionTriggers) (err error) { + return +} +func (ms *MapStorage) SetTPAccountActions(accActions []*utils.TPAccountActions) (err error) { + return +} +func (ms *MapStorage) SetTPResources(resources []*utils.TPResource) (err error) { + return +} +func (ms *MapStorage) SetTPStats(stats []*utils.TPStats) (err error) { + return +} + +func (ms *MapStorage) SetTPThresholds(thresholds []*utils.TPThreshold) (err error) { + return +} + +func (ms *MapStorage) SetTPFilters(filters []*utils.TPFilterProfile) (err error) { + return +} +func (ms *MapStorage) SetTPSuppliers(suppliers []*utils.TPSupplierProfile) (err error) { + return +} +func (ms *MapStorage) SetTPAttributes(attributes []*utils.TPAttributeProfile) (err error) { + return +} + +//implement CdrStorage interface +func (ms *MapStorage) SetCDR(cdr *CDR, allowUpdate bool) (err error) { + return +} +func (ms *MapStorage) RemoveSMCost(smc *SMCost) (err error) { + return +} +func (ms *MapStorage) GetCDRs(filter *utils.CDRsFilter, remove bool) (cdrs []*CDR, count int64, err error) { + return +}