Classes
class	DemoServer

class	Greeter

class	HashFinder

class	LimitedGreeter

class	Phone

class	PrimeChecker

Functions
None	_configure_greeter_server (grpc.Server server, int port, bool secure_mode, hostname)

None	_configure_maintenance_server (grpc.Server server, int maintenance_port)

def	_reserve_port ()

def	_run_server (bind_address)

def	_running_server (port, maximum_hashes)

def	_start_async_server ()

def	_wait_forever (server)

def	create_greet_limit_exceed_error_status (name)

def	create_server (server_address)

phone_pb2.StreamCallResponse	create_state_response (phone_pb2.CallState.State call_state)

def	is_prime (n)

def	main ()

def	run_server (server_compression, no_compress_every_n, port)

None	serve (int port, str hostname, int maintenance_port, bool secure_mode)

def	serve (server)

None	serve (str address)

Variables
string	__all__ = 'DemoServer'

dictionary	_COMPRESSION_OPTIONS

string	_DESCRIPTION = "A server for finding hashes similar to names."

string	_LISTEN_HOST = "0.0.0.0"

	_LOGGER = logging.getLogger(__name__)

	_ONE_DAY = datetime.timedelta(days=1)

	_PROCESS_COUNT = multiprocessing.cpu_count()

string	_SERVER_HOST = 'localhost'

	_THREAD_CONCURRENCY = _PROCESS_COUNT

int	_THREAD_POOL_SIZE = 256

	action

	args = parser.parse_args()

	console_handler = logging.StreamHandler()

	default

	formatter = logging.Formatter('[PID %(process)d] %(message)s')

	handler = logging.StreamHandler(sys.stdout)

	help

	level

	logger = logging.getLogger()

	nargs

	parser = argparse.ArgumentParser(description=_DESCRIPTION)

	port = server.add_insecure_port('localhost:%s' % 50051)

	server = aio.server()

string	SERVER_ADDRESS = 'localhost:23333'

int	SERVER_ID = 1

	servicer = benchmark_servicer.BenchmarkServicer()

	type

Function Documentation

◆ _configure_greeter_server()

None server._configure_greeter_server	(	grpc.Server	server,
		int	port,
		bool	secure_mode,
			hostname
	)

private

Definition at line 78 of file examples/python/xds/server.py.

◆ _configure_maintenance_server()

None server._configure_maintenance_server	(	grpc.Server	server,
		int	maintenance_port
	)

private

Definition at line 53 of file examples/python/xds/server.py.

◆ _reserve_port()

def server._reserve_port ( )

private

Find and reserve a port for all subprocesses to use.

Definition at line 79 of file examples/python/multiprocessing/server.py.

◆ _run_server()

def server._run_server ( bind_address )

private

Start a server in a subprocess.

Definition at line 64 of file examples/python/multiprocessing/server.py.

◆ _running_server()

def server._running_server	(	port,
		maximum_hashes
	)

private

Definition at line 88 of file examples/python/cancellation/server.py.

◆ _start_async_server()

def server._start_async_server ( )

private

Definition at line 25 of file src/python/grpcio_tests/tests_aio/benchmark/server.py.

◆ _wait_forever()

def server._wait_forever ( server )

private

Definition at line 56 of file examples/python/multiprocessing/server.py.

◆ create_greet_limit_exceed_error_status()

def server.create_greet_limit_exceed_error_status ( name )

Definition at line 31 of file examples/python/errors/server.py.

◆ create_server()

def server.create_server ( server_address )

Definition at line 64 of file examples/python/errors/server.py.

◆ create_state_response()

phone_pb2.StreamCallResponse server.create_state_response ( phone_pb2.CallState.State call_state )

Definition at line 28 of file examples/python/async_streaming/server.py.

◆ is_prime()

def server.is_prime ( n )

Definition at line 41 of file examples/python/multiprocessing/server.py.

◆ main()

def server.main ( )

Definition at line 103 of file examples/python/cancellation/server.py.

◆ run_server()

def server.run_server	(	server_compression,
		no_compress_every_n,
		port
	)

Definition at line 63 of file examples/python/compression/server.py.

◆ serve() [1/3]

None server.serve	(	int	port,
		str	hostname,
		int	maintenance_port,
		bool	secure_mode
	)

Definition at line 95 of file examples/python/xds/server.py.

◆ serve() [2/3]

def server.serve ( server )

Definition at line 71 of file examples/python/errors/server.py.

◆ serve() [3/3]

None server.serve ( str address )

Definition at line 81 of file examples/python/async_streaming/server.py.

Variable Documentation

◆ all

string server.__all__ = 'DemoServer'

private

Definition at line 24 of file examples/python/data_transmission/server.py.

◆ _COMPRESSION_OPTIONS

dictionary server._COMPRESSION_OPTIONS

