juturna.nodes.source package#

Module contents#

class juturna.nodes.source.AudioFile(file_source: str, block_size: int, audio_rate: int)#

Bases: BaseNode

static chunker(seq, size)#

generate_chunks()#

update(chunk)#

warmup()#

class juturna.nodes.source.AudioRTP(rec_host: str, rec_port: int | str, audio_rate: int, block_size: int, channels: int, payload_type: int)#

Bases: BaseNode

Source node for streaming audio

property configuration: dict#

configure()#

destroy()#

property ffmpeg_launcher: Path#

property sdp_descriptor: Path#

start()#: Start the node and begin processing. This method is called automatically when the parent pipeline is started. If you override this method in your custom node class, make sure to call the parent method to ensure the bridge is started correctly.

stop()#: Stop the node and begin processing. This method is called automatically when the parent pipeline is stopped. If you override this method in your custom node class, make sure to call the parent method to ensure the bridge is stopped correctly.

update(message: bytes)#

warmup()#

class juturna.nodes.source.VideoRTP(rec_host: str, rec_port: int | str, payload_type: int, codec: str, width: int, height: int)#

Bases: BaseNode

Source node for video streaming

property configuration: dict#

configure()#

destroy()#

property ffmpeg_launcher: Path#

property sdp_descriptor: Path#

start()#: Start the node and begin processing. This method is called automatically when the parent pipeline is started. If you override this method in your custom node class, make sure to call the parent method to ensure the bridge is started correctly.

stop()#: Stop the node and begin processing. This method is called automatically when the parent pipeline is stopped. If you override this method in your custom node class, make sure to call the parent method to ensure the bridge is stopped correctly.

update(message: bytes)#

warmup()#