(ctx context.Context)
| 73 | } |
| 74 | |
| 75 | func (kvs *KVInitService) running(ctx context.Context) error { |
| 76 | select { |
| 77 | case <-ctx.Done(): |
| 78 | return nil |
| 79 | case err := <-kvs.watcher.Chan(): |
| 80 | // Only happens if KV service was actually initialized in GetMemberlistKV and it fails. |
| 81 | return err |
| 82 | } |
| 83 | } |
| 84 | |
| 85 | func (kvs *KVInitService) stopping(_ error) error { |
| 86 | kv := kvs.getKV() |