Index

A

aclose() (qbss.ctlclient.ControllerClient method) add_status() (qbss.controller.receiver_tracker.ReceiversTracker method) add_store() (qbss.controller.uuid_tracker.UUIDTracker method)

add_stream() (qbss.controller.stream_tracker.StreamsTracker method) ALREADY_EXISTS (qbss.proxy.qbss_client.QbssStatus attribute) AVAILABLE (qbss.proxy.qbss_client.QbssBlockState attribute)

B

blocks_per_second (qbss.ctlclient.StreamStatus attribute)

BSSController (class in qbss.controller.controller)

C

call_rpc_method() (qbss.ctlclient.ControllerClient method) close() (pubsub.client.PubSubClient method) (qbss.proxy.qbss_client.QbssClient method) connect() (pubsub.client.PubSubClient method) (qbss.proxy.qbss_client.QbssClient method)

CONTROLLER_ERR (qbss.proxy.qbss_client.QbssStatus attribute) ControllerClient (class in qbss.ctlclient) CREATE (qbss.proxy.qbss_client.QbssStreamAction attribute) creation_time (qbss.ctlclient.StreamStatus attribute) current_source (qbss.ctlclient.StreamStatus attribute)

D

DEAD_ROLL_CALL_INTERVAL (qbss.controller.receiver_tracker.ReceiversTracker attribute) default_time (qbss.controller.stream_tracker.StreamStatus attribute)

DELETE (qbss.proxy.qbss_client.QbssStreamAction attribute) deregister() (pubsub.client.PubSubTopic method)

E

ERROR_FETCHING_TIMEOUT (qbss.proxy.qbss_client.QbssBlockState attribute) ERROR_MAX_RETRIES (qbss.proxy.qbss_client.QbssBlockState attribute)

ERROR_NONEXISTENT (qbss.proxy.qbss_client.QbssBlockState attribute) ERROR_STREAM (qbss.proxy.qbss_client.QbssBlockState attribute) ERROR_UNKNOWN (qbss.proxy.qbss_client.QbssBlockState attribute)

F

FETCHING (qbss.proxy.qbss_client.QbssBlockState attribute) FINISH (qbss.proxy.qbss_client.QbssStreamAction attribute)

finished (qbss.ctlclient.StreamStatus attribute) first_hop (qbss.ctlclient.ReceiverInfo attribute)

G

get_block() (qbss.proxy.qbss_client.QbssClient method) get_dsp() (qbss.proxy.qbss_client.QbssClient method) GET_INFO (qbss.proxy.qbss_client.QbssStreamAction attribute) GET_NOTE (qbss.proxy.qbss_client.QbssStreamAction attribute) get_receiver() (qbss.controller.receiver_tracker.ReceiversTracker method)

get_receivers() (qbss.controller.receiver_tracker.ReceiversTracker method) get_response() (qbss.controller.controller.BSSController class method) get_stream() (qbss.controller.stream_tracker.StreamsTracker method) get_streams() (qbss.controller.stream_tracker.StreamsTracker method) get_uuid() (qbss.controller.uuid_tracker.UUIDTracker method)

H

highest_block (qbss.ctlclient.ReceiveStatus attribute) (qbss.ctlclient.StreamStatus attribute)

highest_block_time (qbss.ctlclient.ReceiveStatus attribute) (qbss.ctlclient.StreamStatus attribute)

I

incoming_messages() (pubsub.client.PubSubClient method)

INFO_ALL (qbss.proxy.qbss_client.QbssStreamAction attribute)

L

launch() (in module pubsub.proxy) (in module qbss.controller) (in module qbss.proxy.qbss_proxy)

lowest_block (qbss.ctlclient.ReceiveStatus attribute) (qbss.ctlclient.StreamStatus attribute)

M

MALFORMED_ERR (qbss.proxy.qbss_client.QbssStatus attribute) manage_stream() (qbss.proxy.qbss_client.QbssClient method) MISC_ERR (qbss.proxy.qbss_client.QbssStatus attribute) missing_blocks (qbss.ctlclient.StreamStatus attribute) module pubsub.client pubsub.proxy qbss.controller qbss.controller.controller qbss.controller.receiver_tracker qbss.controller.stream_tracker qbss.controller.uuid_tracker qbss.ctlclient qbss.proxy.qbss_client qbss.proxy.qbss_proxy

