From da7c612bb6eadaed448fbf83c1cbb8b61d4afa84 Mon Sep 17 00:00:00 2001 From: Clayton Coleman Date: Fri, 22 May 2015 23:30:41 -0400 Subject: [PATCH] Expire is a new type of watch action --- pkg/tools/etcd_helper_watch.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/pkg/tools/etcd_helper_watch.go b/pkg/tools/etcd_helper_watch.go index a10128cdd4a..4b3fb1cab21 100644 --- a/pkg/tools/etcd_helper_watch.go +++ b/pkg/tools/etcd_helper_watch.go @@ -39,6 +39,7 @@ const ( EtcdSet = "set" EtcdCAS = "compareAndSwap" EtcdDelete = "delete" + EtcdExpire = "expire" ) // FilterFunc is a predicate which takes an API object and returns true @@ -405,7 +406,7 @@ func (w *etcdWatcher) sendResult(res *etcd.Response) { w.sendAdd(res) case EtcdSet, EtcdCAS: w.sendModify(res) - case EtcdDelete: + case EtcdDelete, EtcdExpire: w.sendDelete(res) default: glog.Errorf("unknown action: %v", res.Action)