openpectus.aggregator.aggregator_message_handlers

Attributes

logger

Classes

AggregatorMessageHandlers

Module Contents

openpectus.aggregator.aggregator_message_handlers.logger

class openpectus.aggregator.aggregator_message_handlers.AggregatorMessageHandlers(aggregator)

Parameters:

aggregator (openpectus.aggregator.aggregator.Aggregator)

aggregator

__str__()

Return type:

str

async handle_RegisterEngineMsg(register_engine_msg)

Registers engine

Parameters:

register_engine_msg (openpectus.protocol.engine_messages.RegisterEngineMsg)

Return type:

openpectus.protocol.aggregator_messages.RegisterEngineReplyMsg

validate_msg(msg)

Parameters:

msg (openpectus.protocol.engine_messages.EngineMessage)

async handle_UodInfoMsg(msg)

Parameters:

msg (openpectus.protocol.engine_messages.UodInfoMsg)

Return type:

openpectus.protocol.aggregator_messages.SuccessMessage | openpectus.protocol.aggregator_messages.ErrorMessage

async handle_EngineConnected(engine_id)

Parameters:

engine_id (str)

async handle_EngineDisconnected(engine_id)

Parameters:

engine_id (str)

async handle_TagsUpdatedMsg(msg)

Parameters:

msg (openpectus.protocol.engine_messages.TagsUpdatedMsg)

Return type:

openpectus.protocol.aggregator_messages.SuccessMessage | openpectus.protocol.aggregator_messages.ErrorMessage

async handle_RunLogMsg(msg)

Parameters:

msg (openpectus.protocol.engine_messages.RunLogMsg)

Return type:

openpectus.protocol.aggregator_messages.SuccessMessage | openpectus.protocol.aggregator_messages.ErrorMessage

async handle_ControlStateMsg(msg)

Parameters:

msg (openpectus.protocol.engine_messages.ControlStateMsg)

Return type:

openpectus.protocol.aggregator_messages.SuccessMessage | openpectus.protocol.aggregator_messages.ErrorMessage

async handle_MethodStateMsg(msg)

Parameters:

msg (openpectus.protocol.engine_messages.MethodStateMsg)

async handle_ErrorLogMsg(msg)

Parameters:

msg (openpectus.protocol.engine_messages.ErrorLogMsg)

async handle_RunStartedMsg(msg)

Parameters:

msg (openpectus.protocol.engine_messages.RunStartedMsg)

async handle_RunStoppedMsg(msg)

Parameters:

msg (openpectus.protocol.engine_messages.RunStoppedMsg)

async handle_MethodMsg(msg)

Parameters:

msg (openpectus.protocol.engine_messages.MethodMsg)

async handle_WebPushNotificationMsg(msg)

Parameters:

msg (openpectus.protocol.engine_messages.WebPushNotificationMsg)