flexget.ipc module#

class flexget.ipc.ClientService[source]#

Bases: Service

exposed_console(text, *args, **kwargs)[source]#
exposed_log_sink(message)[source]#
exposed_version()[source]#
exposed_write(text, *args, **kwargs)[source]#
on_connect(conn)[source]#

called when the connection is established

class flexget.ipc.DaemonService[source]#

Bases: Service

client_log_sink(message)[source]#
exposed_handle_cli(args)[source]#
exposed_version()[source]#
on_connect(conn)[source]#

called when the connection is established

property client_out_stream#
manager = None#
class flexget.ipc.IPCClient(port, password)[source]#

Bases: object

Parameters:

password (str)

close()[source]#
class flexget.ipc.IPCServer(manager, port=None)[source]#

Bases: object

authenticator(sock)[source]#
run()[source]#
shutdown()[source]#
start()[source]#
class flexget.ipc.RemoteStream(writer)[source]#

Bases: object

Used as a filelike to stream text to remote client.

If client disconnects while this is in use, an error will be logged, but no exception raised.

Parameters:

writer (Callable | None)

flush()[source]#
Return type:

None

write(text)[source]#
Parameters:

text (str)

Return type:

None