velodrome/transform/influx.go
func (i *InfluxDB) Push(tags map[string]string, fields map[string]interface{}, date time.Time) error {
	pt, err := influxdb.NewPoint(i.measurement, mergeTags(i.tags, tags), fields, date)
	if err != nil {
		return err
	}

	i.batch.AddPoint(pt)
	i.batchSize++

	return nil
}
func (i *InfluxDB) Push(tags map[string]string, fields map[string]interface{}, date time.Time) error {
	pt, err := influxdb.NewPoint(i.measurement, mergeTags(i.tags, tags), fields, date)
	if err != nil {
		return err
	}

	i.batch.AddPoint(pt)
	i.batchSize++

	return nil
}
// Push a point to the database. This appends to current batchpoint