tests.qps.benchmark_client.BenchmarkClient Class Reference

Inheritance diagram for tests.qps.benchmark_client.BenchmarkClient:

Public Member Functions
def	__init__ (self, server, config, hist)
def	add_response_callback (self, callback)
def	send_request (self)
def	start (self)
def	stop (self)

Private Member Functions
def	_handle_response (self, client, query_time)

Private Attributes
	_generic
	_hist
	_request
	_response_callbacks
	_stub

Static Private Attributes
	__metaclass__ = abc.ABCMeta

Detailed Description

Benchmark client interface that exposes a non-blocking send_request().

Definition at line 43 of file qps/benchmark_client.py.

Constructor & Destructor Documentation

__init__()

def tests.qps.benchmark_client.BenchmarkClient.__init__	(		self,
			server,
			config,
			hist
	)

Reimplemented in tests.qps.benchmark_client.ServerStreamingSyncBenchmarkClient, tests.qps.benchmark_client.StreamingSyncBenchmarkClient, and tests.qps.benchmark_client.UnarySyncBenchmarkClient.

Definition at line 48 of file qps/benchmark_client.py.

Member Function Documentation

_handle_response()

def tests.qps.benchmark_client.BenchmarkClient._handle_response (   self,   client,   query_time  )

private

Definition at line 95 of file qps/benchmark_client.py.

add_response_callback()

def tests.qps.benchmark_client.BenchmarkClient.add_response_callback	(		self,
			callback
	)

callback will be invoked as callback(client, query_time)

Definition at line 80 of file qps/benchmark_client.py.

send_request()

def tests.qps.benchmark_client.BenchmarkClient.send_request

(

self

)

Non-blocking wrapper for a client's request operation.

Reimplemented in tests.qps.benchmark_client.ServerStreamingSyncBenchmarkClient, tests.qps.benchmark_client.StreamingSyncBenchmarkClient, tests.qps.benchmark_client.UnaryAsyncBenchmarkClient, and tests.qps.benchmark_client.UnarySyncBenchmarkClient.

Definition at line 85 of file qps/benchmark_client.py.

start()

def tests.qps.benchmark_client.BenchmarkClient.start

(

self

)

Reimplemented in tests.qps.benchmark_client.StreamingSyncBenchmarkClient.

Definition at line 89 of file qps/benchmark_client.py.

stop()

def tests.qps.benchmark_client.BenchmarkClient.stop

(

self

)

Reimplemented in tests.qps.benchmark_client.ServerStreamingSyncBenchmarkClient, tests.qps.benchmark_client.StreamingSyncBenchmarkClient, tests.qps.benchmark_client.UnaryAsyncBenchmarkClient, and tests.qps.benchmark_client.UnarySyncBenchmarkClient.

Definition at line 92 of file qps/benchmark_client.py.

Member Data Documentation

__metaclass__

tests.qps.benchmark_client.BenchmarkClient.__metaclass__ = abc.ABCMeta

staticprivate

Definition at line 46 of file qps/benchmark_client.py.

_generic

tests.qps.benchmark_client.BenchmarkClient._generic

private

Definition at line 62 of file qps/benchmark_client.py.

_hist

tests.qps.benchmark_client.BenchmarkClient._hist

private

Definition at line 77 of file qps/benchmark_client.py.

_request

tests.qps.benchmark_client.BenchmarkClient._request

private

Definition at line 68 of file qps/benchmark_client.py.

_response_callbacks

tests.qps.benchmark_client.BenchmarkClient._response_callbacks

private

Definition at line 78 of file qps/benchmark_client.py.

_stub

tests.qps.benchmark_client.BenchmarkClient._stub

private

Definition at line 63 of file qps/benchmark_client.py.

---

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

• qps/benchmark_client.py