titanfe.messages module

Messages within titanfe

class titanfe.messages.AssignmentContent(brick_description, input_sources, output_targets)

Bases: tuple

brick_description

Alias for field number 0

input_sources

Alias for field number 1

output_targets

Alias for field number 2

class titanfe.messages.BrickDescription(flowname, name, parameters, uid, path_to_module, is_inlet)

Bases: tuple

flowname

Alias for field number 0

is_inlet

Alias for field number 5

name

Alias for field number 1

parameters

Alias for field number 2

path_to_module

Alias for field number 4

uid

Alias for field number 3

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

Bases: tuple

address

Alias for field number 2

name

Alias for field number 0

port

Alias for field number 1

class titanfe.messages.Message(type, content)

Bases: tuple

content

Alias for field number 1

type

Alias for field number 0

class titanfe.messages.MessageType[source]

Bases: enum.IntEnum

Types of Messages used within titanfe

Assignment = 3
AssignmentRequest = 2
ConsumerRegistration = 22
NewInputSource = 6
Packet = 20
PacketRequest = 21
Register = 1
SlowQueueAlert = 5
Terminate = 4
class titanfe.messages.OutputTarget(name, port, autoscale_queue_level)

Bases: tuple

autoscale_queue_level

Alias for field number 2

name

Alias for field number 0

port

Alias for field number 1