corelink.resources.variables

Some global corelink variables.

 1"""Some global corelink variables."""
 2
 3DEBUG = False
 4valid_proto = ["ws", "tcp", "udp"]
 5
 6def log(obj):
 7    """Logger for debug information."""
 8    if DEBUG:
 9        print("log: ", obj)
10
11user = None
12password = None
13host = None
14port = None
15protocol = "ws"
16token = None
17connection = None
18user_ip = None
19controlID = 0
20request_queue = {}
21streams = {}  # # holds sender dicts with info and connection object
22receiver = {}  # holds receiver dicts with info and connection object
23loop = None
24receiver_task = None
25is_open = True
26shut_down = False
27
28async def default_cb(data, *args, key='data'):
29    print("Callback not set for", key)
30    if key == 'data':
31        print("message:\n", data)
32
33user_cb = default_cb
34server_callbacks = {"update": default_cb, "subscriber": default_cb, "stale": default_cb, "dropped": default_cb}
DEBUG = False
valid_proto = ['ws', 'tcp', 'udp']
def log(obj): 
 7def log(obj):
 8    """Logger for debug information."""
 9    if DEBUG:
10        print("log: ", obj)

Logger for debug information.

user = None
password = None
host = None
port = None
protocol = 'ws'
token = None
connection = None
user_ip = None
controlID = 0
request_queue = {}
streams = {}
receiver = {}
loop = None
receiver_task = None
is_open = True
shut_down = False
async def default_cb(data, *args, key='data'): 
29async def default_cb(data, *args, key='data'):
30    print("Callback not set for", key)
31    if key == 'data':
32        print("message:\n", data)
async def user_cb(data, *args, key='data'): 
29async def default_cb(data, *args, key='data'):
30    print("Callback not set for", key)
31    if key == 'data':
32        print("message:\n", data)
server_callbacks = {'update': <function default_cb>, 'subscriber': <function default_cb>, 'stale': <function default_cb>, 'dropped': <function default_cb>}