Public Member Functions | Static Public Member Functions | Public Attributes | Static Public Attributes | Private Member Functions | List of all members
framework.xds_k8s_testcase.XdsKubernetesBaseTestCase Class Reference
Inheritance diagram for framework.xds_k8s_testcase.XdsKubernetesBaseTestCase:
Inheritance graph
[legend]

Public Member Functions

def assertAllBackendsReceivedRpcs (self, lb_stats)
 
def assertFailedRpcs (self, XdsTestClient test_client, Optional[int] num_rpcs=100)
 
def assertRouteConfigUpdateTrafficHandoff (self, XdsTestClient test_client, str previous_route_config_version, int retry_wait_second, int timeout_second)
 
def assertRpcsEventuallyGoToGivenServers (self, XdsTestClient test_client, List[XdsTestServer] servers, int num_rpcs=100)
 
None assertRpcStatusCodes (self, XdsTestClient test_client, *grpc.StatusCode status_code, _timedelta duration, str method)
 
def assertSuccessfulRpcs (self, XdsTestClient test_client, int num_rpcs=100)
 
def assertXdsConfigExists (self, XdsTestClient test_client)
 
def removeServerBackends (self, *server_runner=None)
 
def setUpClass (cls)
 
def setupServerBackends (self, *wait_for_healthy_status=True, server_runner=None, Optional[int] max_rate_per_endpoint=None)
 
def setupTrafficDirectorGrpc (self)
 
def tearDownClass (cls)
 

Static Public Member Functions

def diffAccumulatedStatsPerMethod (grpc_testing.LoadBalancerAccumulatedStatsResponse before, grpc_testing.LoadBalancerAccumulatedStatsResponse after)
 
LoadBalancerStatsResponse getClientRpcStats (XdsTestClient test_client, int num_rpcs)
 
bool is_supported (skips.TestConfig config)
 

Public Attributes

 check_local_certs
 
 client_image
 
 client_name
 
 client_port
 
 compute_api_version
 
 debug_use_port_forwarding
 
 enable_workload_identity
 
 ensure_firewall
 
 firewall_allowed_ports
 
 force_cleanup
 
 gcp_api_manager
 
 gcp_service_account
 
 k8s_api_manager
 
 network
 
 project
 
 resource_prefix
 
 resource_suffix
 
 resource_suffix_randomize
 
 secondary_k8s_api_manager
 
 server_image
 
 server_maintenance_port
 
 server_name
 
 server_port
 
 server_xds_host
 
 server_xds_port
 
 td_bootstrap_image
 
 xds_server_uri
 

Static Public Attributes

 bool
 
 str
 

Private Member Functions

def _assertRpcsEventuallyGoToGivenServers (self, XdsTestClient test_client, List[XdsTestServer] servers, int num_rpcs)
 

Detailed Description

Definition at line 73 of file xds_k8s_testcase.py.

Member Function Documentation

◆ _assertRpcsEventuallyGoToGivenServers()

def framework.xds_k8s_testcase.XdsKubernetesBaseTestCase._assertRpcsEventuallyGoToGivenServers (   self,
XdsTestClient  test_client,
List[XdsTestServer]  servers,
int  num_rpcs 
)
private

Definition at line 267 of file xds_k8s_testcase.py.

◆ assertAllBackendsReceivedRpcs()

def framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.assertAllBackendsReceivedRpcs (   self,
  lb_stats 
)

Definition at line 369 of file xds_k8s_testcase.py.

◆ assertFailedRpcs()

def framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.assertFailedRpcs (   self,
XdsTestClient  test_client,
Optional[int]   num_rpcs = 100 
)

Definition at line 350 of file xds_k8s_testcase.py.

◆ assertRouteConfigUpdateTrafficHandoff()

def framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.assertRouteConfigUpdateTrafficHandoff (   self,
XdsTestClient  test_client,
str  previous_route_config_version,
int  retry_wait_second,
int  timeout_second 
)

Definition at line 312 of file xds_k8s_testcase.py.

◆ assertRpcsEventuallyGoToGivenServers()

def framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.assertRpcsEventuallyGoToGivenServers (   self,
XdsTestClient  test_client,
List[XdsTestServer]  servers,
int   num_rpcs = 100 
)

Definition at line 251 of file xds_k8s_testcase.py.

◆ assertRpcStatusCodes()

None framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.assertRpcStatusCodes (   self,
XdsTestClient  test_client,
*grpc.StatusCode  status_code,
_timedelta  duration,
str  method 
) 
Assert all RPCs for a method are completing with a certain status.

Definition at line 227 of file xds_k8s_testcase.py.

◆ assertSuccessfulRpcs()

def framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.assertSuccessfulRpcs (   self,
XdsTestClient  test_client,
int   num_rpcs = 100 
)

Definition at line 201 of file xds_k8s_testcase.py.

◆ assertXdsConfigExists()

def framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.assertXdsConfigExists (   self,
XdsTestClient  test_client 
)

Definition at line 285 of file xds_k8s_testcase.py.

◆ diffAccumulatedStatsPerMethod()

def framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.diffAccumulatedStatsPerMethod ( grpc_testing.LoadBalancerAccumulatedStatsResponse  before,
grpc_testing.LoadBalancerAccumulatedStatsResponse  after 
)
static 
Only diffs stats_per_method, as the other fields are deprecated.

