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.