Index

A

AAS AAS Core AAS Manager AAS_INFRASTRUCTURE_SVC_LOG_FILENAME (utilities.AASarchiveInfo.AASarchiveInfo attribute) aas_manager module AAS_MANAGER_LOG_FILENAME (utilities.AASarchiveInfo.AASarchiveInfo attribute) AAS_SERVICES_LOG_FILENAME (utilities.AASarchiveInfo.AASarchiveInfo attribute) AASarchiveInfo (class in utilities.AASarchiveInfo) AASFSMBehaviour (class in behaviours.AASFSMBehaviour) AASManagerAgent (class in agents.AASManagerAgent) AASManagerAppAgent (class in agents.AASManagerAppAgent) AASmanagerInfo (class in utilities.AASmanagerInfo) AASManagerResourceAgent (class in agents.AASManagerResourceAgent)

acl_svc_requests (agents.AASManagerAgent.AASManagerAgent attribute) acl_svc_responses (agents.AASManagerAgent.AASManagerAgent attribute) add_new_svc_request() (in module logic.IntraAASInteractions_utils) add_value_and_unlock_neg_handling_behaviour() (in module logic.Negotiation_utils) agents module agents.AASManagerAgent module agents.AASManagerAppAgent module agents.AASManagerResourceAgent module API ASSET_RELATED_SVC_LOG_FILENAME (utilities.AASarchiveInfo.AASarchiveInfo attribute)

B

behaviours module behaviours.AASFSMBehaviour module behaviours.CheckCoreInitializationBehaviour module behaviours.CheckPhysicalAssetBehaviour module behaviours.EndBehaviour module behaviours.HandleNegotiationBehaviour module behaviours.HandleSvcRequestBehaviour module behaviours.HandleSvcResponseBehaviour module

behaviours.IdleBehaviour module behaviours.InitAASarchiveBehaviour module behaviours.InitSubmodelsBehaviour module behaviours.InteractionHandlingBehaviour module behaviours.NegotiatingBehaviour module behaviours.SvcACLHandlingBehaviour module booting_state_logic() (states.StateBooting.StateBooting method) BOOTING_STATE_NAME (utilities.AASmanagerInfo.AASmanagerInfo attribute)

C

change_status() (in module utilities.AAS_Archive_utils) check_core_initialization() (in module utilities.AAS_Archive_utils) check_if_submodel_exists() (in module utilities.Submodels_utils) CheckCoreInitializationBehaviour (class in behaviours.CheckCoreInitializationBehaviour) CheckPhysicalAssetBehaviour (class in behaviours.CheckPhysicalAssetBehaviour) Class CM_AAS_PROPERTIES_FILENAME (utilities.AASarchiveInfo.AASarchiveInfo attribute) CM_ASSET_PROPERTIES_FILENAME (utilities.AASarchiveInfo.AASarchiveInfo attribute) CM_SM_PROPERTIES_FILENAME (utilities.AASarchiveInfo.AASarchiveInfo attribute) COLORS (utilities.GeneralUtils.GeneralUtils.ColoredFormatter attribute) CONFIG_MAP_PATH (utilities.AASarchiveInfo.AASarchiveInfo attribute) CONFIGURATION_SM_FILENAME (utilities.AASarchiveInfo.AASarchiveInfo attribute) configure_logging() (utilities.GeneralUtils.GeneralUtils static method) CORE_INTERACTIONS_FOLDER_PATH (utilities.AASarchiveInfo.AASarchiveInfo attribute) CORE_STATUS_FILE_PATH (utilities.AASarchiveInfo.AASarchiveInfo attribute) CORE_TOPIC_PARTITION (utilities.KafkaInfo.KafkaInfo attribute) create_acl_msg() (utilities.GeneralUtils.GeneralUtils static method) create_acl_template() (utilities.GeneralUtils.GeneralUtils static method)

create_configuration_sm() (in module utilities.Submodels_utils) create_inter_aas_request_msg() (in module logic.InterAASInteractions_utils) create_inter_aas_response_object() (in module logic.InterAASInteractions_utils) create_interaction_files() (in module utilities.AAS_Archive_utils) create_interaction_kafka_consumer() (in module logic.IntraAASInteractions_utils) create_intra_aas_neg_req_data() (in module logic.Negotiation_utils) create_intra_aas_response_object() (in module logic.IntraAASInteractions_utils) create_log_files() (in module utilities.AAS_Archive_utils) create_neg_cfp_msg() (in module logic.Negotiation_utils) create_neg_json_to_store() (in module logic.Negotiation_utils) create_neg_propose_msg() (in module logic.Negotiation_utils) create_neg_response_msg() (in module logic.Negotiation_utils) create_status_file() (in module utilities.AAS_Archive_utils) create_submodel_files() (in module utilities.Submodels_utils) create_submodel_folder() (in module utilities.Submodels_utils) create_svc_json_data_from_acl_msg() (in module logic.InterAASInteractions_utils) create_svc_request_interaction_json() (in module logic.IntraAASInteractions_utils) create_technical_data_sm() (in module utilities.Submodels_utils)

