Start RetentionPolicy control

2015-01-08 19:40:22 -08:00 · 2015-01-08 19:40:22 -08:00 · 405d300cd8
parent 0daaf4588f
commit 405d300cd8
1 changed files with 6 additions and 1 deletions
--- a/handler.go
+++ b/handler.go
@ -191,8 +191,13 @@ func (h *Handler) serveQuery(w http.ResponseWriter, r *http.Request, u *User) {
 			continue

 		case *influxql.CreateRetentionPolicyStatement:
-			continue
+			rp := NewRetentionPolicy(c.Name)
+			rp.Duration = c.Duration
+			rp.ReplicaN = c.Replication
+			err = h.server.CreateRetentionPolicy(c.Database, rp)
 		case *influxql.AlterRetentionPolicyStatement:
+			rp := NewRetentionPolicy(c.Name) // Not going to work.
+			err = h.server.UpdateRetentionPolicy(c.Database, c.Name, rp)
 			continue

 		case *influxql.CreateContinuousQueryStatement: