Function TestFatalErrors

lambda/invoke_loop_test.go:26–42

(t *testing.T)

)

func TestFatalErrors(t *testing.T) {
	ts, record := runtimeAPIServer(``, 100)
	defer ts.Close()
	handler := NewHandler(func() error {
		panic(errors.New("a fatal error"))
	})
	endpoint := strings.Split(ts.URL, "://")[1]
	expectedErrorMessage := "calling the handler function resulted in a panic, the process should exit"
	assert.EqualError(t, startRuntimeAPILoop(endpoint, handler), expectedErrorMessage)
	assert.Equal(t, 1, record.nGets)
	var invokeErr messages.InvokeResponse_Error
	err := json.Unmarshal(record.responses[0], &invokeErr)
	assert.NoError(t, err)
	assert.NotNil(t, invokeErr.StackTrace)
	assert.Equal(t, "errorString", invokeErr.Type)
	assert.Equal(t, "a fatal error", invokeErr.Message)
}

func TestRuntimeAPILoop(t *testing.T) {
	nInvokes := 10