old_tasks Package

task Module

class cbtestlib.old_tasks.task.BucketCreateTask(server, bucket='default', replicas=1, port=11210, size=0, password=None)

Bases: cbtestlib.old_tasks.task.Task

check_bucket_ready(task_manager)

create_bucket(task_manager)

step(task_manager)

class cbtestlib.old_tasks.task.BucketDeleteTask(server, bucket='default')

Bases: cbtestlib.old_tasks.task.Task

check_bucket_deleted()

delete_bucket(task_manager)

step(task_manager)

class cbtestlib.old_tasks.task.DocumentAccessTask(rest, doc_ids, bucket='default', info=None, loop=False)

Bases: cbtestlib.old_tasks.task.GenericLoadingTask

run()

class cbtestlib.old_tasks.task.DocumentDeleteTask(rest, doc_ids, bucket='default', info=None, kv_store=None, store_enabled=True)

Bases: cbtestlib.old_tasks.task.GenericLoadingTask

run()

class cbtestlib.old_tasks.task.DocumentExpireTask(rest, doc_ids, bucket='default', info=None, kv_store=None, store_enabled=True, expiration=5)

Bases: cbtestlib.old_tasks.task.GenericLoadingTask

run()

class cbtestlib.old_tasks.task.FailOverTask(servers, to_remove=[])

Bases: cbtestlib.old_tasks.task.Task

failingOver(task_manager)

start_failover(task_manager)

step(task_manager)

class cbtestlib.old_tasks.task.GenericLoadingTask(rest, bucket, kv_store=None, store_enabled=True, info=None)

Bases: threading.Thread, cbtestlib.old_tasks.task.Task

cancel()

do_task_op(op, key, value=None, expiration=None)

step(task_manager)

class cbtestlib.old_tasks.task.KVStoreIntegrityTask(rest, kv_store, bucket='default')

Bases: cbtestlib.old_tasks.task.Task, threading.Thread

run()

step(task_manager)

class cbtestlib.old_tasks.task.LoadDocGeneratorTask(rest, doc_generators, bucket='default', kv_store=None, store_enabled=True, expiration=None, loop=False)

Bases: cbtestlib.old_tasks.task.GenericLoadingTask

run()

class cbtestlib.old_tasks.task.NodeInitializeTask(server)

Bases: cbtestlib.old_tasks.task.Task

init_node()

init_node_memory()

step(task_manager)

class cbtestlib.old_tasks.task.RebalanceTask(servers, to_add=[], to_remove=[], do_stop=False, progress=30)

Bases: cbtestlib.old_tasks.task.Task

add_nodes(task_manager)

getStats(servers)

rebalancing(task_manager)

start_rebalance(task_manager)

step(task_manager)

stop_rebalance(task_manager)

class cbtestlib.old_tasks.task.Task(name)

cancel()

is_timed_out()

result(retries=0)

set_result(result)

taskhelper Module

class cbtestlib.old_tasks.taskhelper.TaskHelper

static add_bucket_create_task(tm, server, bucket='default', replicas=1, port=11210, size=0, password=None)

static add_node_init_task(tm, server)

taskmanager Module

class cbtestlib.old_tasks.taskmanager.TaskManager

Bases: threading.Thread

cancel()

run()

schedule(task, sleep_time=0)

stop()