#include <xds_end2end_test_lib.h>

Inheritance diagram for grpc::testing::XdsEnd2endTest:

[legend]

Classes
class	BackendServerThread

class	BalancerServerThread

class	BootstrapBuilder

class	ClientHcmAccessor

struct	ConcurrentRpc

struct	EdsResourceArgs

class	HcmAccessor

class	LongRunningRpc

struct	RpcOptions

struct	RpcResult

class	ScopedExperimentalEnvVar

class	ServerHcmAccessor

class	ServerThread

struct	WaitForBackendOptions

Protected Types
using	Cluster = ::envoy::config::cluster::v3::Cluster

using	ClusterLoadAssignment = ::envoy::config::endpoint::v3::ClusterLoadAssignment

using	HttpConnectionManager = ::envoy::extensions::filters::network::http_connection_manager::v3::HttpConnectionManager

using	Listener = ::envoy::config::listener::v3::Listener

using	RouteConfiguration = ::envoy::config::route::v3::RouteConfiguration

enum	RpcMethod { METHOD_ECHO, METHOD_ECHO1, METHOD_ECHO2 }

enum	RpcService { SERVICE_ECHO, SERVICE_ECHO1, SERVICE_ECHO2 }

Protected Member Functions
ClusterLoadAssignment	BuildEdsResource (const EdsResourceArgs &args, const char *eds_service_name=kDefaultEdsServiceName)

void	CheckRpcSendFailure (const grpc_core::DebugLocation &debug_location, StatusCode expected_status, absl::string_view expected_message_regex, const RpcOptions &rpc_options=RpcOptions())

void	CheckRpcSendOk (const grpc_core::DebugLocation &debug_location, const size_t times=1, const RpcOptions &rpc_options=RpcOptions())

void	CreateAndStartBackends (size_t num_backends, bool xds_enabled=false)

std::unique_ptr< BalancerServerThread >	CreateAndStartBalancer ()

void	CreateBackends (size_t num_backends, bool xds_enabled=false)

std::shared_ptr< Channel >	CreateChannel (int failover_timeout_ms=0, const char server_name=kServerName, const char xds_authority="", ChannelArguments *args=nullptr)

EdsResourceArgs::Endpoint	CreateEndpoint (size_t backend_idx, ::envoy::config::endpoint::v3::HealthStatus health_status=::envoy::config::endpoint::v3::HealthStatus::UNKNOWN, int lb_weight=1)

std::vector< EdsResourceArgs::Endpoint >	CreateEndpointsForBackends (size_t start_index=0, size_t stop_index=0, ::envoy::config::endpoint::v3::HealthStatus health_status=::envoy::config::endpoint::v3::HealthStatus::UNKNOWN, int lb_weight=1)

std::vector< int >	GetBackendPorts (size_t start_index=0, size_t stop_index=0) const

std::string	GetServerListenerName (int port)

void	InitClient (BootstrapBuilder builder=BootstrapBuilder(), std::string lb_expected_authority="", int xds_resource_does_not_exist_timeout_ms=0)

EdsResourceArgs::Endpoint	MakeNonExistantEndpoint ()

Listener	PopulateServerListenerNameAndPort (const Listener &listener_template, int port)

void	ResetBackendCounters (size_t start_index=0, size_t stop_index=0)

void	ResetStub (int failover_timeout_ms=0, ChannelArguments *args=nullptr)

absl::optional< AdsServiceImpl::ResponseState >	RouteConfigurationResponseState (BalancerServerThread *balancer) const

bool	SeenAllBackends (size_t start_index=0, size_t stop_index=0, const RpcService rpc_service=SERVICE_ECHO)

bool	SeenBackend (size_t backend_idx, const RpcService rpc_service=SERVICE_ECHO)

std::vector< ConcurrentRpc >	SendConcurrentRpcs (const grpc_core::DebugLocation &debug_location, grpc::testing::EchoTestService::Stub *stub, size_t num_rpcs, const RpcOptions &rpc_options)

Status	SendRpc (const RpcOptions &rpc_options=RpcOptions(), EchoResponse *response=nullptr)

size_t	SendRpcsAndCountFailuresWithMessage (const grpc_core::DebugLocation &debug_location, size_t num_rpcs, StatusCode expected_status, absl::string_view expected_message_prefix, const RpcOptions &rpc_options=RpcOptions())

void	SendRpcsUntil (const grpc_core::DebugLocation &debug_location, std::function< bool(const RpcResult &)> continue_predicate, int timeout_ms=5000, const RpcOptions &rpc_options=RpcOptions())

void	SetListenerAndRouteConfiguration (BalancerServerThread *balancer, Listener listener, const RouteConfiguration &route_config, const HcmAccessor &hcm_accessor=ClientHcmAccessor())

void	SetRouteConfiguration (BalancerServerThread balancer, const RouteConfiguration &route_config, const Listener listener_to_copy=nullptr)

