From d18814267ea6cc70f24571b58dc116afe0431a3f Mon Sep 17 00:00:00 2001 From: Jeff Wendling Date: Wed, 26 Sep 2018 23:00:41 -0600 Subject: [PATCH] Add very basic write support --- cmd/influxd/main.go | 4 ++++ tsdb/shard.go | 5 +++++ 2 files changed, 9 insertions(+) diff --git a/cmd/influxd/main.go b/cmd/influxd/main.go index e8b94df69d..c56c815ba2 100644 --- a/cmd/influxd/main.go +++ b/cmd/influxd/main.go @@ -36,6 +36,10 @@ import ( "github.com/influxdata/platform/tsdb" _ "github.com/influxdata/platform/tsdb/index/tsi1" _ "github.com/influxdata/platform/tsdb/tsm1" +<<<<<<< HEAD +======= + pzap "github.com/influxdata/platform/zap" +>>>>>>> Add very basic write support "github.com/prometheus/client_golang/prometheus" "github.com/spf13/cobra" "github.com/spf13/viper" diff --git a/tsdb/shard.go b/tsdb/shard.go index 89995adf13..4cc338779d 100644 --- a/tsdb/shard.go +++ b/tsdb/shard.go @@ -225,6 +225,11 @@ func (s *Shard) Index() (Index, error) { // WritePoints will write the raw data points and any new metadata to the index in the shard. func (s *Shard) WritePoints(points []models.Point) error { + points, err := explodePoints([]byte("insert-org-bucket"), points) + if err != nil { + return err + } + collection := NewSeriesCollection(points) j := 0