N

note (qbss.ctlclient.StreamStatus attribute)

O

OKAY (qbss.proxy.qbss_client.QbssStatus attribute)

owner (qbss.ctlclient.StreamStatus attribute)

P

persist() (qbss.controller.receiver_tracker.ReceiversTracker method) ping() (qbss.proxy.qbss_client.QbssClient method) publish_block() (qbss.proxy.qbss_client.QbssClient method) PUBLISHING (qbss.proxy.qbss_client.QbssBlockState attribute) pubsub.client module

pubsub.proxy module PubSubClient (class in pubsub.client) PubSubTopic (class in pubsub.client) PubSubWebSocketHandler (class in pubsub.proxy)

Q

qbss.controller module qbss.controller.controller module qbss.controller.receiver_tracker module qbss.controller.stream_tracker module qbss.controller.uuid_tracker module

qbss.ctlclient module qbss.proxy.qbss_client module qbss.proxy.qbss_proxy module QbssBlockState (class in qbss.proxy.qbss_client) QbssClient (class in qbss.proxy.qbss_client) QBSSProxy (class in qbss.proxy.qbss_proxy) QbssStatus (class in qbss.proxy.qbss_client) QbssStreamAction (class in qbss.proxy.qbss_client)

R

receiver_id (qbss.ctlclient.ReceiverInfo attribute) receiver_note (qbss.ctlclient.ReceiverInfo attribute) receiver_rollcall() (qbss.controller.receiver_tracker.ReceiversTracker method) ReceiverInfo (class in qbss.controller.receiver_tracker) (class in qbss.ctlclient) ReceiversTracker (class in qbss.controller.receiver_tracker)

ReceiveStatus (class in qbss.controller.receiver_tracker) (class in qbss.ctlclient) refresh() (qbss.controller.receiver_tracker.ReceiversTracker method) register() (pubsub.client.PubSubTopic method) remove_status() (qbss.controller.receiver_tracker.ReceiversTracker method) remove_stream() (qbss.controller.stream_tracker.StreamsTracker method) roll_call_update() (qbss.controller.receiver_tracker.ReceiversTracker method)

S

send() (pubsub.client.PubSubTopic method) SET_NOTE (qbss.proxy.qbss_client.QbssStreamAction attribute) set_storage_limit() (qbss.proxy.qbss_client.QbssClient method) skipped_blocks (qbss.ctlclient.ReceiveStatus attribute) STALE_THREAD_SLEEP (qbss.controller.receiver_tracker.ReceiversTracker attribute) stream_id (qbss.ctlclient.ReceiveStatus attribute) (qbss.ctlclient.StreamStatus attribute)

StreamStatus (class in qbss.controller.stream_tracker) (class in qbss.ctlclient) StreamsTracker (class in qbss.controller.stream_tracker) SUBSCRIBE (qbss.proxy.qbss_client.QbssStreamAction attribute) subscribe() (pubsub.client.PubSubClient method)

T

to_dict() (qbss.controller.receiver_tracker.ReceiverInfo method) (qbss.controller.receiver_tracker.ReceiveStatus method) (qbss.controller.stream_tracker.StreamStatus method)

TOO_LARGE (qbss.proxy.qbss_client.QbssStatus attribute) topic() (pubsub.client.PubSubClient method)

U

UNAVAIALBLE (qbss.proxy.qbss_client.QbssBlockState attribute) UNKNOWN_KEY (qbss.proxy.qbss_client.QbssStatus attribute) unsubscribe() (pubsub.client.PubSubClient method) update_status() (qbss.controller.receiver_tracker.ReceiversTracker method)

update_stream() (qbss.controller.controller.BSSController method) (qbss.controller.stream_tracker.StreamStatus method) (qbss.controller.stream_tracker.StreamsTracker method) uuid_in_kv_stores() (qbss.controller.uuid_tracker.UUIDTracker method) UUIDTracker (class in qbss.controller.uuid_tracker)

W

WAITING (qbss.proxy.qbss_client.QbssBlockState attribute)