Definition at line 213 of file xds_k8s_testcase.py.

◆ getClientRpcStats()

LoadBalancerStatsResponse framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.getClientRpcStats ( XdsTestClient  test_client,
int  num_rpcs 
)
static

Definition at line 361 of file xds_k8s_testcase.py.

◆ is_supported()

bool framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.is_supported ( skips.TestConfig  config)
static 
Overridden by the test class to decide if the config is supported.

Returns:
  A bool indicates if the given config is supported.

Definition at line 98 of file xds_k8s_testcase.py.

◆ removeServerBackends()

def framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.removeServerBackends (   self,
*  server_runner = None 
)

Definition at line 191 of file xds_k8s_testcase.py.

◆ setUpClass()

def framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.setUpClass (   cls) 
Hook method for setting up class fixture before running tests in
the class.

Reimplemented in framework.xds_k8s_testcase.SecurityXdsKubernetesTestCase, framework.xds_k8s_testcase.RegularXdsKubernetesTestCase, and framework.bootstrap_generator_testcase.BootstrapGeneratorBaseTest.

Definition at line 108 of file xds_k8s_testcase.py.

◆ setupServerBackends()

def framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.setupServerBackends (   self,
*  wait_for_healthy_status = True,
  server_runner = None,
Optional[int]   max_rate_per_endpoint = None 
)

Definition at line 174 of file xds_k8s_testcase.py.

◆ setupTrafficDirectorGrpc()

def framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.setupTrafficDirectorGrpc (   self)

Definition at line 169 of file xds_k8s_testcase.py.

◆ tearDownClass()

def framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.tearDownClass (   cls)

Reimplemented in framework.bootstrap_generator_testcase.BootstrapGeneratorBaseTest.

Definition at line 164 of file xds_k8s_testcase.py.

Member Data Documentation

◆ bool

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.bool
static

Definition at line 88 of file xds_k8s_testcase.py.

◆ check_local_certs

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.check_local_certs

Definition at line 154 of file xds_k8s_testcase.py.

◆ client_image

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.client_image

Definition at line 144 of file xds_k8s_testcase.py.

◆ client_name

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.client_name

Definition at line 145 of file xds_k8s_testcase.py.

◆ client_port

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.client_port

Definition at line 146 of file xds_k8s_testcase.py.

◆ compute_api_version

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.compute_api_version

Definition at line 127 of file xds_k8s_testcase.py.

◆ debug_use_port_forwarding

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.debug_use_port_forwarding

Definition at line 150 of file xds_k8s_testcase.py.

◆ enable_workload_identity

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.enable_workload_identity

Definition at line 152 of file xds_k8s_testcase.py.

◆ ensure_firewall

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.ensure_firewall

Definition at line 125 of file xds_k8s_testcase.py.

◆ firewall_allowed_ports

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.firewall_allowed_ports

Definition at line 126 of file xds_k8s_testcase.py.

◆ force_cleanup

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.force_cleanup

Definition at line 149 of file xds_k8s_testcase.py.

◆ gcp_api_manager

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.gcp_api_manager

Definition at line 161 of file xds_k8s_testcase.py.

◆ gcp_service_account

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.gcp_service_account

Definition at line 122 of file xds_k8s_testcase.py.

◆ k8s_api_manager

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.k8s_api_manager

Definition at line 157 of file xds_k8s_testcase.py.

◆ network

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.network

Definition at line 121 of file xds_k8s_testcase.py.

◆ project

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.project

Definition at line 120 of file xds_k8s_testcase.py.

◆ resource_prefix

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.resource_prefix

Definition at line 130 of file xds_k8s_testcase.py.

◆ resource_suffix

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.resource_suffix

Definition at line 133 of file xds_k8s_testcase.py.

◆ resource_suffix_randomize

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.resource_suffix_randomize

Definition at line 132 of file xds_k8s_testcase.py.

◆ secondary_k8s_api_manager

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.secondary_k8s_api_manager

Definition at line 159 of file xds_k8s_testcase.py.

◆ server_image

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.server_image

Definition at line 136 of file xds_k8s_testcase.py.

◆ server_maintenance_port

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.server_maintenance_port

Definition at line 139 of file xds_k8s_testcase.py.

◆ server_name

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.server_name

Definition at line 137 of file xds_k8s_testcase.py.

◆ server_port

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.server_port

Definition at line 138 of file xds_k8s_testcase.py.

◆ server_xds_host

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.server_xds_host

Definition at line 140 of file xds_k8s_testcase.py.

◆ server_xds_port

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.server_xds_port

Definition at line 141 of file xds_k8s_testcase.py.

◆ str

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.str
static

Definition at line 85 of file xds_k8s_testcase.py.

◆ td_bootstrap_image

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.td_bootstrap_image

Definition at line 123 of file xds_k8s_testcase.py.

◆ xds_server_uri

framework.xds_k8s_testcase.XdsKubernetesBaseTestCase.xds_server_uri

Definition at line 124 of file xds_k8s_testcase.py.

The documentation for this class was generated from the following file:

grpc
Author(s):
autogenerated on Fri May 16 2025 03:03:10