(ctx context.Context, nodeToken string)
| 333 | } |
| 334 | |
| 335 | func waitWikiNodeDeleted(ctx context.Context, nodeToken string) error { |
| 336 | deadline := time.NewTimer(20 * time.Second) |
| 337 | defer deadline.Stop() |
| 338 | ticker := time.NewTicker(time.Second) |
| 339 | defer ticker.Stop() |
| 340 | |
| 341 | for { |
| 342 | deleted, err := isWikiNodeDeleted(ctx, nodeToken) |
| 343 | if err != nil { |
| 344 | return err |
| 345 | } |
| 346 | if deleted { |
| 347 | return nil |
| 348 | } |
| 349 | |
| 350 | select { |
| 351 | case <-ctx.Done(): |
| 352 | return ctx.Err() |
| 353 | case <-deadline.C: |
| 354 | return fmt.Errorf("wiki node %s still exists after delete", nodeToken) |
| 355 | case <-ticker.C: |
| 356 | } |
| 357 | } |
| 358 | } |
| 359 | |
| 360 | func isWikiNodeDeleted(ctx context.Context, nodeToken string) (bool, error) { |
| 361 | result, err := clie2e.RunCmdWithRetry(ctx, clie2e.Request{ |
no test coverage detected