~gabe/mortar unlisted

af9087e5a606ec0d1cd405906140389a125e972d — Gabe Fierro 1 year, 7 months ago a1cbf5d
switch default back to btrdb frontend
1 files changed, 15 insertions(+), 15 deletions(-)

M main.go
M main.go => main.go +15 -15
@@ 80,28 80,28 @@ func main() {
	}
	brickready = true

	//ts_stage_cfg := &stages.TimeseriesStageConfig{
	//	Upstream:     md_stage,
	//	StageContext: maincontext,
	//	BTrDBAddress: cfg.BTrDBAddr,
	//}
	//ts_stage, err := stages.NewTimeseriesQueryStage(ts_stage_cfg)
	//if err != nil {
	//	log.Fatal(err)
	//}

	ts_stage_cfg := &stages.InfluxDBTimeseriesStageConfig{
	ts_stage_cfg := &stages.TimeseriesStageConfig{
		Upstream:     md_stage,
		StageContext: maincontext,
		Address:      cfg.InfluxDBAddr,
		Username:     cfg.InfluxDBUser,
		Password:     cfg.InfluxDBPass,
		BTrDBAddress: cfg.BTrDBAddr,
	}
	ts_stage, err := stages.NewInfluxDBTimeseriesQueryStage(ts_stage_cfg)
	ts_stage, err := stages.NewTimeseriesQueryStage(ts_stage_cfg)
	if err != nil {
		log.Fatal(err)
	}

	//	ts_stage_cfg := &stages.InfluxDBTimeseriesStageConfig{
	//		Upstream:     md_stage,
	//		StageContext: maincontext,
	//		Address:      cfg.InfluxDBAddr,
	//		Username:     cfg.InfluxDBUser,
	//		Password:     cfg.InfluxDBPass,
	//	}
	//	ts_stage, err := stages.NewInfluxDBTimeseriesQueryStage(ts_stage_cfg)
	//	if err != nil {
	//		log.Fatal(err)
	//	}

	//_ = ts_stage

	var end stages.Stage = ts_stage