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)

Bases: object

Wraps all the Brick-Handling

create_instance()

create an instance of the actual Brick

enqueue_result_as_packet(result, port=None, parent_packet=None)

create a packet with an empty buffer if needed and add the bricks result to the packets payload

async execute_brick(packet)

run the brick module for the given packet in a separate thread

property execution_time

get_results()

async generator over the results from the brick

async process(packet)

run_instance_processing(payload, port)

do the actual execution of the brick module and return it’s result

terminate()

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