Skip to content

test: Add interop test for a random_subsetting_experimental LB policy. #8816

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

Closed
marek-szews wants to merge 2 commits into from
Closed

test: Add interop test for a random_subsetting_experimental LB policy. #8816

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
c1af589
Add interopt test for a random_subsetting_experimental LB policy.
marek-szews Jan 8, 2026
7543fba
A more appropriate variable name.
marek-szews Jan 12, 2026
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
10 changes: 7 additions & 3 deletions interop/client/client.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -48,9 +48,10 @@ import (
"google.golang.org/grpc/resolver"
"google.golang.org/grpc/testdata"

_ "google.golang.org/grpc/balancer/grpclb" // Register the grpclb load balancing policy.
_ "google.golang.org/grpc/balancer/rls" // Register the RLS load balancing policy.
"google.golang.org/grpc/xds/googledirectpath" // Register xDS resolver required for c2p directpath.
_ "google.golang.org/grpc/balancer/grpclb" // Register the grpclb load balancing policy.
_ "google.golang.org/grpc/balancer/randomsubsetting" // Register the random_subsetting_experimental load balancing policy.
_ "google.golang.org/grpc/balancer/rls" // Register the RLS load balancing policy.
"google.golang.org/grpc/xds/googledirectpath" // Register xDS resolver required for c2p directpath.

testgrpc "google.golang.org/grpc/interop/grpc_testing"
)
Expand Down Expand Up @@ -402,6 +403,9 @@ func main() {
case "orca_oob":
interop.DoORCAOOBTest(ctx, tc)
logger.Infoln("ORCAOOB done")
case "random_subsetting":
interop.DoEmptyUnaryCall(ctx, tc)
logger.Infoln("Random subsetting done")
default:
logger.Fatal("Unsupported test case: ", *testCase)
}
Expand Down
8 changes: 7 additions & 1 deletion interop/interop_test.sh
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -94,6 +94,7 @@ CASES=(
"orca_oob"
"rpc_soak"
"channel_soak"
"random_subsetting"
)

# Build server
Expand All @@ -112,19 +113,24 @@ else
pass "successfully built client"
fi

SERVICE_CONFIG='{ "loadBalancingConfig": [{ "test_backend_metrics_load_balancer": {} }]}'

# Start server
SERVER_LOG="$(mktemp)"
GRPC_GO_LOG_SEVERITY_LEVEL=info go run ./interop/server --use_tls &> $SERVER_LOG &

for case in ${CASES[@]}; do
echo "$(tput setaf 4) $(date): testing: ${case} $(tput sgr 0)"

if [[ "${case}" == "random_subsetting" ]]; then
SERVICE_CONFIG='{ "loadBalancingConfig": [{ "random_subsetting_experimental": { "subsetSize": 3, "childPolicy": [{ "round_robin": {} }] } }]}'
fi
CLIENT_LOG="$(mktemp)"
if ! GRPC_GO_LOG_SEVERITY_LEVEL=info withTimeout 20 go run ./interop/client \
--use_tls \
--server_host_override=foo.test.google.fr \
--use_test_ca --test_case="${case}" \
--service_config_json='{ "loadBalancingConfig": [{ "test_backend_metrics_load_balancer": {} }]}' \
--service_config_json="${SERVICE_CONFIG}" \
&> $CLIENT_LOG; then
fail "FAIL: test case ${case}
got server log:
Expand Down
Loading