openrvdas.logger.readers.network_reader

No module-level documentation available.
 1#!/usr/bin/env python3
 2
 3import logging
 4
 5from logger.readers.reader import Reader  # noqa: E402
 6
 7
 8class NetworkReader(Reader):
 9    def __init__(self, network, eol='',
10                 encoding='utf-8', encoding_errors='ignore'):
11        logging.error("NetworkReader has been replaced by TCPReader and UDPReader")
12
13    def read(self):
14        logging.error("not reading anything: NetworkReader has been "
15                      "replaced by TCPReader and UDPReader")
class NetworkReader(logger.readers.reader.Reader):
 9class NetworkReader(Reader):
10    def __init__(self, network, eol='',
11                 encoding='utf-8', encoding_errors='ignore'):
12        logging.error("NetworkReader has been replaced by TCPReader and UDPReader")
13
14    def read(self):
15        logging.error("not reading anything: NetworkReader has been "
16                      "replaced by TCPReader and UDPReader")

Base class Reader about which we know nothing else.

Passes arguments quiet, encoding and encoding_errors up to BaseModule

NetworkReader(network, eol='', encoding='utf-8', encoding_errors='ignore')
10    def __init__(self, network, eol='',
11                 encoding='utf-8', encoding_errors='ignore'):
12        logging.error("NetworkReader has been replaced by TCPReader and UDPReader")
quiet - if type checking should log type errors or operate silently.

Two additional arguments govern how records will be encoded/decoded
from bytes, if desired by the Writer subclass when it calls
_encode_str() or _decode_bytes:

encoding - 'utf-8' by default. If empty or None, do not attempt any
        decoding and return raw bytes. Other possible encodings are
        listed in online documentation here:
        https://docs.python.org/3/library/codecs.html#standard-encodings

encoding_errors - 'ignore' by default. Other error strategies are
        'strict', 'replace', and 'backslashreplace', described here:
        https://docs.python.org/3/howto/unicode.html#encodings

mirror_to - Optional Writer to which all records read or transformed
        by this module (if it is a Reader or Transform) will be
        "mirrored" (copied). Mirroring happens asynchronously via
        a queue and background thread to minimize impact on the
        primary data flow. Writers cannot be mirrored.
def read(self):
14    def read(self):
15        logging.error("not reading anything: NetworkReader has been "
16                      "replaced by TCPReader and UDPReader")

read() should return None when there are no more records.