titanfe.messages module¶

Messages within titanfe

class titanfe.messages.BrickDescription(flowuid, flowname, name, brick_type, brick_family, parameters, uid, path_to_module, is_inlet, exit_after_idle_seconds, default_port)¶

Bases: tuple

property brick_family¶: Alias for field number 4

property brick_type¶: Alias for field number 3

property default_port¶: Alias for field number 10

property exit_after_idle_seconds¶: Alias for field number 9

property flowname¶: Alias for field number 1

property flowuid¶: Alias for field number 0

property is_inlet¶: Alias for field number 8

property name¶: Alias for field number 2

property parameters¶: Alias for field number 5

property path_to_module¶: Alias for field number 7

property uid¶: Alias for field number 6

class titanfe.messages.InputSource(name, port, address)¶

Bases: tuple

property address¶: Alias for field number 2

property name¶: Alias for field number 0

property port¶: Alias for field number 1

class titanfe.messages.Message(type, content)¶

Bases: tuple

property content¶: Alias for field number 1

property type¶: Alias for field number 0

class titanfe.messages.MessageType(value)[source]¶

Bases: enum.IntEnum

Types of Messages used within titanfe

ConsumerRegistration = 22¶

Packet = 20¶

PacketRequest = 21¶

class titanfe.messages.OutputTarget(name, port, autoscale_queue_level)¶

Bases: tuple

property autoscale_queue_level¶: Alias for field number 2

property name¶: Alias for field number 0

property port¶: Alias for field number 1