Skip to content

Commit 1a47397

Browse files
committed
add test for reconnection
1 parent bdb03d4 commit 1a47397

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

test/integration/grpc_management_plane_api_test.go

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -200,7 +200,11 @@ func TestGrpc_Reconnection(t *testing.T) {
200200
startErr := mockManagementPlaneGrpcContainer.Start(ctx)
201201
require.NoError(t, startErr)
202202

203-
mockManagementPlaneGrpcAddress = "managementPlane:9092"
203+
ipAddress, err := mockManagementPlaneGrpcContainer.Host(ctx)
204+
require.NoError(t, err)
205+
ports, err := mockManagementPlaneGrpcContainer.Ports(ctx)
206+
require.NoError(t, err)
207+
mockManagementPlaneAPIAddress = net.JoinHostPort(ipAddress, ports["9093/tcp"][0].HostPort)
204208
currentID := verifyConnection(t, 2)
205209
assert.Equal(t, originalID, currentID)
206210
}
@@ -221,6 +225,7 @@ func verifyConnection(t *testing.T, instancesLength int) string {
221225
client := resty.New()
222226
client.SetRetryCount(retryCount).SetRetryWaitTime(retryWaitTime).SetRetryMaxWaitTime(retryMaxWaitTime)
223227

228+
t.Logf("-------- mockManagementPlaneAPIAddress: %s", mockManagementPlaneAPIAddress)
224229
url := fmt.Sprintf("http://%s/api/v1/connection", mockManagementPlaneAPIAddress)
225230
resp, err := client.R().EnableTrace().Get(url)
226231

0 commit comments

Comments
 (0)