(t *testing.T)
| 392 | } |
| 393 | |
| 394 | func TestWaitInstanceState_TimeoutOnError(t *testing.T) { |
| 395 | t.Parallel() |
| 396 | |
| 397 | const ( |
| 398 | instanceID = "test" |
| 399 | timeoutDuration = time.Second |
| 400 | ) |
| 401 | |
| 402 | ctx, cancel := context.WithTimeout(context.Background(), timeoutDuration) |
| 403 | defer cancel() |
| 404 | |
| 405 | ring := &RingMock{} |
| 406 | ring.On("GetInstanceState", mock.Anything, mock.Anything).Return(PENDING, errors.New("instance not found in the ring")) |
| 407 | |
| 408 | err := WaitInstanceState(ctx, ring, instanceID, ACTIVE) |
| 409 | |
| 410 | assert.Equal(t, context.DeadlineExceeded, err) |
| 411 | ring.AssertCalled(t, "GetInstanceState", instanceID) |
| 412 | } |
| 413 | |
| 414 | func TestWaitInstanceState_ExitsAfterActualStateEqualsState(t *testing.T) { |
| 415 | t.Parallel() |
nothing calls this directly
no test coverage detected