Classes | |
| class | CallMaker |
Functions | |
| def | _calculate_primes (server_address) |
| def | _initialize_worker (server_address) |
| def | _run_worker_query (primality_candidate) |
| def | _shutdown_worker () |
| def | bidirectional_streaming_method (stub) |
| def | client_streaming_method (stub) |
| def | main () |
| def | process (stub) |
| None | process_call (ThreadPoolExecutor executor, grpc.Channel channel, str phone_number) |
| def | run () |
| def | run (server_address, secure) |
| def | run_client (channel_compression, call_compression, target) |
| def | run_streaming_client (server_target, name, ideal_distance, interesting_distance) |
| def | run_unary_client (server_target, name, ideal_distance) |
| def | server_streaming_method (stub) |
| def | simple_method (stub) |
Variables | |
| list | __all__ |
| dictionary | _COMPRESSION_OPTIONS |
| string | _DESCRIPTION = "A client for finding hashes similar to names." |
| _LOGGER = logging.getLogger(__name__) | |
| int | _MAXIMUM_CANDIDATE = 10000 |
| int | _PROCESS_COUNT = 8 |
| _worker_channel_singleton = None | |
| _worker_stub_singleton = None | |
| action | |
| args = parser.parse_args() | |
| int | CLIENT_ID = 1 |
| default | |
| formatter = logging.Formatter('[PID %(process)d] %(message)s') | |
| handler = logging.StreamHandler(sys.stdout) | |
| help | |
| level | |
| parser = argparse.ArgumentParser(description=_DESCRIPTION) | |
| string | SERVER_ADDRESS = "localhost:23333" |
|
private |
Definition at line 65 of file examples/python/multiprocessing/client.py.
|
private |
Definition at line 49 of file examples/python/multiprocessing/client.py.
|
private |
Definition at line 59 of file examples/python/multiprocessing/client.py.
|
private |
Definition at line 43 of file examples/python/multiprocessing/client.py.
| def client.bidirectional_streaming_method | ( | stub | ) |
Definition at line 88 of file examples/python/data_transmission/client.py.
| def client.client_streaming_method | ( | stub | ) |
Definition at line 52 of file examples/python/data_transmission/client.py.
| def client.main | ( | ) |
Definition at line 69 of file examples/python/cancellation/client.py.
| def client.process | ( | stub | ) |
Definition at line 30 of file examples/python/errors/client.py.
| None client.process_call | ( | ThreadPoolExecutor | executor, |
| grpc.Channel | channel, | ||
| str | phone_number | ||
| ) |
Definition at line 98 of file examples/python/async_streaming/client.py.
| def client.run | ( | ) |
Definition at line 109 of file examples/python/async_streaming/client.py.
| def client.run | ( | server_address, | |
| secure | |||
| ) |
Definition at line 29 of file examples/python/xds/client.py.
| def client.run_client | ( | channel_compression, | |
| call_compression, | |||
| target | |||
| ) |
Definition at line 38 of file examples/python/compression/client.py.
| def client.run_streaming_client | ( | server_target, | |
| name, | |||
| ideal_distance, | |||
| interesting_distance | |||
| ) |
Definition at line 50 of file examples/python/cancellation/client.py.
| def client.run_unary_client | ( | server_target, | |
| name, | |||
| ideal_distance | |||
| ) |
Definition at line 34 of file examples/python/cancellation/client.py.
| def client.server_streaming_method | ( | stub | ) |
Definition at line 73 of file examples/python/data_transmission/client.py.
| def client.simple_method | ( | stub | ) |
Definition at line 39 of file examples/python/data_transmission/client.py.
|
private |
Definition at line 23 of file examples/python/data_transmission/client.py.
|
private |
Definition at line 29 of file examples/python/compression/client.py.
Definition at line 30 of file examples/python/cancellation/client.py.
|
private |
Definition at line 31 of file examples/python/cancellation/client.py.
|
private |
Definition at line 32 of file examples/python/multiprocessing/client.py.
|
private |
Definition at line 31 of file examples/python/multiprocessing/client.py.
|
private |
Definition at line 37 of file examples/python/multiprocessing/client.py.
|
private |
Definition at line 38 of file examples/python/multiprocessing/client.py.
| client.action |
Definition at line 49 of file examples/python/xds/client.py.
| client.args = parser.parse_args() |
Definition at line 51 of file examples/python/xds/client.py.
| int client.CLIENT_ID = 1 |
Definition at line 29 of file examples/python/data_transmission/client.py.
| client.default |
Definition at line 45 of file examples/python/xds/client.py.
Definition at line 88 of file examples/python/multiprocessing/client.py.
| client.handler = logging.StreamHandler(sys.stdout) |
Definition at line 87 of file examples/python/multiprocessing/client.py.
| client.help |
Definition at line 46 of file examples/python/xds/client.py.
| client.level |
Definition at line 118 of file examples/python/async_streaming/client.py.
| client.parser = argparse.ArgumentParser(description=_DESCRIPTION) |
Definition at line 43 of file examples/python/xds/client.py.
| string client.SERVER_ADDRESS = "localhost:23333" |
Definition at line 28 of file examples/python/data_transmission/client.py.