void	SetServerListenerNameAndRouteConfiguration (BalancerServerThread *balancer, Listener listener, int port, const RouteConfiguration &route_config)

void	SetUp () override

void	ShutdownAllBackends ()

void	ShutdownBackend (size_t index)

void	StartAllBackends ()

void	StartBackend (size_t index)

void	TearDown () override

size_t	WaitForAllBackends (const grpc_core::DebugLocation &debug_location, size_t start_index=0, size_t stop_index=0, std::function< void(const RpcResult &)> check_status=nullptr, const WaitForBackendOptions &wait_options=WaitForBackendOptions(), const RpcOptions &rpc_options=RpcOptions())

void	WaitForBackend (const grpc_core::DebugLocation &debug_location, size_t backend_idx, std::function< void(const RpcResult &)> check_status=nullptr, const WaitForBackendOptions &wait_options=WaitForBackendOptions(), const RpcOptions &rpc_options=RpcOptions())

absl::optional< AdsServiceImpl::ResponseState >	WaitForCdsNack (const grpc_core::DebugLocation &debug_location, StatusCode expected_status=StatusCode::UNAVAILABLE)

absl::optional< AdsServiceImpl::ResponseState >	WaitForEdsNack (const grpc_core::DebugLocation &debug_location)

absl::optional< AdsServiceImpl::ResponseState >	WaitForLdsNack (const grpc_core::DebugLocation &debug_location, StatusCode expected_status=StatusCode::UNAVAILABLE)

absl::optional< AdsServiceImpl::ResponseState >	WaitForNack (const grpc_core::DebugLocation &debug_location, std::function< absl::optional< AdsServiceImpl::ResponseState >()> get_state, StatusCode expected_status=StatusCode::UNAVAILABLE)

absl::optional< AdsServiceImpl::ResponseState >	WaitForRdsNack (const grpc_core::DebugLocation &debug_location, StatusCode expected_status=StatusCode::UNAVAILABLE)

absl::optional< AdsServiceImpl::ResponseState >	WaitForRouteConfigNack (const grpc_core::DebugLocation &debug_location, StatusCode expected_status=StatusCode::UNAVAILABLE)

	XdsEnd2endTest ()

Protected Member Functions inherited from testing::Test
	Test ()

	Test ()

	Test ()

	Test ()

	Test ()

	Test ()

Static Protected Member Functions
static size_t	ComputeIdealNumRpcs (double p, double error_tolerance)

static std::shared_ptr< ChannelCredentials >	CreateTlsFallbackCredentials ()

static grpc_core::Timestamp	NowFromCycleCounter ()

static std::string	ReadFile (const char *file_path)

static grpc_core::PemKeyCertPairList	ReadTlsIdentityPair (const char key_path, const char cert_path)

template<typename Stub >
static Status	SendRpcMethod (Stub stub, const RpcOptions &rpc_options, ClientContext context, EchoRequest &request, EchoResponse *response)

Protected Attributes
std::vector< std::unique_ptr< BackendServerThread > >	backends_

std::unique_ptr< BalancerServerThread >	balancer_

std::string	bootstrap_

bool	bootstrap_contents_from_env_var_

char *	bootstrap_file_ = nullptr

std::shared_ptr< Channel >	channel_

Cluster	default_cluster_

Listener	default_listener_

RouteConfiguration	default_route_config_

Listener	default_server_listener_

RouteConfiguration	default_server_route_config_

bool	ipv6_only_ = false

std::unique_ptr< grpc::testing::EchoTest1Service::Stub >	stub1_

std::unique_ptr< grpc::testing::EchoTest2Service::Stub >	stub2_

std::unique_ptr< grpc::testing::EchoTestService::Stub >	stub_

grpc_channel_args	xds_channel_args_

absl::InlinedVector< grpc_arg, 3 >	xds_channel_args_to_add_

int	xds_drain_grace_time_ms_ = 10 * 60 * 1000

Static Protected Attributes
static const char	kCaCertPath [] = "src/core/tsi/test_creds/ca.pem"

static const char	kDefaultClusterName [] = "cluster_name"

static const char	kDefaultEdsServiceName [] = "eds_service_name"

static const int	kDefaultLocalityPriority = 0

static const char	kDefaultLocalityRegion []

static const int	kDefaultLocalityWeight = 3

static const char	kDefaultLocalityZone [] = "xds_default_locality_zone"

static const char	kDefaultRouteConfigurationName []

static const char	kDefaultServerRouteConfigurationName []

static const char	kRequestMessage [] = "Live long and prosper."

static const char	kServerCertPath []

static const char	kServerKeyPath []

static const char	kServerName [] = "server.example.com"

Additional Inherited Members
Public Types inherited from testing::Test
typedef internal::SetUpTestCaseFunc	SetUpTestCaseFunc

typedef internal::TearDownTestCaseFunc	TearDownTestCaseFunc