private

Initial value:

 =  {
     "none": grpc.Compression.NoCompression,
     "deflate": grpc.Compression.Deflate,
     "gzip": grpc.Compression.Gzip,
 }

Definition at line 31 of file examples/python/compression/server.py.

◆ _DESCRIPTION

string server._DESCRIPTION = "A server for finding hashes similar to names."

private

Definition at line 34 of file examples/python/cancellation/server.py.

◆ _LISTEN_HOST

string server._LISTEN_HOST = "0.0.0.0"

private

Definition at line 31 of file examples/python/xds/server.py.

◆ _LOGGER

server._LOGGER = logging.getLogger(__name__)

private

Definition at line 31 of file examples/python/cancellation/server.py.

◆ _ONE_DAY

server._ONE_DAY = datetime.timedelta(days=1)

private

Definition at line 36 of file examples/python/multiprocessing/server.py.

◆ _PROCESS_COUNT

server._PROCESS_COUNT = multiprocessing.cpu_count()

private

Definition at line 37 of file examples/python/multiprocessing/server.py.

◆ _SERVER_HOST

string server._SERVER_HOST = 'localhost'

private

Definition at line 32 of file examples/python/cancellation/server.py.

◆ _THREAD_CONCURRENCY

server._THREAD_CONCURRENCY = _PROCESS_COUNT

private

Definition at line 38 of file examples/python/multiprocessing/server.py.

◆ _THREAD_POOL_SIZE

int server._THREAD_POOL_SIZE = 256

private

Definition at line 33 of file examples/python/xds/server.py.

◆ action

server.action

Definition at line 138 of file examples/python/xds/server.py.

◆ args

server.args = parser.parse_args()

Definition at line 140 of file examples/python/xds/server.py.

◆ console_handler

server.console_handler = logging.StreamHandler()

Definition at line 36 of file examples/python/xds/server.py.

◆ default

server.default

Definition at line 127 of file examples/python/xds/server.py.

◆ formatter

server.formatter = logging.Formatter('[PID %(process)d] %(message)s')

Definition at line 112 of file examples/python/multiprocessing/server.py.

◆ handler

server.handler = logging.StreamHandler(sys.stdout)

Definition at line 111 of file examples/python/multiprocessing/server.py.

◆ help

server.help

Definition at line 130 of file examples/python/xds/server.py.

◆ level

server.level

Definition at line 91 of file examples/python/async_streaming/server.py.

◆ logger

server.logger = logging.getLogger()

Definition at line 35 of file examples/python/xds/server.py.

◆ nargs

server.nargs

Definition at line 129 of file examples/python/xds/server.py.

◆ parser

server.parser = argparse.ArgumentParser(description=_DESCRIPTION)

Definition at line 125 of file examples/python/xds/server.py.

◆ port

server.port = server.add_insecure_port('localhost:%s' % 50051)

Definition at line 28 of file src/python/grpcio_tests/tests_aio/benchmark/server.py.

◆ server

server.server = aio.server()

Definition at line 26 of file src/python/grpcio_tests/tests_aio/benchmark/server.py.

◆ SERVER_ADDRESS

string server.SERVER_ADDRESS = 'localhost:23333'

Definition at line 25 of file examples/python/data_transmission/server.py.

◆ SERVER_ID

int server.SERVER_ID = 1

Definition at line 26 of file examples/python/data_transmission/server.py.

◆ servicer

server.servicer = benchmark_servicer.BenchmarkServicer()

Definition at line 29 of file src/python/grpcio_tests/tests_aio/benchmark/server.py.

◆ type

server.type

Definition at line 128 of file examples/python/xds/server.py.

Classes

Functions

Variables

Function Documentation

◆ _configure_greeter_server()

◆ _configure_maintenance_server()

◆ _reserve_port()

◆ _run_server()

◆ _running_server()

◆ _start_async_server()

◆ _wait_forever()

◆ create_greet_limit_exceed_error_status()

◆ create_server()

◆ create_state_response()

◆ is_prime()

◆ main()

◆ run_server()

◆ serve() [1/3]

◆ serve() [2/3]

◆ serve() [3/3]

Variable Documentation

◆ __all__

◆ _COMPRESSION_OPTIONS

◆ _DESCRIPTION

◆ _LISTEN_HOST

◆ _LOGGER

◆ _ONE_DAY

◆ _PROCESS_COUNT

◆ _SERVER_HOST

◆ _THREAD_CONCURRENCY

◆ _THREAD_POOL_SIZE

◆ action

◆ args

◆ console_handler

◆ default

◆ formatter

◆ handler

◆ help

◆ level

◆ logger

◆ nargs

◆ parser

◆ port

◆ server

◆ SERVER_ADDRESS

◆ SERVER_ID

◆ servicer

◆ type

◆ all