|
18 | 18 |
|
19 | 19 | """Output module of ParallelSSH"""
|
20 | 20 |
|
21 |
| -from collections import namedtuple |
22 | 21 | from os import linesep
|
23 | 22 |
|
24 | 23 | from . import logger
|
25 | 24 |
|
26 | 25 |
|
27 |
| -HostOutputBuffers = namedtuple('HostOutputBuffers', ['stdout', 'stderr'], ) |
28 |
| -HostOutputBuffers.__doc__ = """ |
29 |
| -:param stdout: Stdout data |
30 |
| -:type stdout: :py:class:`BufferData` |
31 |
| -:param stderr: Stderr data |
32 |
| -:type stderr: :py:class:`BufferData` |
33 |
| -""" |
34 |
| -HostOutputBuffers.stdout.__doc__ = "Stdout :py:class:`BufferData`" |
35 |
| -HostOutputBuffers.stderr.__doc__ = "Stderr :py:class:`BufferData`" |
36 |
| - |
37 |
| -BufferData = namedtuple('BufferData', ['reader', 'rw_buffer']) |
38 |
| -BufferData.__doc__ = """ |
39 |
| -:param reader: Reader |
40 |
| -:type reader: :py:class:`gevent.Greenlet` |
41 |
| -:param rw_bufffer: Read/write buffer |
42 |
| -:type rw_buffer: :py:class:`pssh.clients.reader.ConcurrentRWBuffer` |
43 |
| -""" |
44 |
| -BufferData.rw_buffer.__doc__ = "Read/write buffer" |
45 |
| -BufferData.reader.__doc__ = "Greenlet reading data from channel and writing to rw_buffer" |
| 26 | +class HostOutputBuffers(object): |
| 27 | + __slots__ = ('stdout', 'stderr') |
| 28 | + |
| 29 | + def __init__(self, stdout, stderr): |
| 30 | + """ |
| 31 | + :param stdout: Stdout data |
| 32 | + :type stdout: :py:class:`BufferData` |
| 33 | + :param stderr: Stderr data |
| 34 | + :type stderr: :py:class:`BufferData` |
| 35 | + """ |
| 36 | + self.stdout = stdout |
| 37 | + self.stderr = stderr |
| 38 | + |
| 39 | + |
| 40 | +class BufferData(object): |
| 41 | + __slots__ = ('reader', 'rw_buffer') |
| 42 | + |
| 43 | + def __init__(self, reader, rw_buffer): |
| 44 | + """ |
| 45 | + :param reader: Greenlet reading data from channel and writing to rw_buffer |
| 46 | + :type reader: :py:class:`gevent.Greenlet` |
| 47 | + :param rw_bufffer: Read/write buffer |
| 48 | + :type rw_buffer: :py:class:`pssh.clients.reader.ConcurrentRWBuffer` |
| 49 | + """ |
| 50 | + self.reader = reader |
| 51 | + self.rw_buffer = rw_buffer |
46 | 52 |
|
47 | 53 |
|
48 | 54 | class HostOutput(object):
|
|
0 commit comments