Add very basic write support
parent
d8f55446fd
commit
d18814267e
|
@ -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"
|
||||
|
|
|
@ -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
|
||||
|
|
Loading…
Reference in New Issue