fault.transcript

Status frame I/O support.

sys
import

os0
import

io0
import

itertools0
import

signal0
import

tools0
import

execution0
import

frames0
import

allocate_line_buffer10%
function

allocate_line_buffer(fd)

spawnframes230%
function

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
class

IO array manager for frame sources.

FrameArrayio0
method

io(self)

FrameArray__init__0
method

__init__(self)

FrameArray__enter__0
method

__enter__(self)

FrameArray__exit__0
method

__exit__(self, exc, val, tb)

FrameArrayconnect0
method

connect(self, id, fd)

FrameArrayforce10%
method

force(self)

FrameArrayframe340%
method

frame(self, line)

Decode and unpack the binary status frame using Array's configuration.

FrameArraycollect0
method

collect(self)

FrameArray__iter__484%
method

__iter__(self)

Log0
class

Status frame serialization interface and write buffer.

Loghighlights0
data

highlights = {
	'reset': '\x1b[0m',
	'error': '\x1b[31m',
	'warning': '\x1b[33m',
	'notice': '\x1b[34m',
	'synopsis': '\x1b[38;5;247m',
}
	@staticmethod

Log_xid180%
staticmethod

_xid(extension, xid)

Logstdout0
classmethod

stdout(Class)

Construct a Log instance for serializing frames to sys.stdout.

Logstderr0
classmethod

stderr(Class)

Construct a Log instance for serializing frames to sys.stderr.

Log__init__0
method

__init__(self, pack, stream, encoding)

Logtransaction325%
method
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.

Return True when a flush is performed, otherwise False.

Logflush0
method

flush(self)

Write any emitted messages to the configured stream and reset the operation count.

Logemit0
method

emit(self, frame)

Send a message using the given channel identifier.

Loginject20%
method

inject(self, data)

Write bytes directly to the log's stream.

Logwrite0
method

write(self, text)

Write text to the log's stream incrementing the transmit count.

Logdeclare0
method

declare(self)

Emit a protocol declaration.

Logcompose140%
method

compose(self, type, severity, qualifier, text, extension)

Lognotice420%
method

notice(self, *text)

Logwarning420%
method

warning(self, *text)

Logerror420%
method

error(self, *text)

Logxact_open0
method

xact_open(self, xid, synopsis, extension)

Logxact_status0
method

xact_status(self, xid, synopsis, extension)

Logxact_close0
method

xact_close(self, xid, synopsis, extension)