(t *testing.T)
| 274 | } |
| 275 | |
| 276 | func TestWaitInstanceState_Timeout(t *testing.T) { |
| 277 | t.Parallel() |
| 278 | |
| 279 | const ( |
| 280 | instanceID = "test" |
| 281 | timeoutDuration = time.Second |
| 282 | ) |
| 283 | |
| 284 | ctx, cancel := context.WithTimeout(context.Background(), timeoutDuration) |
| 285 | defer cancel() |
| 286 | |
| 287 | ring := &RingMock{} |
| 288 | ring.On("GetInstanceState", mock.Anything, mock.Anything).Return(ACTIVE, nil) |
| 289 | |
| 290 | err := WaitInstanceState(ctx, ring, instanceID, PENDING) |
| 291 | |
| 292 | assert.Equal(t, context.DeadlineExceeded, err) |
| 293 | ring.AssertCalled(t, "GetInstanceState", instanceID) |
| 294 | } |
| 295 | |
| 296 | func TestWaitInstanceState_TimeoutOnError(t *testing.T) { |
| 297 | t.Parallel() |
nothing calls this directly
no test coverage detected