juturna.nodes.sink package#

Module contents#

class juturna.nodes.sink.NotifierHTTP(endpoint: str, timeout: int, content_type: str)#

Bases: BaseNode

property configuration: dict#

set_on_config(property: str, value: str)#

update(message: Message)#

warmup()#

class juturna.nodes.sink.NotifierWebsocket(endpoint: str)#

Bases: BaseNode

destroy()#

update(message: Message)#

warmup()#

class juturna.nodes.sink.VideostreamFFMPEG(dst_host: str, dst_port: int, in_width: int, in_height: int, out_width: int, out_height: int, gop: int, ffmpeg_proc_path: str)#

Bases: BaseNode

Sink node for video streaming

property ffmpeg_launcher: 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: Message)#

warmup()#