qbss.ctlclient module

class qbss.ctlclient.ControllerClient(endpoint, id)

Bases: object

async aclose()

async call_rpc_method(method, params={}, **kwargs)

class qbss.ctlclient.ReceiveStatus(stream_id, lowest_block, highest_block, highest_block_time, skipped_blocks)

Bases: NamedTuple

highest_block: Any

Alias for field number 2

highest_block_time: Any

Alias for field number 3

lowest_block: Any

Alias for field number 1

skipped_blocks: Any

Alias for field number 4

stream_id: Any

Alias for field number 0

class qbss.ctlclient.ReceiverInfo(receiver_id, receiver_note, first_hop)

Bases: NamedTuple

first_hop: Any

Alias for field number 2

receiver_id: Any

Alias for field number 0

receiver_note: Any

Alias for field number 1

class qbss.ctlclient.StreamStatus(stream_id, blocks_per_second, creation_time, current_source, finished, lowest_block, highest_block, highest_block_time, missing_blocks, owner, note)

Bases: NamedTuple

blocks_per_second: Any

Alias for field number 1

creation_time: Any

Alias for field number 2

current_source: Any

Alias for field number 3

finished: Any

Alias for field number 4

highest_block: Any

Alias for field number 6

highest_block_time: Any

Alias for field number 7

lowest_block: Any

Alias for field number 5

missing_blocks: Any

Alias for field number 8

note: Any

Alias for field number 10

owner: Any

Alias for field number 9

stream_id: Any

Alias for field number 0