helper Package

data_helper Module

class cbtestlib.memcached.helper.data_helper.DocumentGenerator

Bases: object

static create_value(pattern, size)

static get_doc_generators(count, kv_template=None, seed=None, sizes=None)

static get_doc_generators_by_load_ratio(rest, bucket='default', ram_load_ratio=1, value_size_distribution=None, seed=None)

static make_docs(items, kv_template, options={'seed': '098a2bcc-0f5c-458a-8718-ed21e4503c8e', 'size': 1024})

class cbtestlib.memcached.helper.data_helper.GeneratedDocuments(items, kv_template, options={'size': 1024})

Bases: object

has_next()

next()

reset()

class cbtestlib.memcached.helper.data_helper.KVStoreAwareSmartClient(rest, bucket, kv_store=None, info=None, store_enabled=True)

Bases: cbtestlib.memcached.helper.data_helper.VBucketAwareMemcached

delete(key)

get_all_deleted_items()

get_all_expired_items()

get_all_keys()

get_all_valid_items()

get_deleted_key(key)

get_doc_metadata(num_vbuckets, key)

get_expired_key(key)

get_key_check_status(key, status)

get_valid_key(key)

kv_get(key)

kv_mc_sync_get(key, status)

mc_get(key)

mc_get_full(key)

set(key, value, ttl=-1)

class cbtestlib.memcached.helper.data_helper.KVStoreSmartClientHelper

Bases: object

static do_verification(client)

static verify_delete(client, key)

static verify_expired(client, key)

static verify_key(client, key)

static verify_set(client, key)

class cbtestlib.memcached.helper.data_helper.LoadWithMcsoda(master, num_docs, prefix='', bucket='default', user='Administrator', password='', protocol='membase-binary', port=11211)

Bases: object

get_cfg()

load_data()

load_stop()

protocol_parse(protocol_in)

class cbtestlib.memcached.helper.data_helper.MemcachedClientHelper

Bases: object

static create_threads(servers=None, name='default', ram_load_ratio=-1, number_of_items=-1, value_size_distribution=None, number_of_threads=50, override_vBucketId=-1, write_only=False, moxi=True, async_write=False, delete_ratio=0, expiry_ratio=0)

static create_threads_for_load_bucket(serverInfo=None, name='default', ram_load_ratio=-1, number_of_items=-1, value_size_distribution=None, number_of_threads=50, override_vBucketId=-1, write_only=False, moxi=True, delete_ratio=0, expiry_ratio=0)

static create_value(pattern, size)

static direct_client(server, bucket, timeout=30)

static flush_bucket(server, bucket)

static load_bucket(servers, name='default', ram_load_ratio=-1, number_of_items=-1, value_size_distribution=None, number_of_threads=50, override_vBucketId=-1, write_only=False, moxi=True)

static load_bucket_and_return_the_keys(servers=None, name='default', ram_load_ratio=-1, number_of_items=-1, value_size_distribution=None, number_of_threads=50, override_vBucketId=-1, write_only=False, moxi=True, delete_ratio=0, expiry_ratio=0)

static proxy_client(server, bucket, timeout=30, force_ascii=False)

static random_pick(list)

exception cbtestlib.memcached.helper.data_helper.MemcachedClientHelperExcetion(errorcode, message)

Bases: exceptions.Exception

class cbtestlib.memcached.helper.data_helper.MutationThread(serverInfo, keys, op, seed, name='default')

Bases: threading.Thread

run()

class cbtestlib.memcached.helper.data_helper.ReaderThread(info, keyset, queue)

Bases: object

abort()

start()

class cbtestlib.memcached.helper.data_helper.VBucketAwareMemcached(rest, bucket, info=None)

Bases: object

add_memcached(server_str, memcacheds, rest, bucket)

delete(key)

done()

get(key)

memcached(key, replica_index=None)

memcached_for_replica_vbucket(vBucketId, replica_index=0)

memcached_for_vbucket(vBucketId)

not_my_vbucket_memcached(key)

request_map(rest, bucket)

reset(rest=None)

reset_vbucket(rest, key)

set(key, exp, flags, value)

class cbtestlib.memcached.helper.data_helper.WorkerThread(serverInfo, name, values_list, ignore_how_many_errors=5000, override_vBucketId=-1, terminate_in_minutes=120, write_only=False, moxi=True, async_write=False, delete_ratio=0, expiry_ratio=0)

Bases: threading.Thread

inserted_keys_count()

keys_set()

rejected_keys_count()

run()

cbtestlib.memcached.helper.data_helper.start_reader_process(info, keyset, queue)

kvstore Module

class cbtestlib.memcached.helper.kvstore.KVStore(num_locks=16)

Bases: object

acquire_partition(key)

acquire_random_partition(has_valid=True)

key_set()

release_partition(key)

reset()

class cbtestlib.memcached.helper.kvstore.Partition

Bases: object

delete(key)

deleted_key_set()

get_deleted(key)

get_flag(key)

get_random_deleted_key()

get_random_valid_key()

get_valid(key)

has_deleted_keys()

has_valid_keys()

set(key, value, exp=0, flag=0)

valid_key_set()

old_kvstore Module

class cbtestlib.memcached.helper.old_kvstore.ClientKeyValueStore

Bases: object

delete(key)

keys()

read(key)

valid_items()

write(key, value, ttl=-1)