titanfe.apps.brick_runner.brick module
A Brick within the brick runner
-
class
titanfe.apps.brick_runner.brick.
Brick
(instance_definition: titanfe.apps.control_peer.brick.BrickInstanceDefinition, metric_emitter, logger)[source]
Bases: object
Wraps all the Brick-Handling
-
create_instance
()[source]
create an instance of the actual Brick
-
enqueue_result_as_packet
(result, port=None, parent_packet=None)[source]
create a packet with an empty buffer if needed and
add the bricks result to the packets payload
-
async
execute_brick
(packet)[source]
run the brick module for the given packet in a separate thread
-
property
execution_time
-
get_results
()[source]
async generator over the results from the brick
-
async
process
(packet)[source]
-
run_instance_processing
(payload, port)[source]
do the actual execution of the brick module and return it’s result
-
terminate
()[source]
-
class
titanfe.apps.brick_runner.brick.
PortMapping
(rules, type)
Bases: tuple
-
property
rules
Alias for field number 0
-
property
type
Alias for field number 1