(update AuthUpdate, ts int64)
| 221 | } |
| 222 | |
| 223 | func (w *Watcher) authUpdateKey(update AuthUpdate, ts int64) string { |
| 224 | if update.ID != "" { |
| 225 | return update.ID |
| 226 | } |
| 227 | return fmt.Sprintf("%s:%d", update.Action, ts) |
| 228 | } |
| 229 | |
| 230 | func (w *Watcher) dispatchLoop(ctx context.Context) { |
| 231 | for { |