Public Types inherited from testing::WithParamInterface< XdsTestType >
typedef XdsTestType	ParamType

typedef XdsTestType	ParamType

typedef XdsTestType	ParamType

typedef XdsTestType	ParamType

typedef XdsTestType	ParamType

typedef XdsTestType	ParamType

Public Member Functions inherited from testing::Test
virtual	~Test ()

virtual	~Test ()

virtual	~Test ()

virtual	~Test ()

virtual	~Test ()

virtual	~Test ()

Public Member Functions inherited from testing::WithParamInterface< XdsTestType >
const ParamType &	GetParam () const

virtual	~WithParamInterface ()

virtual	~WithParamInterface ()

virtual	~WithParamInterface ()

virtual	~WithParamInterface ()

virtual	~WithParamInterface ()

virtual	~WithParamInterface ()

Static Public Member Functions inherited from testing::Test
static bool	HasFailure ()

static bool	HasFailure ()

static bool	HasFailure ()

static bool	HasFailure ()

static bool	HasFailure ()

static bool	HasFailure ()

static bool	HasFatalFailure ()

static bool	HasFatalFailure ()

static bool	HasFatalFailure ()

static bool	HasFatalFailure ()

static bool	HasFatalFailure ()

static bool	HasFatalFailure ()

static bool	HasNonfatalFailure ()

static bool	HasNonfatalFailure ()

static bool	HasNonfatalFailure ()

static bool	HasNonfatalFailure ()

static bool	HasNonfatalFailure ()

static bool	HasNonfatalFailure ()

static bool	IsSkipped ()

static bool	IsSkipped ()

static bool	IsSkipped ()

static bool	IsSkipped ()

static bool	IsSkipped ()

static void	RecordProperty (const std::string &key, const std::string &value)

static void	RecordProperty (const std::string &key, const std::string &value)

static void	RecordProperty (const std::string &key, const std::string &value)

static void	RecordProperty (const std::string &key, const std::string &value)

static void	RecordProperty (const std::string &key, const std::string &value)

static void	RecordProperty (const std::string &key, const std::string &value)

static void	RecordProperty (const std::string &key, int value)

static void	RecordProperty (const std::string &key, int value)

static void	RecordProperty (const std::string &key, int value)

static void	RecordProperty (const std::string &key, int value)

static void	RecordProperty (const std::string &key, int value)

static void	RecordProperty (const std::string &key, int value)

static void	SetUpTestCase ()

static void	SetUpTestCase ()

static void	SetUpTestCase ()

static void	SetUpTestCase ()

static void	SetUpTestCase ()

static void	SetUpTestCase ()

static void	SetUpTestSuite ()

static void	SetUpTestSuite ()

static void	SetUpTestSuite ()

static void	SetUpTestSuite ()

static void	SetUpTestSuite ()

static void	TearDownTestCase ()

static void	TearDownTestCase ()

static void	TearDownTestCase ()

static void	TearDownTestCase ()

static void	TearDownTestCase ()

static void	TearDownTestCase ()

static void	TearDownTestSuite ()

static void	TearDownTestSuite ()

static void	TearDownTestSuite ()

static void	TearDownTestSuite ()

static void	TearDownTestSuite ()

Static Public Member Functions inherited from testing::WithParamInterface< XdsTestType >
static const ParamType &	GetParam ()

static const ParamType &	GetParam ()

static const ParamType &	GetParam ()

static const ParamType &	GetParam ()

static const ParamType &	GetParam ()

Detailed Description

Definition at line 183 of file xds_end2end_test_lib.h.

Member Typedef Documentation

◆ Cluster

using grpc::testing::XdsEnd2endTest::Cluster = ::envoy::config::cluster::v3::Cluster

protected

Definition at line 185 of file xds_end2end_test_lib.h.

◆ ClusterLoadAssignment

using grpc::testing::XdsEnd2endTest::ClusterLoadAssignment = ::envoy::config::endpoint::v3::ClusterLoadAssignment

protected

Definition at line 187 of file xds_end2end_test_lib.h.

◆ HttpConnectionManager

using grpc::testing::XdsEnd2endTest::HttpConnectionManager = ::envoy::extensions::filters::network:: http_connection_manager::v3::HttpConnectionManager

protected

Definition at line 191 of file xds_end2end_test_lib.h.

◆ Listener

using grpc::testing::XdsEnd2endTest::Listener = ::envoy::config::listener::v3::Listener

protected

Definition at line 188 of file xds_end2end_test_lib.h.

◆ RouteConfiguration

using grpc::testing::XdsEnd2endTest::RouteConfiguration = ::envoy::config::route::v3::RouteConfiguration

protected

Definition at line 189 of file xds_end2end_test_lib.h.

Member Enumeration Documentation

◆ RpcMethod

enum grpc::testing::XdsEnd2endTest::RpcMethod

protected

Enumerator
METHOD_ECHO
METHOD_ECHO1
METHOD_ECHO2

