github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-07 03:03:59 +00:00
Code Issues Projects Releases Wiki Activity

Expire is a new type of watch action

Browse Source
This commit is contained in:
Clayton Coleman 2015-05-22 23:30:41 -04:00
parent 3368e12a6c
commit da7c612bb6
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pkg/tools/etcd_helper_watch.go
View File

@ -39,6 +39,7 @@ const (
EtcdSet = "set" EtcdSet = "set"
EtcdCAS = "compareAndSwap" EtcdCAS = "compareAndSwap"
EtcdDelete = "delete" EtcdDelete = "delete"
EtcdExpire = "expire"
) )
// FilterFunc is a predicate which takes an API object and returns true // 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) w.sendAdd(res)
case EtcdSet, EtcdCAS: case EtcdSet, EtcdCAS:
w.sendModify(res) w.sendModify(res)
case EtcdDelete: case EtcdDelete, EtcdExpire:
w.sendDelete(res) w.sendDelete(res)
default: default:
glog.Errorf("unknown action: %v", res.Action) glog.Errorf("unknown action: %v", res.Action)