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

Some initial work

pull/1302/head
Philip O'Toole 2015-01-08 16:40:23 -08:00 committed by Philip O'Toole
parent 1d68cf8581
commit 50aa4d3a6a
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
handler.go
View File

@ -195,12 +195,12 @@ func (h *Handler) serveQuery(w http.ResponseWriter, r *http.Request, u *User) {
rp := NewRetentionPolicy(c.Name)
rp.Duration = c.Duration
rp.ReplicaN = uint32(c.Replication)
err = h.server.CreateRetentionPolicy(c.DB, rp)
err = h.server.CreateRetentionPolicy(c.Database, rp)
case *influxql.AlterRetentionPolicyStatement:
rp := NewRetentionPolicy(c.Name)
rp.Duration = *c.Duration // Why is this a pointer, and the next?
rp.ReplicaN = uint32(*c.Replication)
err = h.server.UpdateRetentionPolicy(c.DB, c.Name, rp)
err = h.server.UpdateRetentionPolicy(c.Database, c.Name, rp)
case *influxql.CreateContinuousQueryStatement:
continue
@ -277,7 +277,6 @@ func (h *Handler) serveMetastore(w http.ResponseWriter, r *http.Request, u *User
w.Header().Set("Content-Type", "application/octet-stream")
w.Header().Set("Content-Disposition", `attachment; filename="meta"`)
// Write metastore to response body.
if err := h.server.CopyMetastore(w); err != nil {
h.error(w, err.Error(), http.StatusInternalServerError)
}