velodrome/transform/influx.go
func (i *InfluxDB) PushBatchPoints() error {
	// Push
	err := i.client.Write(i.batch)
	if err != nil {
		return err
	}
	glog.Infof("Sent to influx: %d points", i.batchSize)

	// Recreate new batch
	i.batch, err = influxdb.NewBatchPoints(influxdb.BatchPointsConfig{
		Database:  i.database,
		Precision: "s",
	})
	i.batchSize = 0

	if err != nil {
		return err
	}

	return nil
}
func (i *InfluxDB) PushBatchPoints() error {
	// Push
	err := i.client.Write(i.batch)
	if err != nil {
		return err
	}
	glog.Infof("Sent to influx: %d points", i.batchSize)

	// Recreate new batch
	i.batch, err = influxdb.NewBatchPoints(influxdb.BatchPointsConfig{
		Database:  i.database,
		Precision: "s",
	})
	i.batchSize = 0

	if err != nil {
		return err
	}

	return nil
}
func ( i * InfluxDB ) PushBatchPoints ( ) error { // Push err := i . client . Write ( i . batch ) if err != nil { return err } glog . Infof ( " " , i . batchSize ) // Recreate new batch i . batch , err = influxdb . NewBatchPoints ( influxdb . BatchPointsConfig { Database : i . database , Precision : " " , } ) i . batchSize = 0 if err != nil { return err } return nil }
// PushBatchPoints pushes the batch points (for real)
PushBatchPoints pushes the batch points ( for real )