bordercontrol 0.2.0.0.4

NATS wrapper for fast scanner development

---

Instruction for develop a new module.

from bc.dev.handlers import WorkerThreadHandler

counter = 0

def worker_function(data):
global counter
counter += 1
print(counter)

return {"results": [1, 2, 3, 45]}


a = WorkerThreadHandler(worker_function=worker_function, name='name', hostname='hostname')
a.run()

data - here you see all data which send in sheduler in your channel

{"results": [1, 2, 3, 45]} - module send to channel _reporter as:

{
    'task_data': data,
    'result': [1, 2, 3, 45],
    'name': 'name',
    'hostname': 'hostname'
}

worker_function - required arg name - optional hostname - optional

Module send to channel _registration:

{
    "name": "name",
    "hostname": "hostname"
}

Module must receive from channel _registration:

{
    'subjects_to_subscribe': ['test'],
    'unique_name': 'test_module1'
}

If error will be detected in worker, module send error message to channel _errors:

{
    'task_data': data,
    'result': "ERROR",
    'name': 'name',
    'hostname': 'hostname'
}