Function TestClientTTRPC_Reconnect

integration/client/client_ttrpc_test.go:45–71

(t *testing.T)

}

func TestClientTTRPC_Reconnect(t *testing.T) {
	if testing.Short() {
		t.Skip()
	}
	client, err := ttrpcutil.NewClient(address + ".ttrpc")
	assert.NoError(t, err)

	err = client.Reconnect()
	assert.NoError(t, err)

	service, err := client.EventsService()
	assert.NoError(t, err)

	// Send test request to make sure its alive after reconnect
	_, err = service.Forward(context.Background(), &v1.ForwardRequest{
		Envelope: &apitypes.Envelope{
			Timestamp: protobuf.ToTimestamp(time.Now()),
			Namespace: namespaces.Default,
			Topic:     "/test",
			Event:     &types.Any{},
		},
	})
	assert.NoError(t, err)

	err = client.Close()
	assert.NoError(t, err)
}

func TestClientTTRPC_Close(t *testing.T) {
	if testing.Short() {