Public Member Functions | |
def | __init__ (self, *str ip, int rpc_port, Optional[int] maintenance_port=None, Optional[bool] secure_mode=False, Optional[str] server_id=None, Optional[str] xds_host=None, Optional[int] xds_port=None, Optional[str] rpc_host=None, Optional[str] pod_name=None) |
_ChannelzServiceClient | channelz (self) |
def | get_server_socket_matching_client (self, grpc_channelz.Socket client_socket) |
grpc_channelz.Server | get_test_server (self) |
Iterator[grpc_channelz.Socket] | get_test_server_sockets (self) |
_HealthClient | health_client (self) |
def | set_not_serving (self) |
def | set_serving (self) |
def | set_xds_address (self, xds_host, Optional[int] xds_port=None) |
_XdsUpdateHealthServiceClient | update_health_service_client (self) |
str | xds_address (self) |
str | xds_uri (self) |
![]() | |
def | __del__ (self) |
def | __enter__ (self) |
def | __exit__ (self, exc_type, exc_val, exc_tb) |
def | __init__ (self, rpc_host) |
def | close (self) |
Public Attributes | |
ip | |
maintenance_port | |
pod_name | |
rpc_port | |
secure_mode | |
server_id | |
xds_port | |
![]() | |
channels | |
rpc_host | |
Represents RPC services implemented in Server component of the xDS test app. https://github.com/grpc/grpc/blob/master/doc/xds-test-descriptions.md#server
Definition at line 39 of file server_app.py.
def framework.test_app.server_app.XdsTestServer.__init__ | ( | self, | |
*str | ip, | ||
int | rpc_port, | ||
Optional[int] | maintenance_port = None , |
||
Optional[bool] | secure_mode = False , |
||
Optional[str] | server_id = None , |
||
Optional[str] | xds_host = None , |
||
Optional[int] | xds_port = None , |
||
Optional[str] | rpc_host = None , |
||
Optional[str] | pod_name = None |
||
) |
Definition at line 45 of file server_app.py.
_ChannelzServiceClient framework.test_app.server_app.XdsTestServer.channelz | ( | self | ) |
Definition at line 67 of file server_app.py.
def framework.test_app.server_app.XdsTestServer.get_server_socket_matching_client | ( | self, | |
grpc_channelz.Socket | client_socket | ||
) |
Find test server socket that matches given test client socket. Sockets are matched using TCP endpoints (ip:port), further on "address". Server socket remote address matched with client socket local address. Raises: GrpcApp.NotFound: Server socket matching client socket not found.
Definition at line 129 of file server_app.py.
grpc_channelz.Server framework.test_app.server_app.XdsTestServer.get_test_server | ( | self | ) |
Return channelz representation of a server running TestService. Raises: GrpcApp.NotFound: Test server not found.
Definition at line 108 of file server_app.py.
Iterator[grpc_channelz.Socket] framework.test_app.server_app.XdsTestServer.get_test_server_sockets | ( | self | ) |
List all sockets of the test server. Raises: GrpcApp.NotFound: Test server not found.
Definition at line 120 of file server_app.py.
_HealthClient framework.test_app.server_app.XdsTestServer.health_client | ( | self | ) |
Definition at line 78 of file server_app.py.
def framework.test_app.server_app.XdsTestServer.set_not_serving | ( | self | ) |
Definition at line 86 of file server_app.py.
def framework.test_app.server_app.XdsTestServer.set_serving | ( | self | ) |
Definition at line 81 of file server_app.py.
def framework.test_app.server_app.XdsTestServer.set_xds_address | ( | self, | |
xds_host, | |||
Optional[int] | xds_port = None |
||
) |
Definition at line 91 of file server_app.py.
_XdsUpdateHealthServiceClient framework.test_app.server_app.XdsTestServer.update_health_service_client | ( | self | ) |
Definition at line 72 of file server_app.py.
str framework.test_app.server_app.XdsTestServer.xds_address | ( | self | ) |
Definition at line 95 of file server_app.py.
str framework.test_app.server_app.XdsTestServer.xds_uri | ( | self | ) |
Definition at line 103 of file server_app.py.
framework.test_app.server_app.XdsTestServer.ip |
Definition at line 47 of file server_app.py.
framework.test_app.server_app.XdsTestServer.maintenance_port |
Definition at line 49 of file server_app.py.
framework.test_app.server_app.XdsTestServer.pod_name |
Definition at line 53 of file server_app.py.
framework.test_app.server_app.XdsTestServer.rpc_port |
Definition at line 48 of file server_app.py.
framework.test_app.server_app.XdsTestServer.secure_mode |
Definition at line 50 of file server_app.py.
framework.test_app.server_app.XdsTestServer.server_id |
Definition at line 51 of file server_app.py.
framework.test_app.server_app.XdsTestServer.xds_port |
Definition at line 52 of file server_app.py.