Method WaitUntilRunning

tests/integration/framework/process/daprd/daprd.go:249–264

(t *testing.T, ctx context.Context)

}

func (d *Daprd) WaitUntilRunning(t *testing.T, ctx context.Context) {
	t.Helper()

	client := client.HTTP(t)
	require.EventuallyWithT(t, func(c *assert.CollectT) {
		cctx, cancel := context.WithTimeout(ctx, time.Second)
		defer cancel()
		req, err := http.NewRequestWithContext(cctx, http.MethodGet, fmt.Sprintf("http://%s/v1.0/healthz", d.HTTPAddress()), nil)
		require.NoError(t, err)
		resp, err := client.Do(req)
		if assert.NoError(c, err) {
			defer resp.Body.Close()
			assert.Equal(c, http.StatusNoContent, resp.StatusCode)
		}
	}, 30*time.Second, 10*time.Millisecond)
}

func (d *Daprd) WaitUntilAppHealth(t *testing.T, ctx context.Context) {
	switch d.appProtocol {