pulsar.client.test package

Submodules

pulsar.client.test.check module

Script used to run an example job against a running Pulsar server.

Exercises various features both the Pulsar client and server.

class pulsar.client.test.check.ClientInfo(client, client_manager)

Bases: tuple

client

Alias for field number 0

client_manager

Alias for field number 1

class pulsar.client.test.check.MockTool(tool_dir)

Bases: object

class pulsar.client.test.check.TestRequiredFilesObject

Bases: object

find_required_files(tool_directory)

class pulsar.client.test.check.Waiter(client, client_manager)

Bases: object

shutdown()

wait(seconds=120)

pulsar.client.test.check.client_info(options, client_options, job_id=None)

From command-line arguments options - extract options related to build a client manager and build it. Then get a client with supplied client options and optional job id.

pulsar.client.test.check.client_manager_from_args(options)

pulsar.client.test.check.extract_client_options(options)

Exract options explicitly related to build client from configured client manager.

pulsar.client.test.check.main(argv=None)

Exercises a running Pulsar with the Pulsar client.

pulsar.client.test.check.run(options)

pulsar.client.test.test_common module

For code shared between test_utils.py and check.py. Not sure this is the best place - but check needs to not depend on test_utils so run_client_tests can execute without webob dependency.

pulsar.client.test.test_common.write_config(has_temp_directory, data, name='config.json')

Module contents