mirror of
https://github.com/cgrates/cgrates.git
synced 2026-02-11 18:16:24 +05:00
Add methods name for MapStorage as StorDb
This commit is contained in:
TeoV
committed by
Dan Christian Bogos
Dan Christian Bogos
parent
aa73538ff8
commit
3c8df467c4
@@ -659,11 +659,11 @@ const CGRATES_CFG_JSON = `
|
||||
"dispatcher":{
|
||||
"enabled": false, // starts DispatcherS service: <true|false>.
|
||||
"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>
|
||||
},
|
||||
|
||||
183
engine/storage_map_stordb.go
Executable file
183
engine/storage_map_stordb.go
Executable file
@@ -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 <http://www.gnu.org/licenses/>
|
||||
*/
|
||||
|
||||
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
|
||||
}
|
||||
Reference in New Issue
Block a user