Definition at line 486 of file xds_end2end_test_lib.h.

◆ RpcService

enum grpc::testing::XdsEnd2endTest::RpcService

protected

Enumerator
SERVICE_ECHO
SERVICE_ECHO1
SERVICE_ECHO2

Definition at line 479 of file xds_end2end_test_lib.h.

Constructor & Destructor Documentation

◆ XdsEnd2endTest()

grpc::testing::XdsEnd2endTest::XdsEnd2endTest ( )

protected

Definition at line 463 of file xds_end2end_test_lib.cc.

Member Function Documentation

◆ BuildEdsResource()

ClusterLoadAssignment grpc::testing::XdsEnd2endTest::BuildEdsResource	(	const EdsResourceArgs &	args,
		const char *	eds_service_name = `kDefaultEdsServiceName`
	)

protected

Definition at line 631 of file xds_end2end_test_lib.cc.

◆ CheckRpcSendFailure()

void grpc::testing::XdsEnd2endTest::CheckRpcSendFailure	(	const grpc_core::DebugLocation &	debug_location,
		StatusCode	expected_status,
		absl::string_view	expected_message_regex,
		const RpcOptions &	rpc_options = `RpcOptions()`
	)

protected

Definition at line 879 of file xds_end2end_test_lib.cc.

◆ CheckRpcSendOk()

void grpc::testing::XdsEnd2endTest::CheckRpcSendOk	(	const grpc_core::DebugLocation &	debug_location,
		const size_t	times = `1`,
		const RpcOptions &	rpc_options = `RpcOptions()`
	)

protected

Definition at line 863 of file xds_end2end_test_lib.cc.

◆ ComputeIdealNumRpcs()

static size_t grpc::testing::XdsEnd2endTest::ComputeIdealNumRpcs	(	double	p,
		double	error_tolerance
	)

inlinestaticprotected

Definition at line 1021 of file xds_end2end_test_lib.h.

◆ CreateAndStartBackends()

void grpc::testing::XdsEnd2endTest::CreateAndStartBackends	(	size_t	num_backends,
		bool	xds_enabled = `false`
	)

inlineprotected

Definition at line 657 of file xds_end2end_test_lib.h.

◆ CreateAndStartBalancer()

std::unique_ptr< XdsEnd2endTest::BalancerServerThread > grpc::testing::XdsEnd2endTest::CreateAndStartBalancer ( )

protected

Definition at line 534 of file xds_end2end_test_lib.cc.

◆ CreateBackends()

void grpc::testing::XdsEnd2endTest::CreateBackends	(	size_t	num_backends,
		bool	xds_enabled = `false`
	)

inlineprotected

Definition at line 645 of file xds_end2end_test_lib.h.

◆ CreateChannel()

std::shared_ptr< Channel > grpc::testing::XdsEnd2endTest::CreateChannel	(	int	failover_timeout_ms = `0`,
		const char *	server_name = `kServerName`,
		const char *	xds_authority = `""`,
		ChannelArguments *	args = `nullptr`
	)

protected

Definition at line 786 of file xds_end2end_test_lib.cc.

◆ CreateEndpoint()

EdsResourceArgs::Endpoint grpc::testing::XdsEnd2endTest::CreateEndpoint	(	size_t	backend_idx,
		::envoy::config::endpoint::v3::HealthStatus	health_status = `::envoy::config::endpoint::v3::HealthStatus::UNKNOWN`,
		int	lb_weight = `1`
	)

inlineprotected

Definition at line 610 of file xds_end2end_test_lib.h.

◆ CreateEndpointsForBackends()

std::vector< XdsEnd2endTest::EdsResourceArgs::Endpoint > grpc::testing::XdsEnd2endTest::CreateEndpointsForBackends	(	size_t	start_index = `0`,
		size_t	stop_index = `0`,
		::envoy::config::endpoint::v3::HealthStatus	health_status = `::envoy::config::endpoint::v3::HealthStatus::UNKNOWN`,
		int	lb_weight = `1`
	)

protected

Definition at line 619 of file xds_end2end_test_lib.cc.

◆ CreateTlsFallbackCredentials()

std::shared_ptr< ChannelCredentials > grpc::testing::XdsEnd2endTest::CreateTlsFallbackCredentials ( )

staticprotected

Definition at line 1042 of file xds_end2end_test_lib.cc.

◆ GetBackendPorts()

std::vector< int > grpc::testing::XdsEnd2endTest::GetBackendPorts	(	size_t	start_index = `0`,
		size_t	stop_index = `0`
	)		const

protected

Definition at line 719 of file xds_end2end_test_lib.cc.

◆ GetServerListenerName()

std::string grpc::testing::XdsEnd2endTest::GetServerListenerName ( int port )

protected

Definition at line 541 of file xds_end2end_test_lib.cc.

◆ InitClient()

