ska_sdp_batchlet.utils.monitor.log module

class ska_sdp_batchlet.utils.monitor.log.LogMonitor(filter_plugins, consumer_plugins)

Bases: object

Monitors logs by utilizing filter and consumer plugins.

This schema of filter_plugins and consumer_plugins is same as the schema of the input configuration of batchlet.

Parameters:

• filter_plugins (list of dict, optional) -- List of dictionaries specifying filter plugins

• consumer_plugins (list of dict, optional) -- List of dictionaries specifying consumer plugins

pipe_read: Connection

Read end of the pipe, between application and filter process

pipe_write: Connection

Write end of the pipe, between application and filter process

event_queue: Queue

Queue for filter process -> consumer process

filter_process: Process

The filter subprocess

consumer_process: Process

The consumer subprocess

property log_write_stream

Returns a new stream to which another process can write its stdout/stderr