qbss.controller package

Submodules

qbss.controller.controller module

class qbss.controller.controller.BSSController(*args: Any, **kwargs: Any)

Bases: JSONRPCHandler

classmethod get_response(**kwargs)

update_stream(stream_id: str, lowest_block: int, highest_block: int, highest_block_time: int, finished: bool, missing_blocks: list[int], current_source: list[int], **kwargs)

qbss.controller.receiver_tracker module

class qbss.controller.receiver_tracker.ReceiveStatus(received_status_obj)

Bases: object

to_dict()

class qbss.controller.receiver_tracker.ReceiverInfo(receiver_obj, roll_call_timestamp: float)

Bases: object

to_dict()

class qbss.controller.receiver_tracker.ReceiversTracker(uuid_tracker: UUIDTracker, filename='receivers.db')

Bases: object

DEAD_ROLL_CALL_INTERVAL = 50

STALE_THREAD_SLEEP = 10

add_status(receiver_info_obj: ReceiverInfo, status: ReceiveStatus) → None

get_receiver(receiver_id)

get_receivers() → list[ReceiverInfo]

persist(receiver_info_obj)

receiver_rollcall(receiver)

refresh(receiver_info_obj, new_obj, fields=['note', 'first_hop', 'last_rollcall'])

remove_status(receiver_info_obj: ReceiverInfo, stream_id: str) → bool

roll_call_update()

update_status(receiver_info_obj: ReceiverInfo, status: ReceiveStatus) → None

qbss.controller.stream_tracker module

class qbss.controller.stream_tracker.StreamStatus(id)

Bases: object

default_time = 0

to_dict()

update_stream(update_object={})

class qbss.controller.stream_tracker.StreamsTracker(uuid_tracker: UUIDTracker, filename='streams.db')

Bases: object

add_stream(uuid_stream, *args, **kwargs)

get_stream(id)

get_streams()

remove_stream(id)

update_stream(obj: StreamStatus, to_update)

qbss.controller.uuid_tracker module

class qbss.controller.uuid_tracker.UUIDTracker

Bases: object

add_store(kv_store)

get_uuid()

uuid_in_kv_stores(possible_uuid)

Module contents

qbss.controller.launch(no_cookieguard=False)