void grpc::testing::XdsEnd2endTest::InitClient	(	BootstrapBuilder	builder = `BootstrapBuilder()`,
		std::string	lb_expected_authority = `""`,
		int	xds_resource_does_not_exist_timeout_ms = `0`
	)

protected

Definition at line 729 of file xds_end2end_test_lib.cc.

◆ MakeNonExistantEndpoint()

EdsResourceArgs::Endpoint grpc::testing::XdsEnd2endTest::MakeNonExistantEndpoint ( )

inlineprotected

Definition at line 629 of file xds_end2end_test_lib.h.

◆ NowFromCycleCounter()

static grpc_core::Timestamp grpc::testing::XdsEnd2endTest::NowFromCycleCounter ( )

inlinestaticprotected

Definition at line 1000 of file xds_end2end_test_lib.h.

◆ PopulateServerListenerNameAndPort()

Listener grpc::testing::XdsEnd2endTest::PopulateServerListenerNameAndPort	(	const Listener &	listener_template,
		int	port
	)

protected

Definition at line 546 of file xds_end2end_test_lib.cc.

◆ ReadFile()

std::string grpc::testing::XdsEnd2endTest::ReadFile ( const char * file_path )

staticprotected

Definition at line 1026 of file xds_end2end_test_lib.cc.

◆ ReadTlsIdentityPair()

grpc_core::PemKeyCertPairList grpc::testing::XdsEnd2endTest::ReadTlsIdentityPair	(	const char *	key_path,
		const char *	cert_path
	)

staticprotected

Definition at line 1035 of file xds_end2end_test_lib.cc.

◆ ResetBackendCounters()

void grpc::testing::XdsEnd2endTest::ResetBackendCounters	(	size_t	start_index = `0`,
		size_t	stop_index = `0`
	)

protected

Definition at line 676 of file xds_end2end_test_lib.cc.

◆ ResetStub()

void grpc::testing::XdsEnd2endTest::ResetStub	(	int	failover_timeout_ms = `0`,
		ChannelArguments *	args = `nullptr`
	)

protected

Definition at line 778 of file xds_end2end_test_lib.cc.

◆ RouteConfigurationResponseState()

absl::optional<AdsServiceImpl::ResponseState> grpc::testing::XdsEnd2endTest::RouteConfigurationResponseState ( BalancerServerThread * balancer ) const

inlineprotected

Definition at line 983 of file xds_end2end_test_lib.h.

◆ SeenAllBackends()

bool grpc::testing::XdsEnd2endTest::SeenAllBackends	(	size_t	start_index = `0`,
		size_t	stop_index = `0`,
		const RpcService	rpc_service = `SERVICE_ECHO`
	)

protected

Definition at line 708 of file xds_end2end_test_lib.cc.

◆ SeenBackend()

bool grpc::testing::XdsEnd2endTest::SeenBackend	(	size_t	backend_idx,
		const RpcService	rpc_service = `SERVICE_ECHO`
	)

protected

Definition at line 686 of file xds_end2end_test_lib.cc.

◆ SendConcurrentRpcs()

std::vector< XdsEnd2endTest::ConcurrentRpc > grpc::testing::XdsEnd2endTest::SendConcurrentRpcs	(	const grpc_core::DebugLocation &	debug_location,
		grpc::testing::EchoTestService::Stub *	stub,
		size_t	num_rpcs,
		const RpcOptions &	rpc_options
	)

protected

Definition at line 934 of file xds_end2end_test_lib.cc.

◆ SendRpc()

Status grpc::testing::XdsEnd2endTest::SendRpc	(	const RpcOptions &	rpc_options = `RpcOptions()`,
		EchoResponse *	response = `nullptr`
	)

protected

Definition at line 815 of file xds_end2end_test_lib.cc.

◆ SendRpcMethod()

template<typename Stub >

static Status grpc::testing::XdsEnd2endTest::SendRpcMethod	(	Stub *	stub,
		const RpcOptions &	rpc_options,
		ClientContext *	context,
		EchoRequest &	request,
		EchoResponse *	response
	)

inlinestaticprotected

Definition at line 795 of file xds_end2end_test_lib.h.

◆ SendRpcsAndCountFailuresWithMessage()

size_t grpc::testing::XdsEnd2endTest::SendRpcsAndCountFailuresWithMessage	(	const grpc_core::DebugLocation &	debug_location,
		size_t	num_rpcs,
		StatusCode	expected_status,
		absl::string_view	expected_message_prefix,
		const RpcOptions &	rpc_options = `RpcOptions()`
	)

protected

Definition at line 892 of file xds_end2end_test_lib.cc.

◆ SendRpcsUntil()

void grpc::testing::XdsEnd2endTest::SendRpcsUntil	(	const grpc_core::DebugLocation &	debug_location,
		std::function< bool(const RpcResult &)>	continue_predicate,
		int	timeout_ms = `5000`,
		const RpcOptions &	rpc_options = `RpcOptions()`
	)

