system.webrtc package

Submodules

system.webrtc.schema module

system.webrtc.schema.generate_field(field: _StructSchemaField) → str | list[Any] | dict[str, Any]

system.webrtc.schema.generate_struct(schema: _StructSchema) → dict[str, Any]

system.webrtc.schema.generate_type(type_walker, schema_walker) → str | list[Any] | dict[str, Any]

system.webrtc.webrtcd module

class system.webrtc.webrtcd.CerealIncomingMessageProxy(pm: PubMaster)

Bases: object

send(message: bytes)

class system.webrtc.webrtcd.CerealOutgoingMessageProxy(sm: SubMaster)

Bases: object

add_channel(channel: RTCDataChannel)

to_json(msg_content: Any)

update()

class system.webrtc.webrtcd.CerealProxyRunner(proxy: CerealOutgoingMessageProxy)

Bases: object

async run()

start()

stop()

class system.webrtc.webrtcd.DynamicPubMaster(*args, **kwargs)

Bases: PubMaster

async add_services_if_needed(services)

class system.webrtc.webrtcd.StreamRequestBody(sdp: str, cameras: list[str], bridge_services_in: list[str] = <factory>, bridge_services_out: list[str] = <factory>)

Bases: object

bridge_services_in: list[str]

bridge_services_out: list[str]

cameras: list[str]

sdp: str

class system.webrtc.webrtcd.StreamSession(sdp: str, cameras: list[str], incoming_services: list[str], outgoing_services: list[str], debug_mode: bool = False)

Bases: object

async get_answer()

async message_handler(message: bytes)

async post_run_cleanup()

async run()

shared_pub_master = <system.webrtc.webrtcd.DynamicPubMaster object>

start()

stop()

async system.webrtc.webrtcd.get_schema(request: Request)

async system.webrtc.webrtcd.get_stream(request: Request)

system.webrtc.webrtcd.main()

async system.webrtc.webrtcd.on_shutdown(app: Application)

system.webrtc.webrtcd.webrtcd_thread(host: str, port: int, debug: bool)

Module contents