monitoring : Fix for cluster statistics push to db

When bigfin attempts to call skyring's module, since
the call is in context of bigfin, the configuration used
is also in the context of bigfin. So, it becomes necessary to
pass the required configuration values from bigfin.This
patch alters the framework to accept the values of required
configurations from the provider along with the values to
push to db.

Change-Id: I4d373f451fe619aae4e22f4a2306f0b42c7739a3
Signed-off-by: anmolbabu <[email protected]>

Author: anmolbabu

monitoring/graphitemanager/graphite_manager.go

@@ -199,7 +199,7 @@ func (tsdbm GraphiteManager) QueryDB(params map[string]interface{}) (interface{}
 }
 
 //This method takes map[string]map[string]string ==> map[metric/table name]map[timestamp]value
-func (tsdbm GraphiteManager) PushToDb(metrics map[string]map[string]string) error {
+func (tsdbm GraphiteManager) PushToDb(metrics map[string]map[string]string, hostName string, port int) error {
 	data := make([]graphite.Metric, 1)
 	for tableName, valueMap := range metrics {
 		for timestamp, value := range valueMap {
@@ -210,7 +210,7 @@ func (tsdbm GraphiteManager) PushToDb(metrics map[string]map[string]string) erro
 			data = append(data, graphite.Metric{Name: tableName, Value: value, Timestamp: timeInt})
 		}
 	}
-	Graphite, err := graphite.NewGraphite(conf.SystemConfig.TimeSeriesDBConfig.Hostname, conf.SystemConfig.TimeSeriesDBConfig.DataPushPort)
+	Graphite, err := graphite.NewGraphite(hostName, port)
 	if err != nil {
 		return fmt.Errorf("%v", err)
 	}

monitoring/influxdbmanager/influxdb_manager.go

@@ -96,7 +96,7 @@ func (idm InfluxdbManager) QueryDB(params map[string]interface{}) (interface{},
 	return res, err
 }
 
-func (idm InfluxdbManager) PushToDb(metrics map[string]map[string]string) error {
+func (idm InfluxdbManager) PushToDb(metrics map[string]map[string]string, hostName string, port int) error {
 	/*
 		TODO Implement
 	*/

monitoring/interfaces.go

@@ -2,5 +2,5 @@ package monitoring
 
 type MonitoringManagerInterface interface {
 	QueryDB(params map[string]interface{}) (interface{}, error)
-	PushToDb(metrics map[string]map[string]string) error
+	PushToDb(metrics map[string]map[string]string, hostName string, port int) error
 }