Index _ | A | B | C | D | E | F | G | I | K | L | M | N | O | P | Q | R | S | T | U | V | W _ __init__() (openfactory.apps.ofaapp.OpenFactoryApp method) (openfactory.apps.supervisor.BaseSupervisor method) (openfactory.apps.supervisor.OPCUASupervisor method) (openfactory.assets.Asset method) (openfactory.assets.asset_base.AssetKafkaMessagesCallback method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) (openfactory.assets.utils.AssetAttribute method) (openfactory.kafka.asset_consumer.KafkaAssetConsumer method) (openfactory.kafka.asset_uns_consumer.KafkaAssetUNSConsumer method) (openfactory.kafka.AssetProducer method) (openfactory.kafka.commands_consumer.KafkaCommandsConsumer method) (openfactory.kafka.kafka_logger.KafkaLogger method) (openfactory.kafka.ksql.KSQLDBClient method) (openfactory.OpenFactory method) (openfactory.OpenFactoryCluster method) (openfactory.OpenFactoryManager method) (openfactory.schemas.devices.Device method) (openfactory.schemas.uns.UNSSchema method) (openfactory.utils.github_tokenstore.GitHubTokenStore method) _device_uuid (openfactory.apps.supervisor.BaseSupervisor attribute) _event_loop (openfactory.apps.supervisor.OPCUASupervisor attribute) _stop_reconnect (openfactory.apps.supervisor.OPCUASupervisor attribute) A Adapter (class in openfactory.schemas.devices) adapter (openfactory.schemas.devices.Agent attribute) (openfactory.schemas.devices.Supervisor attribute) adapter_ip (openfactory.apps.supervisor.OPCUASupervisor attribute) adapter_port (openfactory.apps.supervisor.OPCUASupervisor attribute) add_attribute() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) add_label() (openfactory.OpenFactoryCluster method) add_reference_above() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) add_reference_below() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) add_token() (openfactory.utils.github_tokenstore.GitHubTokenStore method) Agent (class in openfactory.schemas.devices) agent (openfactory.schemas.devices.Device attribute) agents() (openfactory.OpenFactory method) agents_uuid() (openfactory.OpenFactory method) allowed_values (openfactory.schemas.uns.UNSSchema attribute) app_event_loop_stopped() (openfactory.apps.ofaapp.OpenFactoryApp method) (openfactory.apps.supervisor.OPCUASupervisor method) APPLICATION_LICENSE (openfactory.apps.ofaapp.OpenFactoryApp attribute) APPLICATION_MANUFACTURER (openfactory.apps.ofaapp.OpenFactoryApp attribute) APPLICATION_VERSION (openfactory.apps.ofaapp.OpenFactoryApp attribute) applications() (openfactory.OpenFactory method) applications_uuid() (openfactory.OpenFactory method) apps (openfactory.schemas.apps.OpenFactoryAppsConfig attribute) apps_dict (openfactory.schemas.apps.OpenFactoryAppsConfig property) Asset (class in openfactory.assets) ASSET_CONSUMER_CLASS (openfactory.assets.Asset attribute) (openfactory.assets.asset_base.BaseAsset attribute) (openfactory.assets.AssetUNS attribute) ASSET_ID (openfactory.assets.asset_base.BaseAsset attribute) (openfactory.assets.AssetUNS attribute) asset_uuid (openfactory.assets.Asset attribute) (openfactory.assets.asset_base.BaseAsset property) (openfactory.assets.AssetUNS property) (openfactory.kafka.AssetProducer attribute) AssetAttribute (class in openfactory.assets.utils) AssetKafkaMessagesCallback (class in openfactory.assets.asset_base) AssetProducer (class in openfactory.kafka) assets() (openfactory.OpenFactory method) assets_availability() (openfactory.OpenFactory method) assets_docker_services() (openfactory.OpenFactory method) assets_uuid() (openfactory.OpenFactory method) AssetUNS (class in openfactory.assets) attributes() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) aux_addresses (openfactory.schemas.infra.IPAMConfig attribute) available_commands() (openfactory.apps.supervisor.BaseSupervisor method) (openfactory.apps.supervisor.OPCUASupervisor method) B BaseAsset (class in openfactory.assets.asset_base) BaseSupervisor (class in openfactory.apps.supervisor) bootstrap_servers (openfactory.assets.Asset attribute) (openfactory.assets.asset_base.BaseAsset attribute) (openfactory.assets.AssetUNS attribute) browseName (openfactory.apps.supervisor.OPCUASupervisor attribute) C CaseInsensitiveDict (class in openfactory.kafka) check_one_key() (openfactory.schemas.uns.NamespaceItem method) check_template_fields() (openfactory.schemas.uns.UNSSchemaModel method) check_unique_ips() (openfactory.schemas.infra.Nodes class method) close() (openfactory.kafka.ksql.KSQLDBClient method) conditions() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) config (openfactory.schemas.infra.IPAM attribute) constraints (openfactory.schemas.devices.Placement attribute) ConstraintType (in module openfactory.schemas.uns) consume() (openfactory.kafka.asset_consumer.KafkaAssetConsumer method) (openfactory.kafka.commands_consumer.KafkaCommandsConsumer method) consumer_timeout (openfactory.kafka.asset_consumer.KafkaAssetConsumer attribute) (openfactory.kafka.commands_consumer.KafkaCommandsConsumer attribute) cpus (openfactory.schemas.devices.ResourcesDefinition attribute) create_device_ksqldb_tables() (openfactory.OpenFactoryManager method) create_infrastack_from_config_file() (openfactory.OpenFactoryCluster method) create_managers() (openfactory.OpenFactoryCluster method) create_workers() (openfactory.OpenFactoryCluster method) current_timestamp() (in module openfactory.assets.utils) D Deploy (class in openfactory.schemas.devices) deploy (openfactory.schemas.devices.Adapter attribute) (openfactory.schemas.devices.Agent attribute) (openfactory.schemas.devices.Supervisor attribute) deploy() (openfactory.openfactory_deploy_strategy.LocalDockerDeploymentStrategy method) (openfactory.openfactory_deploy_strategy.OpenFactoryServiceDeploymentStrategy method) (openfactory.openfactory_deploy_strategy.SwarmDeploymentStrategy method) deploy_apps_from_config_file() (openfactory.OpenFactoryManager method) deploy_device_supervisor() (openfactory.OpenFactoryManager method) deploy_devices_from_config_file() (openfactory.OpenFactoryManager method) deploy_kafka_producer() (openfactory.OpenFactoryManager method) deploy_mtconnect_adapter() (openfactory.OpenFactoryManager method) deploy_mtconnect_agent() (openfactory.OpenFactoryManager method) deploy_openfactory_application() (openfactory.OpenFactoryManager method) deployment_strategy (openfactory.OpenFactoryManager attribute) deregister_asset() (in module openfactory.utils.assets) Device (class in openfactory.schemas.devices) device_xml (openfactory.schemas.devices.Agent attribute) devices (openfactory.schemas.devices.DevicesConfig attribute) devices() (openfactory.OpenFactory method) devices_dict (openfactory.schemas.devices.DevicesConfig property) devices_uuid() (openfactory.OpenFactory method) DevicesConfig (class in openfactory.schemas.devices) docker_ingress_network (openfactory.schemas.infra.Networks attribute) DockerComposeException driver_opts (openfactory.schemas.infra.Volume attribute) E environment (openfactory.schemas.apps.OpenFactoryApp attribute) (openfactory.schemas.devices.Adapter attribute) events() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) extract_uns_fields() (openfactory.schemas.uns.UNSSchema method) F filter_messages() (openfactory.kafka.asset_consumer.KafkaAssetConsumer method) (openfactory.kafka.commands_consumer.KafkaCommandsConsumer method) find_yaml_files() (in module openfactory.utils) G gateway (openfactory.schemas.infra.IPAMConfig attribute) generate_uns_path() (openfactory.schemas.uns.UNSSchema method) get_apps_from_config_file() (in module openfactory.schemas.apps) get_asset_uuid_from_docker_service() (openfactory.OpenFactoryManager method) get_devices_from_config_file() (in module openfactory.schemas.devices) get_infrastructure_from_config_file() (in module openfactory.schemas.infra) get_kafka_topic() (openfactory.kafka.ksql.KSQLDBClient method) get_nested() (in module openfactory.utils) get_token() (openfactory.utils.github_tokenstore.GitHubTokenStore method) GitHubTokenStore (class in openfactory.utils.github_tokenstore) I idx (openfactory.apps.supervisor.OPCUASupervisor attribute) image (openfactory.schemas.apps.OpenFactoryApp attribute) (openfactory.schemas.devices.Adapter attribute) (openfactory.schemas.devices.Supervisor attribute) info() (openfactory.kafka.ksql.KSQLDBClient method) InfrastructureSchema (class in openfactory.schemas.infra) insert_into_stream() (openfactory.kafka.ksql.KSQLDBClient method) ip (openfactory.schemas.devices.Adapter attribute) (openfactory.schemas.devices.Agent attribute) (openfactory.schemas.infra.Node attribute) ip_range (openfactory.schemas.infra.IPAMConfig attribute) IPAM (class in openfactory.schemas.infra) ipam (openfactory.schemas.infra.Network attribute) IPAMConfig (class in openfactory.schemas.infra) K KafkaAssetConsumer (class in openfactory.kafka.asset_consumer) KafkaAssetUNSConsumer (class in openfactory.kafka.asset_uns_consumer) KafkaCommandsConsumer (class in openfactory.kafka.commands_consumer) KafkaLogger (class in openfactory.kafka.kafka_logger) key() (openfactory.schemas.uns.NamespaceItem method) ksql (openfactory.assets.Asset attribute) (openfactory.assets.asset_base.BaseAsset attribute) (openfactory.assets.AssetUNS attribute) (openfactory.kafka.AssetProducer attribute) KSQL_ASSET_ID (openfactory.assets.asset_base.BaseAsset attribute) (openfactory.assets.AssetUNS attribute) KSQL_ASSET_STREAM (openfactory.kafka.asset_consumer.KafkaAssetConsumer attribute) (openfactory.kafka.asset_uns_consumer.KafkaAssetUNSConsumer attribute) KSQL_ASSET_TABLE (openfactory.assets.asset_base.BaseAsset attribute) (openfactory.assets.AssetUNS attribute) ksql_tables (openfactory.schemas.devices.Device attribute) KSQLDBClient (class in openfactory.kafka.ksql) KSQLDBClientException L labels (openfactory.schemas.infra.Node attribute) level (openfactory.kafka.kafka_logger.KafkaLogger property) limits (openfactory.schemas.devices.Resources attribute) list_tokens() (openfactory.utils.github_tokenstore.GitHubTokenStore method) load_tokens() (openfactory.utils.github_tokenstore.GitHubTokenStore method) LocalDockerDeploymentStrategy (class in openfactory.openfactory_deploy_strategy) logger (openfactory.apps.ofaapp.OpenFactoryApp attribute) (openfactory.kafka.kafka_logger.KafkaLogger property) M main_loop() (openfactory.apps.ofaapp.OpenFactoryApp method) (openfactory.apps.supervisor.BaseSupervisor method) Managers (class in openfactory.schemas.infra) managers (openfactory.schemas.infra.Nodes attribute) memory (openfactory.schemas.devices.ResourcesDefinition attribute) method() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) methods() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) model_config (openfactory.schemas.apps.OpenFactoryApp attribute) (openfactory.schemas.apps.OpenFactoryAppsConfig attribute) (openfactory.schemas.devices.Adapter attribute) (openfactory.schemas.devices.Agent attribute) (openfactory.schemas.devices.Deploy attribute) (openfactory.schemas.devices.Device attribute) (openfactory.schemas.devices.DevicesConfig attribute) (openfactory.schemas.devices.Placement attribute) (openfactory.schemas.devices.Resources attribute) (openfactory.schemas.devices.ResourcesDefinition attribute) (openfactory.schemas.devices.Supervisor attribute) (openfactory.schemas.infra.InfrastructureSchema attribute) (openfactory.schemas.infra.IPAM attribute) (openfactory.schemas.infra.IPAMConfig attribute) (openfactory.schemas.infra.Managers attribute) (openfactory.schemas.infra.Network attribute) (openfactory.schemas.infra.Networks attribute) (openfactory.schemas.infra.Node attribute) (openfactory.schemas.infra.Nodes attribute) (openfactory.schemas.infra.Volume attribute) (openfactory.schemas.infra.Volumes attribute) (openfactory.schemas.infra.Workers attribute) (openfactory.schemas.uns.NamespaceItem attribute) (openfactory.schemas.uns.UNSSchemaModel attribute) module openfactory.assets.utils openfactory.exceptions openfactory.kafka.asset_consumer openfactory.kafka.asset_uns_consumer openfactory.kafka.commands_consumer openfactory.kafka.kafka_logger openfactory.kafka.ksql openfactory.schemas.apps openfactory.schemas.devices openfactory.schemas.infra openfactory.schemas.uns openfactory.utils openfactory.utils.assets openfactory.utils.github_tokenstore openfactory.utils.open_uris N name (openfactory.schemas.infra.Network attribute) namespace_structure (openfactory.schemas.uns.UNSSchemaModel attribute) namespace_uri (openfactory.apps.supervisor.OPCUASupervisor attribute) NamespaceItem (class in openfactory.schemas.uns) Network (class in openfactory.schemas.infra) Networks (class in openfactory.schemas.infra) networks (openfactory.schemas.infra.InfrastructureSchema attribute) Node (class in openfactory.schemas.infra) Nodes (class in openfactory.schemas.infra) nodes (openfactory.schemas.infra.InfrastructureSchema attribute) now_iso_to_epoch_millis() (in module openfactory.utils.assets) O OFAConfigurationException OFAException on_command() (openfactory.apps.supervisor.BaseSupervisor method) (openfactory.apps.supervisor.OPCUASupervisor method) opcua_adapter (openfactory.apps.supervisor.OPCUASupervisor attribute) opcua_client (openfactory.apps.supervisor.OPCUASupervisor attribute) OPCUASupervisor (class in openfactory.apps.supervisor) open_github() (in module openfactory.utils.open_uris) open_ofa() (in module openfactory.utils.open_uris) OpenFactory (class in openfactory) openfactory.assets.utils module openfactory.exceptions module openfactory.kafka.asset_consumer module openfactory.kafka.asset_uns_consumer module openfactory.kafka.commands_consumer module openfactory.kafka.kafka_logger module openfactory.kafka.ksql module openfactory.schemas.apps module openfactory.schemas.devices module openfactory.schemas.infra module openfactory.schemas.uns module openfactory.utils module openfactory.utils.assets module openfactory.utils.github_tokenstore module openfactory.utils.open_uris module openfactory_network (openfactory.schemas.infra.Networks attribute) OpenFactoryApp (class in openfactory.apps.ofaapp) (class in openfactory.schemas.apps) OpenFactoryAppsConfig (class in openfactory.schemas.apps) OpenFactoryCluster (class in openfactory) OpenFactoryManager (class in openfactory) OpenFactoryServiceDeploymentStrategy (class in openfactory.openfactory_deploy_strategy) P Placement (class in openfactory.schemas.devices) placement (openfactory.schemas.devices.Deploy attribute) port (openfactory.schemas.devices.Adapter attribute) (openfactory.schemas.devices.Agent attribute) producer (openfactory.assets.Asset attribute) (openfactory.assets.asset_base.BaseAsset attribute) (openfactory.assets.AssetUNS attribute) producers() (openfactory.OpenFactory method) producers_uuid() (openfactory.OpenFactory method) Q query() (openfactory.kafka.ksql.KSQLDBClient method) R RECONNECT_INTERVAL (openfactory.apps.supervisor.OPCUASupervisor attribute) references_above() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) references_above_uuid() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) references_below() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) references_below_uuid() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) register_asset() (in module openfactory.utils.assets) remove() (openfactory.openfactory_deploy_strategy.LocalDockerDeploymentStrategy method) (openfactory.openfactory_deploy_strategy.OpenFactoryServiceDeploymentStrategy method) (openfactory.openfactory_deploy_strategy.SwarmDeploymentStrategy method) remove_infrastack_from_config_file() (openfactory.OpenFactoryCluster method) remove_workers() (openfactory.OpenFactoryCluster method) replicas (openfactory.schemas.devices.Deploy attribute) reservations (openfactory.schemas.devices.Resources attribute) Resources (class in openfactory.schemas.devices) resources (openfactory.schemas.devices.Deploy attribute) ResourcesDefinition (class in openfactory.schemas.devices) run() (openfactory.apps.ofaapp.OpenFactoryApp method) S samples() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) save_tokens() (openfactory.utils.github_tokenstore.GitHubTokenStore method) send_asset_attribute() (openfactory.kafka.AssetProducer method) separator (openfactory.schemas.uns.UNSSchema attribute) shut_down_apps_from_config_file() (openfactory.OpenFactoryManager method) shut_down_devices_from_config_file() (openfactory.OpenFactoryManager method) signal_handler() (openfactory.apps.ofaapp.OpenFactoryApp method) statement_query() (openfactory.kafka.ksql.KSQLDBClient method) stop() (openfactory.kafka.asset_consumer.KafkaAssetConsumer method) (openfactory.kafka.commands_consumer.KafkaCommandsConsumer method) stop_conditions_subscription() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) stop_events_subscription() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) stop_messages_subscription() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) stop_samples_subscription() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) streams() (openfactory.kafka.ksql.KSQLDBClient method) subnet (openfactory.schemas.infra.IPAMConfig attribute) subscribe_to_conditions() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) subscribe_to_events() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) subscribe_to_messages() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) subscribe_to_samples() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) Supervisor (class in openfactory.schemas.devices) supervisor (openfactory.schemas.devices.Device attribute) supervisors() (openfactory.OpenFactory method) supervisors_uuid() (openfactory.OpenFactory method) SwarmDeploymentStrategy (class in openfactory.openfactory_deploy_strategy) T tables() (openfactory.kafka.ksql.KSQLDBClient method) tag (openfactory.assets.utils.AssetAttribute attribute) tear_down_application() (openfactory.OpenFactoryManager method) tear_down_device() (openfactory.OpenFactoryManager method) template_fields (openfactory.schemas.uns.UNSSchema attribute) timestamp (openfactory.assets.utils.AssetAttribute attribute) topic (openfactory.kafka.AssetProducer attribute) type (openfactory.assets.Asset property) (openfactory.assets.asset_base.BaseAsset property) (openfactory.assets.AssetUNS property) (openfactory.assets.utils.AssetAttribute attribute) U uns_template (openfactory.schemas.uns.UNSSchemaModel attribute) UNSSchema (class in openfactory.schemas.uns) UNSSchemaModel (class in openfactory.schemas.uns) uuid (openfactory.schemas.apps.OpenFactoryApp attribute) (openfactory.schemas.devices.Device attribute) V validate_adapter() (openfactory.schemas.devices.Adapter class method) validate_agent() (openfactory.schemas.devices.Agent class method) validate_devices() (openfactory.schemas.devices.DevicesConfig method) validate_ksql_tables() (openfactory.schemas.devices.Device class method) validate_uns_fields() (openfactory.schemas.uns.UNSSchema method) value (openfactory.assets.utils.AssetAttribute attribute) value() (openfactory.schemas.uns.NamespaceItem method) Volume (class in openfactory.schemas.infra) Volumes (class in openfactory.schemas.infra) volumes (openfactory.schemas.infra.InfrastructureSchema attribute) W wait_until() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) welcome_banner() (openfactory.apps.ofaapp.OpenFactoryApp method) (openfactory.apps.supervisor.OPCUASupervisor method) Workers (class in openfactory.schemas.infra) workers (openfactory.schemas.infra.Nodes attribute)