E

EndBehaviour (class in behaviours.EndBehaviour)

exit_negotiation() (behaviours.HandleNegotiationBehaviour.HandleNegotiationBehaviour method)

F

file_to_json() (in module utilities.AAS_Archive_utils) format() (utilities.GeneralUtils.GeneralUtils.ColoredFormatter method)

FORMAT_COMPLEX (utilities.GeneralUtils.GeneralUtils.ColoredFormatter attribute) FORMAT_SIMPLE (utilities.GeneralUtils.GeneralUtils.ColoredFormatter attribute) Function

G

GeneralUtils (class in utilities.GeneralUtils) GeneralUtils.ColoredFormatter (class in utilities.GeneralUtils) get_aas_general_property() (in module utilities.ConfigMap_utils) get_acl_svc_request() (agents.AASManagerAgent.AASManagerAgent method) get_asset_type() (in module utilities.ConfigMap_utils) get_current_timestamp() (utilities.GeneralUtils.GeneralUtils static method) get_interaction_id() (agents.AASManagerAgent.AASManagerAgent method) get_interaction_request() (agents.AASManagerAgent.AASManagerAgent method)

get_log_file_by_service_type() (in module utilities.AAS_Archive_utils) get_neg_intra_aas_request_by_thread() (in module logic.Negotiation_utils) get_neg_value_with_criteria() (behaviours.HandleNegotiationBehaviour.HandleNegotiationBehaviour method) get_status() (in module utilities.AAS_Archive_utils) get_submodel_information() (in module utilities.ConfigMap_utils) get_submodel_names() (in module utilities.ConfigMap_utils) get_svc_info() (in module logic.IntraAASInteractions_utils) get_svc_request_info() (in module logic.IntraAASInteractions_utils) get_svc_response_info() (in module logic.IntraAASInteractions_utils)

GroupA

Sphinx

GroupB

RST

H

handle_aas_infrastructure_svc() (behaviours.HandleSvcRequestBehaviour.HandleSvcRequestBehaviour method) (behaviours.HandleSvcResponseBehaviour.HandleSvcResponseBehaviour method) handle_aas_services() (behaviours.HandleSvcRequestBehaviour.HandleSvcRequestBehaviour method) (behaviours.HandleSvcResponseBehaviour.HandleSvcResponseBehaviour method) handle_asset_related_svc() (behaviours.HandleSvcRequestBehaviour.HandleSvcRequestBehaviour method) (behaviours.HandleSvcResponseBehaviour.HandleSvcResponseBehaviour method)

handle_submodel_services() (behaviours.HandleSvcRequestBehaviour.HandleSvcRequestBehaviour method) (behaviours.HandleSvcResponseBehaviour.HandleSvcResponseBehaviour method) HandleNegotiationBehaviour (class in behaviours.HandleNegotiationBehaviour) HandleSvcRequestBehaviour (class in behaviours.HandleSvcRequestBehaviour) HandleSvcResponseBehaviour (class in behaviours.HandleSvcResponseBehaviour)

I

IDE IDLE_STATE_NAME (utilities.AASmanagerInfo.AASmanagerInfo attribute) IdleBehaviour (class in behaviours.IdleBehaviour) increase_interaction_id_num() (agents.AASManagerAgent.AASManagerAgent method) Industrial Agent InitAASarchiveBehaviour (class in behaviours.InitAASarchiveBehaviour) initialize_aas_manager_attributes() (agents.AASManagerAgent.AASManagerAgent method)

InitSubmodelsBehaviour (class in behaviours.InitSubmodelsBehaviour) Inter AAS Interaction interaction_id_num (agents.AASManagerAgent.AASManagerAgent attribute) interaction_requests (agents.AASManagerAgent.AASManagerAgent attribute) interaction_responses (agents.AASManagerAgent.AASManagerAgent attribute) InteractionHandlingBehaviour (class in behaviours.InteractionHandlingBehaviour) INTERACTIONS_FOLDER_PATH (utilities.AASarchiveInfo.AASarchiveInfo attribute) Intra AAS Interaction

