Status frame I/O support.
sys
os0
io0
itertools0
signal0
tools0
execution0
frames0
allocate_line_buffer10%
allocate_line_buffer(fd)
spawnframes230%
spawnframes(invocation)
Generator emitting frames produced by the given invocation's standard out. If GeneratorExit or KeyboardInterrupt is thrown, the generator will send the process a signal.SIGKILL.
FrameArray0
IO array manager for frame sources.
FrameArrayio0
io(self)
FrameArray__init__0
__init__(self)
FrameArray__enter__0
__enter__(self)
FrameArray__exit__0
__exit__(self, exc, val, tb)
FrameArrayconnect0
connect(self, id, fd)
FrameArrayforce10%
force(self)
FrameArrayframe340%
frame(self, line)
Decode and unpack the binary status frame using Array's configuration.
FrameArraycollect0
collect(self)
FrameArray__iter__484%
__iter__(self)
Log0
Status frame serialization interface and write buffer.
Loghighlights0
highlights = {
'reset': '\x1b[0m',
'error': '\x1b[31m',
'warning': '\x1b[33m',
'notice': '\x1b[34m',
'synopsis': '\x1b[38;5;247m',
}
@staticmethod
Log_xid180%
_xid(extension, xid)
Logstdout0
stdout(Class)
Construct a Log instance for serializing frames to sys.stdout.
Logstderr0
stderr(Class)
Construct a Log instance for serializing frames to sys.stderr.
Log__init__0
__init__(self, pack, stream, encoding)
Logtransaction325%bool
transaction(self)
Increment the operation count and check if it exceeds the frequency. If in excess, flush the buffer causing serialized messages to be written to the configured stream.
Logflush0
flush(self)
Write any emitted messages to the configured stream and reset the operation count.
Logemit0
emit(self, frame)
Loginject20%
inject(self, data)
Write bytes directly to the log's stream.
Logwrite0
write(self, text)
Write text to the log's stream incrementing the transmit count.
Logdeclare0
declare(self)
Emit a protocol declaration.
Logcompose140%
compose(self, type, severity, qualifier, text, extension)
Lognotice420%
notice(self, *text)
Logwarning420%
warning(self, *text)
Logerror420%
error(self, *text)
Logxact_open0
xact_open(self, xid, synopsis, extension)
Logxact_status0
xact_status(self, xid, synopsis, extension)
Logxact_close0
xact_close(self, xid, synopsis, extension)