protected

Definition at line 844 of file xds_end2end_test_lib.cc.

◆ SetListenerAndRouteConfiguration()

void grpc::testing::XdsEnd2endTest::SetListenerAndRouteConfiguration	(	BalancerServerThread *	balancer,
		Listener	listener,
		const RouteConfiguration &	route_config,
		const HcmAccessor &	hcm_accessor = `ClientHcmAccessor()`
	)

protected

Definition at line 584 of file xds_end2end_test_lib.cc.

◆ SetRouteConfiguration()

void grpc::testing::XdsEnd2endTest::SetRouteConfiguration	(	BalancerServerThread *	balancer,
		const RouteConfiguration &	route_config,
		const Listener *	listener_to_copy = `nullptr`
	)

protected

Definition at line 600 of file xds_end2end_test_lib.cc.

◆ SetServerListenerNameAndRouteConfiguration()

void grpc::testing::XdsEnd2endTest::SetServerListenerNameAndRouteConfiguration	(	BalancerServerThread *	balancer,
		Listener	listener,
		int	port,
		const RouteConfiguration &	route_config
	)

inlineprotected

Definition at line 550 of file xds_end2end_test_lib.h.

◆ SetUp()

void grpc::testing::XdsEnd2endTest::SetUp ( )

inlineoverrideprotectedvirtual

Reimplemented from testing::Test.

Definition at line 494 of file xds_end2end_test_lib.h.

◆ ShutdownAllBackends()

void grpc::testing::XdsEnd2endTest::ShutdownAllBackends ( )

inlineprotected

Definition at line 666 of file xds_end2end_test_lib.h.

◆ ShutdownBackend()

void grpc::testing::XdsEnd2endTest::ShutdownBackend ( size_t index )

inlineprotected

Definition at line 671 of file xds_end2end_test_lib.h.

◆ StartAllBackends()

void grpc::testing::XdsEnd2endTest::StartAllBackends ( )

inlineprotected

Definition at line 652 of file xds_end2end_test_lib.h.

◆ StartBackend()

void grpc::testing::XdsEnd2endTest::StartBackend ( size_t index )

inlineprotected

Definition at line 663 of file xds_end2end_test_lib.h.

◆ TearDown()

void grpc::testing::XdsEnd2endTest::TearDown ( )

overrideprotectedvirtual

Reimplemented from testing::Test.

Definition at line 519 of file xds_end2end_test_lib.cc.

◆ WaitForAllBackends()

size_t grpc::testing::XdsEnd2endTest::WaitForAllBackends	(	const grpc_core::DebugLocation &	debug_location,
		size_t	start_index = `0`,
		size_t	stop_index = `0`,
		std::function< void(const RpcResult &)>	check_status = `nullptr`,
		const WaitForBackendOptions &	wait_options = `WaitForBackendOptions()`,
		const RpcOptions &	rpc_options = `RpcOptions()`
	)

protected

Definition at line 971 of file xds_end2end_test_lib.cc.

◆ WaitForBackend()

void grpc::testing::XdsEnd2endTest::WaitForBackend	(	const grpc_core::DebugLocation &	debug_location,
		size_t	backend_idx,
		std::function< void(const RpcResult &)>	check_status = `nullptr`,
		const WaitForBackendOptions &	wait_options = `WaitForBackendOptions()`,
		const RpcOptions &	rpc_options = `RpcOptions()`
	)

inlineprotected

Definition at line 911 of file xds_end2end_test_lib.h.

◆ WaitForCdsNack()

absl::optional<AdsServiceImpl::ResponseState> grpc::testing::XdsEnd2endTest::WaitForCdsNack	(	const grpc_core::DebugLocation &	debug_location,
		StatusCode	expected_status = `StatusCode::UNAVAILABLE`
	)

inlineprotected

Definition at line 953 of file xds_end2end_test_lib.h.

◆ WaitForEdsNack()

absl::optional<AdsServiceImpl::ResponseState> grpc::testing::XdsEnd2endTest::WaitForEdsNack ( const grpc_core::DebugLocation & debug_location )

inlineprotected

Definition at line 963 of file xds_end2end_test_lib.h.

◆ WaitForLdsNack()

absl::optional<AdsServiceImpl::ResponseState> grpc::testing::XdsEnd2endTest::WaitForLdsNack	(	const grpc_core::DebugLocation &	debug_location,
		StatusCode	expected_status = `StatusCode::UNAVAILABLE`
	)

inlineprotected

Definition at line 933 of file xds_end2end_test_lib.h.

◆ WaitForNack()

absl::optional< AdsServiceImpl::ResponseState > grpc::testing::XdsEnd2endTest::WaitForNack	(	const grpc_core::DebugLocation &	debug_location,
		std::function< absl::optional< AdsServiceImpl::ResponseState >()>	get_state,
		StatusCode	expected_status = `StatusCode::UNAVAILABLE`
	)

protected

