/3.0.3-GA/testrunner/lib/membase/api/ |
H A D | exception.py | 16 def __init__(self): member in MembaseHttpException 23 def __init__(self, message, type, parameters): member in MembaseHttpException 38 def __init__(self, username='', password=''): member in UnauthorizedException 47 def __init__(self, ip='', bucket_name=''): member in BucketCreationException 57 def __init__(self): member in StatsUnavailableException 63 def __init__(self, ip=''): member in ServerUnavailableException 71 def __init__(self, api, parameters): member in InvalidArgumentException 79 def __init__(self, nodeIp='', remoteIp=''): member in ServerSelfJoinException 89 def __init__(self, nodeIp='', remoteIp=''): member in ClusterRemoteException 99 def __init__(sel member in ServerAlreadyJoinedException 108 def __init__(self, string=''): global() member in SetRecoveryTypeFailed 112 def __init__(self, string=''): global() member in RebalanceFailedException 116 def __init__(self, string=''): global() member in FailoverFailedException 121 def __init__(self, design_doc_name, reason=''): global() member in DesignDocCreationException 125 def __init__(self, view_name, reason='', status=0): global() member in QueryViewException 132 def __init__(self, doc_id, reason=''): global() member in ReadDocumentException 136 def __init__(self, design_doc_name, reason=''): global() member in CompactViewFailed 141 def __init__(self, design_doc_name, reason=''): global() member in SetViewInfoNotFound 147 def __init__(self, bucket, reason=''): global() member in GetBucketInfoFailed 152 def __init__(self, nodeIp='', remoteIp='', reason=''): global() member in AddNodeException 160 def __init__(self, ip='', bucket_name=''): global() member in BucketFlushFailed 167 def __init__(self, msg='', ip=''): global() member in CBQError 177 def __init__(self, string=''): global() member in CBRecoveryFailedException 182 def __init__(self, string=''): global() member in XDCRException 186 def __init__(self, string=''): global() member in XDCRCheckpointException 190 def __init__(self, bucket_name=''): global() member in BucketCompactionException [all...] |
/3.0.3-GA/couchbase-python-client/couchbase/ |
H A D | exception.py | 31 def __init__(self, item, timeout): member in MemcachedTimeoutException 45 def __init__(self, message='', errorType='', parameters=dict()): member in CouchbaseHttpException 60 def __init__(self, username='', password=''): member in UnauthorizedException 69 def __init__(self, ip='', bucket_name='', error=''): member in BucketCreationException 81 def __init__(self, ip='', bucket_name='', error=''): member in BucketUnavailableException 93 def __init__(self): member in StatsUnavailableException 99 def __init__(self, ip=''): member in ServerUnavailableException 107 def __init__(self, api, parameters): member in InvalidArgumentException 115 def __init__(self, nodeIp='', remoteIp=''): member in ServerJoinException 125 def __init__(sel member in ServerAlreadyJoinedException [all...] |
/3.0.3-GA/testrunner/lib/ |
H A D | dcp_bin_client.py | 14 def __init__(self, host='127.0.0.1', port=11210, timeout=1): member in DcpClient 15 super(DcpClient, self).__init__(host, port, timeout) 229 def __init__(self, generator, vbucket): member in DcpStream 307 def __init__(self, opcode, key='', value='', member in Operation 325 def __init__(self, name, flag): member in Open 329 Operation.__init__(self, opcode, key, extras = extras) 333 def __init__(self, name): member in OpenConsumer 334 Open.__init__(self, name, FLAG_OPEN_CONSUMER) 338 def __init__(self, name): member in OpenProducer 339 Open.__init__(sel 343 def __init__(self, name): global() member in OpenNotifier 349 def __init__(self, vbucket, takeover = 0): global() member in CloseStream 363 def __init__(self, vbucket, takeover = 0): global() member in AddStream 381 def __init__(self, vbucket, takeover, start_seqno, end_seqno, global() member in StreamRequest 496 def __init__(self, vbucket): global() member in GetFailoverLog 522 def __init__(self, buffer_size): global() member in FlowControl 537 def __init__(self, nbytes): global() member in Ack 552 def __init__(self): global() member in Quit [all...] |
H A D | tap.py | 25 def __init__(self, server, port, callback, clientId=None, opts={}, user=None, pswd=None): member in TapConnection 26 mc_bin_server.MemcachedBinaryChannel.__init__(self, None, None, 104 def __init__(self, servers, callback, opts={}, user=None, pswd=None): member in TapClient 112 def __init__(self, s): member in TapDescriptor
|
H A D | xunit.py | 20 def __init__(self): member in XUnitTestCase 29 def __init__(self): member in XUnitTestCaseError 44 def __init__(self): member in XUnitTestResult 122 def __init__(self): member in XUnitTestSuite
|
/3.0.3-GA/testrunner/lib/old_tasks/ |
H A D | task.py | 21 def __init__(self, name): member in Task 54 def __init__(self, server): member in NodeInitializeTask 55 Task.__init__(self, "node_init_task") 90 def __init__(self, server, bucket='default', replicas=1, port=11210, size=0, password=None): member in BucketCreateTask 91 Task.__init__(self, "bucket_create_task") 152 def __init__(self, server, bucket="default"): member in BucketDeleteTask 153 Task.__init__(self, "bucket_delete_task") 199 def __init__(self, servers, to_add=[], to_remove=[], do_stop=False, progress=30): member in RebalanceTask 200 Task.__init__(self, "rebalance_task") 308 def __init__(sel member in FailOverTask 364 def __init__(self, rest, bucket, kv_store=None, store_enabled=True, info=None): global() member in GenericLoadingTask 425 def __init__(self, rest, doc_generators, bucket="default", kv_store=None, global() member in LoadDocGeneratorTask 457 def __init__(self, rest, doc_ids, bucket="default", global() member in DocumentAccessTask 479 def __init__(self, rest, doc_ids, bucket="default", info=None, global() member in DocumentExpireTask 507 def __init__(self, rest, doc_ids, bucket="default", info=None, global() member in DocumentDeleteTask 525 def __init__(self, rest, kv_store, bucket="default"): global() member in KVStoreIntegrityTask [all...] |
/3.0.3-GA/testrunner/lib/couchbase_helper/ |
H A D | documentgenerator.py | 6 def __init__(self, name, start, end): member in KVGenerator 30 def __init__(self, name, template, *args, **kwargs): member in DocumentGenerator 56 KVGenerator.__init__(self, name, 0, size) 86 def __init__(self, name, seed, value_size, start=0, end=10000): member in BlobGenerator 87 KVGenerator.__init__(self, name, start, end) 109 def __init__(self, document_generator, batch_size_int=100): member in BatchedDocumentGenerator 131 def __init__(self, name, values, start=0, end=10000): member in JSONNonDocGenerator 132 KVGenerator.__init__(self, name, start, end) 149 def __init__(self, name, values, start=0, end=10000): member in Base64Generator 150 KVGenerator.__init__(sel [all...] |
/3.0.3-GA/couchbase-cli/ |
H A D | cbqueue.py | 8 def __init__(self, maxsize=0): member in PumpQueue 9 Queue.__init__(self, maxsize) 12 def __init__(self, maxsize=0): member in PumpQueue 13 Queue.__init__(self, maxsize)
|
H A D | cbcollections.py | 6 def __init__(self, default_factory=None, **kwargs): member in defaultdict 8 super(defaultdict, self).__init__(**kwargs)
|
/3.0.3-GA/healthchecker/Cheetah/ |
H A D | DummyTransaction.py | 23 def __init__(self): member in DummyResponse 77 def __init__(self, *args, **kwargs): member in DummyTransaction 87 def __init__(self, *args, **kwargs): member in TransformerResponse 88 super(TransformerResponse, self).__init__(*args, **kwargs) 102 def __init__(self, *args, **kwargs): member in TransformerTransaction
|
H A D | ErrorCatchers.py | 23 def __init__(self, templateObj): member in ErrorCatcher 46 def __init__(self, templateObj): member in ListErrors 47 ErrorCatcher.__init__(self, templateObj)
|
/3.0.3-GA/couchbase-python-client/couchbase/migrator/ |
H A D | migrator_zip.py | 34 def __init__(self, source): member in ZipReader 42 DirReader.__init__(self, self.tempdir) 50 def __init__(self, destination): member in ZipWriter 58 DirWriter.__init__(self, self.tempdir)
|
H A D | migrator.py | 20 def __init__(self, fp): member in Reader 34 def __init__(self, fp): member in Writer
|
H A D | migrator_json.py | 27 def __init__(self, source): member in JSONReader 52 def __init__(self, destination): member in JSONWriter
|
/3.0.3-GA/testrunner/lib/remote/ |
H A D | Installer.py | 59 def __init__(self): member in MembaseInstallationException 66 def __init__(self, message, type, parameters): member in MembaseInstallationException 80 def __init__(self, username='', password=''): member in UnauthorizedException 89 def __init__(self, build): member in BuildException
|
/3.0.3-GA/couchdb/test/python/lib/couchdb/ |
H A D | mapping.py | 85 def __init__(self, name=None, default=None): member in Field 133 def __init__(self, **values): member in Mapping 242 def __init__(self, design, map_fun, reduce_fun=None, name=None, member in ViewField 298 def __init__(self, id=None, **values): member in Document 299 Mapping.__init__(self, **values) 560 def __init__(self, mapping=None, name=None, default=None): member in DictField 562 Field.__init__(self, name=name, default=lambda: default.copy()) 615 def __init__(self, field, name=None, default=None): member in ListField 617 Field.__init__(self, name=name, default=lambda: copy.copy(default)) 634 def __init__(sel member in ListField.Proxy [all...] |
/3.0.3-GA/couchbase-python-client/httplib2/ |
H A D | __init__.py | 110 def __init__(self, desc, response, content): member in HttpLib2ErrorWithResponse 113 HttpLib2Error.__init__(self, desc) 423 def __init__(self, credentials, host, request_uri, headers, response, content, http): member in Authentication 459 def __init__(self, credentials, host, request_uri, headers, response, content, http): member in BasicAuthentication 460 Authentication.__init__(self, credentials, host, request_uri, headers, response, content, http) 472 def __init__(self, credentials, host, request_uri, headers, response, content, http): member in DigestAuthentication 473 Authentication.__init__(self, credentials, host, request_uri, headers, response, content, http) 532 def __init__(self, credentials, host, request_uri, headers, response, content, http): member in HmacDigestAuthentication 533 Authentication.__init__(self, credentials, host, request_uri, headers, response, content, http) 604 def __init__(sel member in WsseAuthentication 622 def __init__(self, credentials, host, request_uri, headers, response, content, http): global() member in GoogleLoginAuthentication 673 def __init__(self, cache, safe=safename): # use safe=lambda x: md5.new(x).hexdigest() for the old behavior global() member in FileCache 703 def __init__(self): global() member in Credentials 727 def __init__(self, proxy_type, proxy_host, proxy_port, proxy_rdns=None, proxy_user=None, proxy_pass=None): global() member in ProxyInfo 746 def __init__(self, host, port=None, strict=None, timeout=None, proxy_info=None): global() member in HTTPConnectionWithTimeout 786 def __init__(self, host, port=None, key_file=None, cert_file=None, global() member in HTTPSConnectionWithTimeout 822 def __init__(self, cache=None, timeout=None, proxy_info=None): global() member in Http 1173 def __init__(self, info): global() member in Response [all...] |
/3.0.3-GA/testrunner/lib/membase/api/httplib2/ |
H A D | __init__.py | 110 def __init__(self, desc, response, content): member in HttpLib2ErrorWithResponse 113 HttpLib2Error.__init__(self, desc) 423 def __init__(self, credentials, host, request_uri, headers, response, content, http): member in Authentication 459 def __init__(self, credentials, host, request_uri, headers, response, content, http): member in BasicAuthentication 460 Authentication.__init__(self, credentials, host, request_uri, headers, response, content, http) 472 def __init__(self, credentials, host, request_uri, headers, response, content, http): member in DigestAuthentication 473 Authentication.__init__(self, credentials, host, request_uri, headers, response, content, http) 532 def __init__(self, credentials, host, request_uri, headers, response, content, http): member in HmacDigestAuthentication 533 Authentication.__init__(self, credentials, host, request_uri, headers, response, content, http) 604 def __init__(sel member in WsseAuthentication 622 def __init__(self, credentials, host, request_uri, headers, response, content, http): global() member in GoogleLoginAuthentication 673 def __init__(self, cache, safe=safename): # use safe=lambda x: md5.new(x).hexdigest() for the old behavior global() member in FileCache 703 def __init__(self): global() member in Credentials 727 def __init__(self, proxy_type, proxy_host, proxy_port, proxy_rdns=None, proxy_user=None, proxy_pass=None): global() member in ProxyInfo 746 def __init__(self, host, port=None, strict=None, timeout=None, proxy_info=None): global() member in HTTPConnectionWithTimeout 786 def __init__(self, host, port=None, key_file=None, cert_file=None, global() member in HTTPSConnectionWithTimeout 822 def __init__(self, cache=None, timeout=None, proxy_info=None): global() member in Http 1173 def __init__(self, info): global() member in Response [all...] |
/3.0.3-GA/couchbase-python-client/unittest2/test/ |
H A D | support.py | 13 def __init__(self, *_): member in OldTestResult 41 def __init__(self, log): member in LoggingResult 43 super(LoggingResult, self).__init__() 132 def __init__(self, record=False, module=None): member in .catch_warnings 169 def __init__(self, message, category, filename, lineno, file=None, member in .WarningMessage
|
H A D | test_runner.py | 60 def __init__(self, *_): member in Test_TextTestRunner.test_works_with_result_without_startTestRun_stopTestRun.OldTextResult 61 super(OldTextResult, self).__init__() 77 def __init__(self, events): member in Test_TextTestRunner.test_startTestRun_stopTestRun_called.LoggingRunner 78 super(LoggingRunner, self).__init__(StringIO())
|
/3.0.3-GA/testrunner/scripts/ |
H A D | doc_loader.py | 78 def __init__(self): member in DocLoader 114 def __init__(self, servers, cluster): member in DocLoaderCouchbase 115 super(DocLoaderCouchbase, self).__init__() 150 def __init__(self, server, directory, bucket_name): member in DocLoaderDirectory 151 super(DocLoaderDirectory, self).__init__()
|
/3.0.3-GA/healthchecker/Cheetah/Tools/ |
H A D | MondoReport.py | 118 def __init__(self, index, item=None): member in IndexFormats 164 def __init__(self, origList): member in ValuesGetterMixin 180 def __init__(self, origList, index): member in RecordStats 182 IndexFormats.__init__(self, index, record) 183 ValuesGetterMixin.__init__(self, origList) 315 def __init__(self, origList): member in Summary 316 ValuesGetterMixin.__init__(self, origList) 362 def __init__(self, origList, size, start): member in PrevNextPage 374 def __init__(self, origlist): member in MondoReport
|
/3.0.3-GA/ep-engine/management/ |
H A D | tap.py | 25 def __init__(self, server, port, callback, clientId=None, opts={}, user=None, pswd=None): member in TapConnection 26 mc_bin_server.MemcachedBinaryChannel.__init__(self, None, None, 111 def __init__(self, servers, callback, opts={}, user=None, pswd=None): member in TapClient 119 def __init__(self, s): member in TapDescriptor
|
/3.0.3-GA/moxi/t/ |
H A D | moxi_mock_server.py | 24 def __init__(self, port): member in MockServer 25 threading.Thread.__init__(self) 77 def __init__(self, client, address, server, recvlen_in=1024): member in MockSession 78 threading.Thread.__init__(self) 142 def __init__(self, x): member in ProxyClientBase 143 unittest.TestCase.__init__(self, x)
|
/3.0.3-GA/testrunner/lib/tasks/ |
H A D | task.py | 41 def __init__(self, name): member in Task 42 Future.__init__(self) 69 def __init__(self, server, disabled_consistent_view=None, member in NodeInitializeTask 75 Task.__init__(self, "node_init_task") 134 def __init__(self, server, bucket='default', replicas=1, size=0, port=11211, password=None, bucket_type='membase', member in BucketCreateTask 136 Task.__init__(self, "bucket_create_task") 225 def __init__(self, server, bucket="default"): member in BucketDeleteTask 226 Task.__init__(self, "bucket_delete_task") 265 def __init__(self, servers, to_add=[], to_remove=[], do_stop=False, progress=30, member in RebalanceTask 267 Task.__init__(sel 430 def __init__(self, servers, bucket, param, stat, comparison, value): global() member in StatsWaitTask 508 def __init__(self, servers, bucket, param, stat, comparison, value): global() member in XdcrStatsWaitTask 538 def __init__(self, server, bucket, kv_store): global() member in GenericLoadingTask 691 def __init__(self, server, bucket, generator, kv_store, op_type, exp, flag=0, global() member in LoadDocumentsTask 729 def __init__(self, server, bucket, generators, kv_store, op_type, exp, flag=0, only_store_hash=True): global() member in LoadDocumentsGeneratorsTask 762 def __init__(self, server, bucket, generator, kv_store, op_type, exp, flag=0, only_store_hash=True, batch_size=100, pause_secs=1, timeout_secs=30): global() member in BatchedLoadDocumentsTask 890 def __init__(self, server, bucket, kv_store, num_ops, create, read, update, delete, exp): global() member in WorkloadTask 975 def __init__(self, server, bucket, kv_store, max_verify=None, only_store_hash=True, replica_to_read=None): global() member in ValidateDataTask 1063 def __init__(self, server, bucket, kv_store, max_verify=None): global() member in ValidateDataWithActiveAndReplicaTask 1134 def __init__(self, server, bucket, kv_store, max_verify=None, only_store_hash=True, batch_size=100, timeout_sec=5): global() member in BatchedValidateDataTask 1231 def __init__(self, src_server, dest_server, bucket, kv_store, max_err_count=100): global() member in VerifyRevIdTask 1317 def __init__(self, dest_server, bucket, kv_store, meta_data_store, max_err_count=100): global() member in VerifyMetaDataTask 1394 def __init__(self, dest_server, bucket, kv_store): global() member in GetMetaDataTask 1440 def __init__(self, server, design_doc_name, view, bucket="default", with_query=True, global() member in ViewCreateTask 1626 def __init__(self, server, design_doc_name, view, bucket="default"): global() member in ViewDeleteTask 1693 def __init__(self, server, design_doc_name, view_name, global() member in ViewQueryTask 1773 def __init__(self, servers, design_doc_name, view, global() member in MonitorViewQueryResultsTask 1977 def __init__(self, server, config=None, bucket="default"): global() member in ModifyFragmentationConfigTask 2066 def __init__(self, server, type, target_value, wait_progress=100, num_iterations=100, wait_task=True): global() member in MonitorActiveTask 2177 def __init__(self, server, design_doc_name, fragmentation_value=10, bucket="default"): global() member in MonitorViewFragmentationTask 2298 def __init__(self, server, design_doc_name, bucket="default", with_rebalance=False): global() member in ViewCompactionTask 2427 def __init__(self, servers, to_failover=[], wait_for_pending=0, graceful=False, use_hostnames=False): global() member in FailoverTask 2475 def __init__(self, doc_generators, view, query): global() member in GenerateExpectedViewResultsTask 2744 def __init__(self, design_doc_name, view_name, query, expected_rows, server=None, global() member in ViewQueryVerificationTask 2935 def __init__(self, server, bucket="default"): global() member in BucketFlushTask 2985 def __init__(self, server, fragmentation_value=10, bucket="default", get_view_frag=False): global() member in MonitorDBFragmentationTask 3028 def __init__(self, src_server, dest_server, bucket_src='', bucket_dest='', username='', password='', global() member in CBRecoveryTask 3158 def __init__(self, server, bucket="default"): global() member in CompactBucketTask 3219 def __init__(self, server, design_doc_name, bucket="default", with_rebalance=False, frag_value=0): global() member in MonitorViewCompactionTask 3340 def __init__(self, server, fragmentation_value=10, bucket="default", get_view_frag=False): global() member in MonitorDiskSizeFragmentationTask 3381 def __init__(self, server, bucket="default"): global() member in CancelBucketCompactionTask [all...] |