K

KAFKA_SERVER_IP (utilities.KafkaInfo.KafkaInfo attribute)

KAFKA_TOPIC (utilities.KafkaInfo.KafkaInfo attribute) KafkaInfo (class in utilities.KafkaInfo)

L

lock (agents.AASManagerAgent.AASManagerAgent attribute) LOG_FOLDER_PATH (utilities.AASarchiveInfo.AASarchiveInfo attribute) logic module logic.InterAASInteractions_utils module

logic.IntraAASInteractions_utils module logic.Negotiation_utils module logic.Services_utils module

M

main() (in module aas_manager) MANAGER_INTERACTIONS_FOLDER_PATH (utilities.AASarchiveInfo.AASarchiveInfo attribute) MANAGER_STATUS_FILE_PATH (utilities.AASarchiveInfo.AASarchiveInfo attribute) MANAGER_TOPIC_PARTITION (utilities.KafkaInfo.KafkaInfo attribute) Method module aas_manager agents agents.AASManagerAgent agents.AASManagerAppAgent agents.AASManagerResourceAgent behaviours behaviours.AASFSMBehaviour behaviours.CheckCoreInitializationBehaviour behaviours.CheckPhysicalAssetBehaviour behaviours.EndBehaviour behaviours.HandleNegotiationBehaviour behaviours.HandleSvcRequestBehaviour behaviours.HandleSvcResponseBehaviour behaviours.IdleBehaviour behaviours.InitAASarchiveBehaviour behaviours.InitSubmodelsBehaviour behaviours.InteractionHandlingBehaviour behaviours.NegotiatingBehaviour behaviours.SvcACLHandlingBehaviour logic logic.InterAASInteractions_utils logic.IntraAASInteractions_utils logic.Negotiation_utils logic.Services_utils states states.StateBooting states.StateBootingResource states.StateIdle states.StateRunning states.StateStopping utilities utilities.AAS_Archive_utils utilities.AASarchiveInfo utilities.AASmanagerInfo utilities.ConfigMap_utils utilities.GeneralUtils utilities.KafkaInfo utilities.Submodels_utils

Multi-Agent System myagent (behaviours.HandleNegotiationBehaviour.HandleNegotiationBehaviour attribute)

N

neg_criteria (behaviours.HandleNegotiationBehaviour.HandleNegotiationBehaviour attribute) neg_requester_jid (behaviours.HandleNegotiationBehaviour.HandleNegotiationBehaviour attribute) NEG_STANDARD_ACL_TEMPLATE (utilities.AASmanagerInfo.AASmanagerInfo attribute) NEG_STANDARD_ACL_TEMPLATE_CFP (utilities.AASmanagerInfo.AASmanagerInfo attribute) NEG_STANDARD_ACL_TEMPLATE_FAILURE (utilities.AASmanagerInfo.AASmanagerInfo attribute)

NEG_STANDARD_ACL_TEMPLATE_INFORM (utilities.AASmanagerInfo.AASmanagerInfo attribute) NEG_STANDARD_ACL_TEMPLATE_PROPOSE (utilities.AASmanagerInfo.AASmanagerInfo attribute) neg_value (behaviours.HandleNegotiationBehaviour.HandleNegotiationBehaviour attribute) neg_value_event (behaviours.HandleNegotiationBehaviour.HandleNegotiationBehaviour attribute) NegotiatingBehaviour (class in behaviours.NegotiatingBehaviour) negotiations_data (agents.AASManagerAgent.AASManagerAgent attribute)

O

Object on_end() (behaviours.AASFSMBehaviour.AASFSMBehaviour method) on_start() (behaviours.AASFSMBehaviour.AASFSMBehaviour method) (behaviours.HandleNegotiationBehaviour.HandleNegotiationBehaviour method) (behaviours.HandleSvcRequestBehaviour.HandleSvcRequestBehaviour method) (behaviours.HandleSvcResponseBehaviour.HandleSvcResponseBehaviour method) (behaviours.InteractionHandlingBehaviour.InteractionHandlingBehaviour method) (behaviours.NegotiatingBehaviour.NegotiatingBehaviour method) (behaviours.SvcACLHandlingBehaviour.SvcACLHandlingBehaviour method)

R