Definition at line 1002 of file xds_end2end_test_lib.cc.

◆ WaitForRdsNack()

absl::optional<AdsServiceImpl::ResponseState> grpc::testing::XdsEnd2endTest::WaitForRdsNack	(	const grpc_core::DebugLocation &	debug_location,
		StatusCode	expected_status = `StatusCode::UNAVAILABLE`
	)

inlineprotected

Definition at line 943 of file xds_end2end_test_lib.h.

◆ WaitForRouteConfigNack()

absl::optional<AdsServiceImpl::ResponseState> grpc::testing::XdsEnd2endTest::WaitForRouteConfigNack	(	const grpc_core::DebugLocation &	debug_location,
		StatusCode	expected_status = `StatusCode::UNAVAILABLE`
	)

inlineprotected

Definition at line 972 of file xds_end2end_test_lib.h.

Member Data Documentation

◆ backends_

std::vector<std::unique_ptr<BackendServerThread> > grpc::testing::XdsEnd2endTest::backends_

protected

Definition at line 1052 of file xds_end2end_test_lib.h.

◆ balancer_

std::unique_ptr<BalancerServerThread> grpc::testing::XdsEnd2endTest::balancer_

protected

Definition at line 1045 of file xds_end2end_test_lib.h.

◆ bootstrap_

std::string grpc::testing::XdsEnd2endTest::bootstrap_

protected

Definition at line 1064 of file xds_end2end_test_lib.h.

◆ bootstrap_contents_from_env_var_

bool grpc::testing::XdsEnd2endTest::bootstrap_contents_from_env_var_

protected

Definition at line 1063 of file xds_end2end_test_lib.h.

◆ bootstrap_file_

char* grpc::testing::XdsEnd2endTest::bootstrap_file_ = nullptr

protected

Definition at line 1065 of file xds_end2end_test_lib.h.

◆ channel_

std::shared_ptr<Channel> grpc::testing::XdsEnd2endTest::channel_

protected

Definition at line 1047 of file xds_end2end_test_lib.h.

◆ default_cluster_

Cluster grpc::testing::XdsEnd2endTest::default_cluster_

protected

Definition at line 1059 of file xds_end2end_test_lib.h.

◆ default_listener_

Listener grpc::testing::XdsEnd2endTest::default_listener_

protected

Definition at line 1055 of file xds_end2end_test_lib.h.

◆ default_route_config_

RouteConfiguration grpc::testing::XdsEnd2endTest::default_route_config_

protected

Definition at line 1056 of file xds_end2end_test_lib.h.

◆ default_server_listener_

Listener grpc::testing::XdsEnd2endTest::default_server_listener_

protected

Definition at line 1057 of file xds_end2end_test_lib.h.

◆ default_server_route_config_

RouteConfiguration grpc::testing::XdsEnd2endTest::default_server_route_config_

protected

Definition at line 1058 of file xds_end2end_test_lib.h.

◆ ipv6_only_

bool grpc::testing::XdsEnd2endTest::ipv6_only_ = false

protected

Definition at line 1043 of file xds_end2end_test_lib.h.

◆ kCaCertPath

const char grpc::testing::XdsEnd2endTest::kCaCertPath = "src/core/tsi/test_creds/ca.pem"

staticprotected

Definition at line 207 of file xds_end2end_test_lib.h.

◆ kDefaultClusterName

const char grpc::testing::XdsEnd2endTest::kDefaultClusterName = "cluster_name"

staticprotected

Definition at line 202 of file xds_end2end_test_lib.h.

◆ kDefaultEdsServiceName

const char grpc::testing::XdsEnd2endTest::kDefaultEdsServiceName = "eds_service_name"

staticprotected

Definition at line 203 of file xds_end2end_test_lib.h.

◆ kDefaultLocalityPriority

const int grpc::testing::XdsEnd2endTest::kDefaultLocalityPriority = 0

staticprotected

Definition at line 197 of file xds_end2end_test_lib.h.

◆ kDefaultLocalityRegion

const char grpc::testing::XdsEnd2endTest::kDefaultLocalityRegion

staticprotected

Initial value:

=

"xds_default_locality_region"

Definition at line 194 of file xds_end2end_test_lib.h.

◆ kDefaultLocalityWeight

const int grpc::testing::XdsEnd2endTest::kDefaultLocalityWeight = 3

staticprotected

Definition at line 196 of file xds_end2end_test_lib.h.

◆ kDefaultLocalityZone

const char grpc::testing::XdsEnd2endTest::kDefaultLocalityZone = "xds_default_locality_zone"

staticprotected

Definition at line 195 of file xds_end2end_test_lib.h.

◆ kDefaultRouteConfigurationName

const char grpc::testing::XdsEnd2endTest::kDefaultRouteConfigurationName

staticprotected

Initial value:

=

"route_config_name"

Definition at line 201 of file xds_end2end_test_lib.h.

