Influxdata
/
influxdb
mirror of https://github.com/influxdata/influxdb.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Change writeSeriesData() interface.

pull/1134/head
Ben Johnson 2014-11-18 08:03:26 -07:00
parent 8c4bcfafb6
commit 4858f58877
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
database.go
View File

@ -318,7 +318,7 @@ func (db *Database) applyCreateShardIfNotExists(id uint64, space string, timesta
} }
// WriteSeries writes series data to the database. // WriteSeries writes series data to the database.
func (db *Database) WriteSeries(name string, tags map[string]string, values map[string]interface{}) error { func (db *Database) WriteSeries(name string, tags map[string]string, timestamp time.Time, values map[string]interface{}) error {
panic("not yet implemented: Database.WriteSeries()") panic("not yet implemented: Database.WriteSeries()")
/* TEMPORARILY REMOVED FOR PROTOBUFS. /* TEMPORARILY REMOVED FOR PROTOBUFS.
@ -388,7 +388,7 @@ func (db *Database) WriteSeries(name string, tags map[string]string, values map[
} }
/* TEMPORARILY REMOVED FOR PROTOBUFS. /* TEMPORARILY REMOVED FOR PROTOBUFS.
func (db *Database) applyWriteSeries(s *protocol.Series) error { func (db *Database) applyWriteSeries(id uint64, t int64, values map[uint8]interface{}) error {
db.mu.Lock() db.mu.Lock()
defer db.mu.Unlock() defer db.mu.Unlock()
shard := db.shard(s.GetShardId()) shard := db.shard(s.GetShardId())

2
server.go
View File

@ -623,7 +623,7 @@ func (s *Server) applyWriteSeries(m *messaging.Message) error {
return ErrDatabaseNotFound return ErrDatabaseNotFound
} }
if err := db.applyWriteSeries(req.GetSeries()); err != nil { if err := db.applyWriteSeries(id, t, values); err != nil {
return err return err
} }