Skip to content

Add vmId to the Rntbd Health Check Error Message #43079

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
nehrao1 merged 13 commits into from
Jan 10, 2025
Merged

Add vmId to the Rntbd Health Check Error Message #43079

Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
3e82403
float vmId to rntbd layer
nehrao1 Nov 25, 2024
726a94b
remove comment and extra newline
nehrao1 Nov 25, 2024
38e99bb
CHANGELOG
nehrao1 Nov 25, 2024
5d4457d
fetch system info
nehrao1 Dec 2, 2024
a7d7b0a
progress
nehrao1 Dec 10, 2024
1fb1ea9
tests
nehrao1 Dec 28, 2024
4ecff08
pr comment
nehrao1 Jan 6, 2025
88619d1
merge main
nehrao1 Jan 6, 2025
73022d9
fix
nehrao1 Jan 6, 2025
7e359cf
pr comments
nehrao1 Jan 6, 2025
45b2694
pr comments
nehrao1 Jan 8, 2025
fcec0c4
Fix ConnectionStateListenerTest
jeet1995 Jan 9, 2025
845300a
Merge branch 'main' into vmId
nehrao1 Jan 9, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Fix ConnectionStateListenerTest
  • Loading branch information
@jeet1995
jeet1995 committed Jan 9, 2025
commit fcec0c46d4b635ddf3d6b36d2c3d38db04ee8ec4
21 changes: 20 additions & 1 deletion .../java/com/azure/cosmos/implementation/directconnectivity/ConnectionStateListenerTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,7 @@

package com.azure.cosmos.implementation.directconnectivity;

import com.azure.cosmos.ConnectionMode;
import com.azure.cosmos.DirectConnectionConfig;
import com.azure.cosmos.implementation.Configs;
import com.azure.cosmos.implementation.ConnectionPolicy;
Expand All @@ -13,6 +14,8 @@
import com.azure.cosmos.implementation.ResourceType;
import com.azure.cosmos.implementation.RxDocumentServiceRequest;
import com.azure.cosmos.implementation.UserAgentContainer;
import com.azure.cosmos.implementation.clienttelemetry.ClientTelemetry;
import com.azure.cosmos.implementation.clienttelemetry.ClientTelemetryInfo;
import com.azure.cosmos.implementation.directconnectivity.TcpServerMock.RequestResponseType;
import com.azure.cosmos.implementation.directconnectivity.TcpServerMock.SslContextUtils;
import com.azure.cosmos.implementation.directconnectivity.TcpServerMock.TcpServer;
Expand All @@ -33,6 +36,7 @@
import java.io.IOException;
import java.nio.channels.ClosedChannelException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Random;
Expand Down Expand Up @@ -93,12 +97,27 @@ public void connectionStateListener_OnConnectionEvent(
Configs config = Mockito.mock(Configs.class);
Mockito.doReturn(sslContext).when(config).getSslContext(false, false);

ClientTelemetry clientTelemetry = Mockito.mock(ClientTelemetry.class);
ClientTelemetryInfo clientTelemetryInfo = new ClientTelemetryInfo(
"testMachine",
"testClient",
"testProcess",
"testApp",
ConnectionMode.DIRECT,
"test-cdb-account",
"Test Region 1",
"Linux",
false,
Arrays.asList("Test Region 1", "Test Region 2"));

Mockito.when(clientTelemetry.getClientTelemetryInfo()).thenReturn(clientTelemetryInfo);

RntbdTransportClient client = new RntbdTransportClient(
config,
connectionPolicy,
new UserAgentContainer(),
addressResolver,
null,
clientTelemetry,
null);

RxDocumentServiceRequest req =
Expand Down
Loading