◆ kDefaultServerRouteConfigurationName

const char grpc::testing::XdsEnd2endTest::kDefaultServerRouteConfigurationName

staticprotected

Initial value:

=

"default_server_route_config_name"

Definition at line 204 of file xds_end2end_test_lib.h.

◆ kRequestMessage

const char grpc::testing::XdsEnd2endTest::kRequestMessage = "Live long and prosper."

staticprotected

Definition at line 212 of file xds_end2end_test_lib.h.

◆ kServerCertPath

const char grpc::testing::XdsEnd2endTest::kServerCertPath

staticprotected

Initial value:

=

"src/core/tsi/test_creds/server1.pem"

Definition at line 208 of file xds_end2end_test_lib.h.

◆ kServerKeyPath

const char grpc::testing::XdsEnd2endTest::kServerKeyPath

staticprotected

Initial value:

=

"src/core/tsi/test_creds/server1.key"

Definition at line 209 of file xds_end2end_test_lib.h.

◆ kServerName

const char grpc::testing::XdsEnd2endTest::kServerName = "server.example.com"

staticprotected

Definition at line 200 of file xds_end2end_test_lib.h.

◆ stub1_

std::unique_ptr<grpc::testing::EchoTest1Service::Stub> grpc::testing::XdsEnd2endTest::stub1_

protected

Definition at line 1049 of file xds_end2end_test_lib.h.

◆ stub2_

std::unique_ptr<grpc::testing::EchoTest2Service::Stub> grpc::testing::XdsEnd2endTest::stub2_

protected

Definition at line 1050 of file xds_end2end_test_lib.h.

◆ stub_

std::unique_ptr<grpc::testing::EchoTestService::Stub> grpc::testing::XdsEnd2endTest::stub_

protected

Definition at line 1048 of file xds_end2end_test_lib.h.

◆ xds_channel_args_

grpc_channel_args grpc::testing::XdsEnd2endTest::xds_channel_args_

protected

Definition at line 1067 of file xds_end2end_test_lib.h.

◆ xds_channel_args_to_add_

absl::InlinedVector<grpc_arg, 3> grpc::testing::XdsEnd2endTest::xds_channel_args_to_add_

protected

Definition at line 1066 of file xds_end2end_test_lib.h.

◆ xds_drain_grace_time_ms_

int grpc::testing::XdsEnd2endTest::xds_drain_grace_time_ms_ = 10 * 60 * 1000

protected

Definition at line 1061 of file xds_end2end_test_lib.h.

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

Classes

Protected Types

Protected Member Functions

Static Protected Member Functions

Protected Attributes

Static Protected Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ Cluster

◆ ClusterLoadAssignment

◆ HttpConnectionManager

◆ Listener

◆ RouteConfiguration

Member Enumeration Documentation

◆ RpcMethod

◆ RpcService

Constructor & Destructor Documentation

◆ XdsEnd2endTest()

Member Function Documentation

◆ BuildEdsResource()

◆ CheckRpcSendFailure()

◆ CheckRpcSendOk()

◆ ComputeIdealNumRpcs()

◆ CreateAndStartBackends()

◆ CreateAndStartBalancer()

◆ CreateBackends()

◆ CreateChannel()

◆ CreateEndpoint()

◆ CreateEndpointsForBackends()

◆ CreateTlsFallbackCredentials()

◆ GetBackendPorts()

◆ GetServerListenerName()

◆ InitClient()

◆ MakeNonExistantEndpoint()

◆ NowFromCycleCounter()

◆ PopulateServerListenerNameAndPort()

◆ ReadFile()

◆ ReadTlsIdentityPair()

◆ ResetBackendCounters()

◆ ResetStub()

◆ RouteConfigurationResponseState()

◆ SeenAllBackends()

◆ SeenBackend()

◆ SendConcurrentRpcs()

◆ SendRpc()

◆ SendRpcMethod()

◆ SendRpcsAndCountFailuresWithMessage()

◆ SendRpcsUntil()

◆ SetListenerAndRouteConfiguration()

◆ SetRouteConfiguration()

◆ SetServerListenerNameAndRouteConfiguration()

◆ SetUp()

◆ ShutdownAllBackends()

◆ ShutdownBackend()

◆ StartAllBackends()

◆ StartBackend()

◆ TearDown()

◆ WaitForAllBackends()

◆ WaitForBackend()

◆ WaitForCdsNack()

◆ WaitForEdsNack()

◆ WaitForLdsNack()

◆ WaitForNack()

◆ WaitForRdsNack()

◆ WaitForRouteConfigNack()

Member Data Documentation

◆ backends_

◆ balancer_

◆ bootstrap_

◆ bootstrap_contents_from_env_var_

◆ bootstrap_file_

◆ channel_

◆ default_cluster_

◆ default_listener_

◆ default_route_config_

◆ default_server_listener_

◆ default_server_route_config_

◆ ipv6_only_

◆ kCaCertPath