(k *protocol.Kite)
| 76 | } |
| 77 | |
| 78 | func (e *Etcd) Delete(k *protocol.Kite) error { |
| 79 | etcdKey := KitesPrefix + k.String() |
| 80 | etcdIDKey := KitesPrefix + "/" + k.ID |
| 81 | |
| 82 | _, e1 := e.client.Delete(context.TODO(), etcdKey, &etcd.DeleteOptions{ |
| 83 | Recursive: true, |
| 84 | }) |
| 85 | _, e2 := e.client.Delete(context.TODO(), etcdIDKey, &etcd.DeleteOptions{ |
| 86 | Recursive: true, |
| 87 | }) |
| 88 | return nonil(e1, e2) |
| 89 | } |
| 90 | |
| 91 | func (e *Etcd) Clear() error { |
| 92 | _, err := e.client.Delete(context.TODO(), KitesPrefix, &etcd.DeleteOptions{ |