(t *testing.T)
| 294 | } |
| 295 | |
| 296 | func TestWaitInstanceState_TimeoutOnError(t *testing.T) { |
| 297 | t.Parallel() |
| 298 | |
| 299 | const ( |
| 300 | instanceID = "test" |
| 301 | timeoutDuration = time.Second |
| 302 | ) |
| 303 | |
| 304 | ctx, cancel := context.WithTimeout(context.Background(), timeoutDuration) |
| 305 | defer cancel() |
| 306 | |
| 307 | ring := &RingMock{} |
| 308 | ring.On("GetInstanceState", mock.Anything, mock.Anything).Return(PENDING, errors.New("instance not found in the ring")) |
| 309 | |
| 310 | err := WaitInstanceState(ctx, ring, instanceID, ACTIVE) |
| 311 | |
| 312 | assert.Equal(t, context.DeadlineExceeded, err) |
| 313 | ring.AssertCalled(t, "GetInstanceState", instanceID) |
| 314 | } |
| 315 | |
| 316 | func TestWaitInstanceState_ExitsAfterActualStateEqualsState(t *testing.T) { |
| 317 | t.Parallel() |
nothing calls this directly
no test coverage detected