remove_acl_svc_request() (agents.AASManagerAgent.AASManagerAgent method) remove_interaction_request() (agents.AASManagerAgent.AASManagerAgent method) RESET (utilities.GeneralUtils.GeneralUtils.ColoredFormatter attribute) run() (behaviours.CheckCoreInitializationBehaviour.CheckCoreInitializationBehaviour method) (behaviours.CheckPhysicalAssetBehaviour.CheckPhysicalAssetBehaviour method) (behaviours.EndBehaviour.EndBehaviour method) (behaviours.HandleNegotiationBehaviour.HandleNegotiationBehaviour method) (behaviours.HandleSvcRequestBehaviour.HandleSvcRequestBehaviour method) (behaviours.HandleSvcResponseBehaviour.HandleSvcResponseBehaviour method) (behaviours.IdleBehaviour.IdleBehaviour method) (behaviours.InitAASarchiveBehaviour.InitAASarchiveBehaviour method) (behaviours.InitSubmodelsBehaviour.InitSubmodelsBehaviour method) (behaviours.InteractionHandlingBehaviour.InteractionHandlingBehaviour method) (behaviours.NegotiatingBehaviour.NegotiatingBehaviour method) (behaviours.SvcACLHandlingBehaviour.SvcACLHandlingBehaviour method) (states.StateBooting.StateBooting method) (states.StateBootingResource.StateBootingResource method) (states.StateIdle.StateIdle method) (states.StateRunning.StateRunning method) (states.StateStopping.StateStopping method)

RUNNING_STATE_NAME (utilities.AASmanagerInfo.AASmanagerInfo attribute)

S

save_acl_svc_response() (agents.AASManagerAgent.AASManagerAgent method) save_interaction_request() (agents.AASManagerAgent.AASManagerAgent method) save_interaction_response() (agents.AASManagerAgent.AASManagerAgent method) save_negotiation_data() (agents.AASManagerAgent.AASManagerAgent method) save_new_acl_svc_request() (agents.AASManagerAgent.AASManagerAgent method) save_new_interaction_request() (agents.AASManagerAgent.AASManagerAgent method) save_svc_info_in_log_file() (in module logic.IntraAASInteractions_utils) save_svc_log_info() (in module utilities.AAS_Archive_utils) send_interaction_msg_to_core() (in module logic.IntraAASInteractions_utils) setup() (agents.AASManagerAgent.AASManagerAgent method) (agents.AASManagerAppAgent.AASManagerAppAgent method) (agents.AASManagerResourceAgent.AASManagerResourceAgent method) StateBooting (class in states.StateBooting) StateBootingResource (class in states.StateBootingResource) StateIdle (class in states.StateIdle) StateRunning (class in states.StateRunning) states module states.StateBooting module

states.StateBootingResource module states.StateIdle module states.StateRunning module states.StateStopping module StateStopping (class in states.StateStopping) STOPPING_STATE_NAME (utilities.AASmanagerInfo.AASmanagerInfo attribute) SUBMODEL_FOLDER_PATH (utilities.AASarchiveInfo.AASarchiveInfo attribute) SUBMODEL_SERVICES_LOG_FILENAME (utilities.AASarchiveInfo.AASarchiveInfo attribute) SVC_LOG_FOLDER_PATH (utilities.AASarchiveInfo.AASarchiveInfo attribute) SVC_REQUEST_FILE_SUBPATH (utilities.AASarchiveInfo.AASarchiveInfo attribute) SVC_RESPONSE_FILE_SUBPATH (utilities.AASarchiveInfo.AASarchiveInfo attribute) SVC_STANDARD_ACL_TEMPLATE (utilities.AASmanagerInfo.AASmanagerInfo attribute) SVC_STANDARD_ACL_TEMPLATE_CFP (utilities.AASmanagerInfo.AASmanagerInfo attribute) SVC_STANDARD_ACL_TEMPLATE_INFORM (utilities.AASmanagerInfo.AASmanagerInfo attribute) SvcACLHandlingBehaviour (class in behaviours.SvcACLHandlingBehaviour)

T

targets (behaviours.HandleNegotiationBehaviour.HandleNegotiationBehaviour attribute) targets_processed (behaviours.HandleNegotiationBehaviour.HandleNegotiationBehaviour attribute)

TECHNICAL_DATA_SM_FILENAME (utilities.AASarchiveInfo.AASarchiveInfo attribute) thread (behaviours.HandleNegotiationBehaviour.HandleNegotiationBehaviour attribute) TODO

U

update_json_file() (in module utilities.AAS_Archive_utils) utilities module utilities.AAS_Archive_utils module utilities.AASarchiveInfo module utilities.AASmanagerInfo module

utilities.ConfigMap_utils module utilities.GeneralUtils module utilities.KafkaInfo module utilities.Submodels_utils module

V

Variable

X

xml_to_file() (in module utilities.AAS_Archive_utils)