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.BaseAsset method) (openfactory.assets.AssetUNS method) (openfactory.assets.utils.AssetAttribute method) (openfactory.assets.utils.AssetNATSCallback method) (openfactory.assets.utils.AsyncLoopThread method) (openfactory.assets.utils.NATSSubscriber method) (openfactory.connectors.mtconnect.mtc_connector.MTConnectConnector method) (openfactory.connectors.mtconnect.mtcagent_deployer.MTConnectAgentDeployer method) (openfactory.connectors.opcua.opcua_connector.OPCUAConnector method) (openfactory.filelayer.backend.FileBackend method) (openfactory.filelayer.local_backend.LocalBackend method) (openfactory.filelayer.nfs_backend.NFSBackend method) (openfactory.kafka.asset_consumer.KafkaAssetConsumer method) (openfactory.kafka.asset_producer.AssetProducer method) (openfactory.kafka.asset_uns_consumer.KafkaAssetUNSConsumer method) (openfactory.kafka.commands_consumer.KafkaCommandsConsumer method) (openfactory.kafka.kafka_logger.KafkaLogger method) (openfactory.kafka.ksql.KSQLDBClient method) (openfactory.openfactory.OpenFactory method) (openfactory.openfactory_cluster.OpenFactoryCluster method) (openfactory.openfactory_manager.OpenFactoryManager 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 access_level (openfactory.schemas.connectors.opcua.OPCUAVariableConfig attribute) Adapter (class in openfactory.schemas.connectors.mtconnect) adapter (openfactory.schemas.connectors.mtconnect.Agent attribute) (openfactory.schemas.supervisors.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.openfactory_cluster.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.connectors.mtconnect) agent (openfactory.schemas.connectors.mtconnect.MTConnectConnectorSchema attribute) agents() (openfactory.openfactory.OpenFactory method) agents_uuid() (openfactory.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.OpenFactory method) applications_uuid() (openfactory.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.asset_producer.AssetProducer attribute) AssetAttribute (class in openfactory.assets.utils) AssetNATSCallback (class in openfactory.assets.utils) AssetProducer (class in openfactory.kafka.asset_producer) assets() (openfactory.openfactory.OpenFactory method) assets_availability() (openfactory.openfactory.OpenFactory method) assets_docker_services() (openfactory.openfactory.OpenFactory method) assets_uuid() (openfactory.openfactory.OpenFactory method) AssetUNS (class in openfactory.assets) async_main_loop() (openfactory.apps.ofaapp.OpenFactoryApp method) async_run() (openfactory.apps.ofaapp.OpenFactoryApp method) AsyncLoopThread (class in openfactory.assets.utils) attach_uns() (openfactory.schemas.uns.AttachUNSMixin method) AttachUNSMixin (class in openfactory.schemas.uns) 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) BaseBackendConfig (class in openfactory.schemas.filelayer.base_backend) BaseSupervisor (class in openfactory.apps.supervisor) bootstrap_servers (openfactory.assets.Asset attribute) (openfactory.assets.asset_base.BaseAsset attribute) (openfactory.assets.AssetUNS attribute) browse_path (openfactory.schemas.connectors.opcua.OPCUANodeConfig 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 method) clean_mount_options() (openfactory.schemas.filelayer.nfs_backend.NFSBackendConfig class method) close() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) (openfactory.kafka.ksql.KSQLDBClient method) compatible_with_swarm() (openfactory.filelayer.backend.FileBackend method) (openfactory.filelayer.local_backend.LocalBackend method) conditions() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) config (openfactory.schemas.infra.IPAM attribute) Connector (class in openfactory.connectors.base_connector) (in module openfactory.schemas.connectors.types) connector (openfactory.schemas.devices.Device attribute) constraints (openfactory.schemas.common.Placement attribute) constraints() (in module openfactory.schemas.common) 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.common.ResourcesDefinition attribute) cpus_limit() (in module openfactory.schemas.common) cpus_reservation() (in module openfactory.schemas.common) create_backend_instance() (openfactory.schemas.filelayer.base_backend.BaseBackendConfig method) (openfactory.schemas.filelayer.local_backend.LocalBackendConfig method) (openfactory.schemas.filelayer.nfs_backend.NFSBackendConfig method) create_infrastack_from_config_file() (openfactory.openfactory_cluster.OpenFactoryCluster method) create_managers() (openfactory.openfactory_cluster.OpenFactoryCluster method) create_workers() (openfactory.openfactory_cluster.OpenFactoryCluster method) current_timestamp() (in module openfactory.assets.utils) D deadband (openfactory.schemas.connectors.opcua.OPCUAVariableConfig attribute) delete() (openfactory.filelayer.backend.FileBackend method) (openfactory.filelayer.local_backend.LocalBackend method) (openfactory.filelayer.nfs_backend.NFSBackend method) Deploy (class in openfactory.schemas.common) deploy (openfactory.schemas.connectors.mtconnect.Adapter attribute) (openfactory.schemas.connectors.mtconnect.Agent attribute) (openfactory.schemas.supervisors.Supervisor attribute) (openfactory.schemas.supervisors.SupervisorAdapter attribute) deploy() (openfactory.connectors.base_connector.Connector method) (openfactory.connectors.mtconnect.mtc_connector.MTConnectConnector method) (openfactory.connectors.mtconnect.mtcagent_deployer.MTConnectAgentDeployer method) (openfactory.connectors.opcua.opcua_connector.OPCUAConnector method) (openfactory.openfactory_deploy_strategy.LocalDockerDeploymentStrategy method) (openfactory.openfactory_deploy_strategy.OpenFactoryServiceDeploymentStrategy method) (openfactory.openfactory_deploy_strategy.SwarmDeploymentStrategy method) deploy_adapter() (openfactory.connectors.mtconnect.mtcagent_deployer.MTConnectAgentDeployer method) deploy_adapter_if_needed() (openfactory.connectors.mtconnect.mtcagent_deployer.MTConnectAgentDeployer method) deploy_apps_from_config_file() (openfactory.openfactory_manager.OpenFactoryManager method) deploy_device_supervisor() (openfactory.openfactory_manager.OpenFactoryManager method) deploy_devices_from_config_file() (openfactory.openfactory_manager.OpenFactoryManager method) deploy_kafka_producer() (openfactory.connectors.mtconnect.mtc_connector.MTConnectConnector method) deploy_opcua_producer() (openfactory.connectors.opcua.opcua_connector.OPCUAConnector method) deploy_openfactory_application() (openfactory.openfactory_manager.OpenFactoryManager method) deploy_service() (openfactory.connectors.mtconnect.mtcagent_deployer.MTConnectAgentDeployer method) deployment_strategy (openfactory.openfactory_manager.OpenFactoryManager attribute) deregister_asset() (in module openfactory.utils.assets) deregister_device_connector() (in module openfactory.utils.assets) description (openfactory.schemas.filelayer.base_backend.BaseBackendConfig attribute) Device (class in openfactory.schemas.devices) device_xml (openfactory.schemas.connectors.mtconnect.Agent attribute) devices (openfactory.schemas.devices.DevicesConfig attribute) devices() (openfactory.openfactory.OpenFactory method) devices_dict (openfactory.schemas.devices.DevicesConfig property) devices_uuid() (openfactory.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.OpenFactoryAppSchema attribute) (openfactory.schemas.connectors.mtconnect.Adapter attribute) (openfactory.schemas.supervisors.SupervisorAdapter attribute) events (openfactory.schemas.connectors.opcua.OPCUAConnectorSchema attribute) events() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) exists() (openfactory.filelayer.backend.FileBackend method) (openfactory.filelayer.local_backend.LocalBackend method) (openfactory.filelayer.nfs_backend.NFSBackend method) extract_uns_fields() (openfactory.schemas.uns.UNSSchema method) F FileBackend (class in openfactory.filelayer.backend) filter_messages() (openfactory.kafka.asset_consumer.KafkaAssetConsumer method) (openfactory.kafka.commands_consumer.KafkaCommandsConsumer method) find_yaml_files() (in module openfactory.utils) from_config() (openfactory.filelayer.backend.FileBackend static method) (openfactory.filelayer.local_backend.LocalBackend static method) (openfactory.filelayer.nfs_backend.NFSBackend static method) G gateway (openfactory.schemas.infra.IPAMConfig attribute) generate_uns_path() (openfactory.schemas.uns.UNSSchema method) get() (openfactory.kafka.CaseInsensitiveDict method) get_apps_from_config_file() (in module openfactory.schemas.apps) get_asset_uuid_from_docker_service() (openfactory.openfactory_manager.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_mount_spec() (openfactory.filelayer.backend.FileBackend method) (openfactory.filelayer.local_backend.LocalBackend method) (openfactory.filelayer.nfs_backend.NFSBackend method) get_nats_cluster_url() (in module openfactory.assets.utils) get_nested() (in module openfactory.utils) get_token() (openfactory.utils.github_tokenstore.GitHubTokenStore method) GitHubTokenStore (class in openfactory.utils.github_tokenstore) I id (openfactory.assets.utils.AssetAttribute attribute) identifier (openfactory.schemas.connectors.opcua.OPCUANodeConfig attribute) identifier_type (openfactory.schemas.connectors.opcua.OPCUANodeConfig attribute) idx (openfactory.apps.supervisor.OPCUASupervisor attribute) image (openfactory.schemas.apps.OpenFactoryAppSchema attribute) (openfactory.schemas.connectors.mtconnect.Adapter attribute) (openfactory.schemas.supervisors.Supervisor attribute) (openfactory.schemas.supervisors.SupervisorAdapter attribute) info() (openfactory.kafka.ksql.KSQLDBClient method) InfrastructureSchema (class in openfactory.schemas.infra) insert_into_stream() (openfactory.kafka.ksql.KSQLDBClient method) ip (openfactory.schemas.connectors.mtconnect.Adapter attribute) (openfactory.schemas.connectors.mtconnect.Agent attribute) (openfactory.schemas.infra.Node attribute) (openfactory.schemas.supervisors.SupervisorAdapter 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.asset_producer.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.common.Resources attribute) list_tokens() (openfactory.utils.github_tokenstore.GitHubTokenStore method) listdir() (openfactory.filelayer.backend.FileBackend method) (openfactory.filelayer.local_backend.LocalBackend method) (openfactory.filelayer.nfs_backend.NFSBackend method) load_agent_config() (openfactory.connectors.mtconnect.mtcagent_deployer.MTConnectAgentDeployer method) load_device_xml() (openfactory.connectors.mtconnect.mtcagent_deployer.MTConnectAgentDeployer method) load_tokens() (openfactory.utils.github_tokenstore.GitHubTokenStore method) local_path (openfactory.schemas.filelayer.local_backend.LocalBackendConfig attribute) LocalBackend (class in openfactory.filelayer.local_backend) LocalBackendConfig (class in openfactory.schemas.filelayer.local_backend) LocalDockerDeploymentStrategy (class in openfactory.openfactory_deploy_strategy) logger (openfactory.apps.ofaapp.OpenFactoryApp attribute) (openfactory.kafka.kafka_logger.KafkaLogger property) loop_thread (openfactory.assets.asset_base.BaseAsset attribute) M main_loop() (openfactory.apps.ofaapp.OpenFactoryApp method) (openfactory.apps.supervisor.BaseSupervisor method) make_volume_name() (openfactory.filelayer.nfs_backend.NFSBackend method) Managers (class in openfactory.schemas.infra) managers (openfactory.schemas.infra.Nodes attribute) memory (openfactory.schemas.common.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.OpenFactoryAppSchema attribute) (openfactory.schemas.apps.OpenFactoryAppsConfig attribute) (openfactory.schemas.common.Deploy attribute) (openfactory.schemas.common.Placement attribute) (openfactory.schemas.common.Resources attribute) (openfactory.schemas.common.ResourcesDefinition attribute) (openfactory.schemas.connectors.mtconnect.Adapter attribute) (openfactory.schemas.connectors.mtconnect.Agent attribute) (openfactory.schemas.connectors.mtconnect.MTConnectConnectorSchema attribute) (openfactory.schemas.connectors.opcua.OPCUAConnectorSchema attribute) (openfactory.schemas.connectors.opcua.OPCUAEventConfig attribute) (openfactory.schemas.connectors.opcua.OPCUANodeConfig attribute) (openfactory.schemas.connectors.opcua.OPCUAServerConfig attribute) (openfactory.schemas.connectors.opcua.OPCUASubscriptionConfig attribute) (openfactory.schemas.connectors.opcua.OPCUAVariableConfig attribute) (openfactory.schemas.devices.Device attribute) (openfactory.schemas.devices.DevicesConfig attribute) (openfactory.schemas.filelayer.base_backend.BaseBackendConfig attribute) (openfactory.schemas.filelayer.local_backend.LocalBackendConfig attribute) (openfactory.schemas.filelayer.nfs_backend.NFSBackendConfig attribute) (openfactory.schemas.filelayer.storage.StorageBackendSchema 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.supervisors.Supervisor attribute) (openfactory.schemas.supervisors.SupervisorAdapter attribute) (openfactory.schemas.uns.NamespaceItem attribute) (openfactory.schemas.uns.UNSSchemaModel attribute) model_post_init() (openfactory.schemas.connectors.opcua.OPCUAConnectorSchema method) module openfactory.assets.utils openfactory.connectors.base_connector openfactory.connectors.mtconnect.mtc_connector openfactory.connectors.mtconnect.mtcagent_deployer openfactory.connectors.opcua.opcua_connector openfactory.exceptions openfactory.filelayer.backend openfactory.filelayer.local_backend openfactory.filelayer.nfs_backend openfactory.kafka.asset_consumer openfactory.kafka.asset_producer openfactory.kafka.asset_uns_consumer openfactory.kafka.commands_consumer openfactory.kafka.kafka_logger openfactory.kafka.ksql openfactory.openfactory openfactory.openfactory_cluster openfactory.openfactory_manager openfactory.schemas.apps openfactory.schemas.common openfactory.schemas.connectors openfactory.schemas.connectors.mtconnect openfactory.schemas.connectors.opcua openfactory.schemas.devices openfactory.schemas.filelayer.base_backend openfactory.schemas.filelayer.local_backend openfactory.schemas.filelayer.nfs_backend openfactory.schemas.filelayer.storage openfactory.schemas.infra openfactory.schemas.supervisors openfactory.schemas.uns openfactory.utils openfactory.utils.assets openfactory.utils.github_tokenstore openfactory.utils.open_uris mount_options (openfactory.schemas.filelayer.nfs_backend.NFSBackendConfig attribute) mount_point (openfactory.schemas.filelayer.local_backend.LocalBackendConfig attribute) (openfactory.schemas.filelayer.nfs_backend.NFSBackendConfig attribute) MTConnectAgentDeployer (class in openfactory.connectors.mtconnect.mtcagent_deployer) MTConnectConnector (class in openfactory.connectors.mtconnect.mtc_connector) MTConnectConnectorSchema (class in openfactory.schemas.connectors.mtconnect) N name (openfactory.schemas.infra.Network attribute) namespace_index (openfactory.schemas.connectors.opcua.OPCUANodeConfig attribute) namespace_structure (openfactory.schemas.uns.UNSSchemaModel attribute) namespace_uri (openfactory.apps.supervisor.OPCUASupervisor attribute) NamespaceItem (class in openfactory.schemas.uns) NATSSubscriber (class in openfactory.assets.utils) Network (class in openfactory.schemas.infra) Networks (class in openfactory.schemas.infra) networks (openfactory.schemas.infra.InfrastructureSchema attribute) NFSBackend (class in openfactory.filelayer.nfs_backend) NFSBackendConfig (class in openfactory.schemas.filelayer.nfs_backend) Node (class in openfactory.schemas.infra) node_id (openfactory.schemas.connectors.opcua.OPCUANodeConfig attribute) 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) OPCUAConnector (class in openfactory.connectors.opcua.opcua_connector) OPCUAConnectorSchema (class in openfactory.schemas.connectors.opcua) OPCUAEventConfig (class in openfactory.schemas.connectors.opcua) OPCUANodeConfig (class in openfactory.schemas.connectors.opcua) OPCUAServerConfig (class in openfactory.schemas.connectors.opcua) OPCUASubscriptionConfig (class in openfactory.schemas.connectors.opcua) OPCUASupervisor (class in openfactory.apps.supervisor) OPCUAVariableConfig (class in openfactory.schemas.connectors.opcua) open() (openfactory.filelayer.backend.FileBackend method) (openfactory.filelayer.local_backend.LocalBackend method) (openfactory.filelayer.nfs_backend.NFSBackend method) open_github() (in module openfactory.utils.open_uris) open_ofa() (in module openfactory.utils.open_uris) OpenFactory (class in openfactory.openfactory) openfactory.assets.utils module openfactory.connectors.base_connector module openfactory.connectors.mtconnect.mtc_connector module openfactory.connectors.mtconnect.mtcagent_deployer module openfactory.connectors.opcua.opcua_connector module openfactory.exceptions module openfactory.filelayer.backend module openfactory.filelayer.local_backend module openfactory.filelayer.nfs_backend module openfactory.kafka.asset_consumer module openfactory.kafka.asset_producer module openfactory.kafka.asset_uns_consumer module openfactory.kafka.commands_consumer module openfactory.kafka.kafka_logger module openfactory.kafka.ksql module openfactory.openfactory module openfactory.openfactory_cluster module openfactory.openfactory_manager module openfactory.schemas.apps module openfactory.schemas.common module openfactory.schemas.connectors module openfactory.schemas.connectors.mtconnect module openfactory.schemas.connectors.opcua module openfactory.schemas.devices module openfactory.schemas.filelayer.base_backend module openfactory.schemas.filelayer.local_backend module openfactory.schemas.filelayer.nfs_backend module openfactory.schemas.filelayer.storage module openfactory.schemas.infra module openfactory.schemas.supervisors 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) openfactory_timestamp() (in module openfactory.assets.utils) OpenFactoryApp (class in openfactory.apps.ofaapp) OpenFactoryAppSchema (class in openfactory.schemas.apps) OpenFactoryAppsConfig (class in openfactory.schemas.apps) OpenFactoryCluster (class in openfactory.openfactory_cluster) OpenFactoryManager (class in openfactory.openfactory_manager) OpenFactoryServiceDeploymentStrategy (class in openfactory.openfactory_deploy_strategy) P Placement (class in openfactory.schemas.common) placement (openfactory.schemas.common.Deploy attribute) port (openfactory.schemas.connectors.mtconnect.Adapter attribute) (openfactory.schemas.connectors.mtconnect.Agent attribute) (openfactory.schemas.supervisors.SupervisorAdapter attribute) prepare_env() (openfactory.connectors.mtconnect.mtcagent_deployer.MTConnectAgentDeployer method) producer (openfactory.assets.Asset attribute) (openfactory.assets.asset_base.BaseAsset attribute) (openfactory.assets.AssetUNS attribute) producers() (openfactory.openfactory.OpenFactory method) producers_uuid() (openfactory.openfactory.OpenFactory method) publishing_interval (openfactory.schemas.connectors.opcua.OPCUASubscriptionConfig attribute) Q query() (openfactory.kafka.ksql.KSQLDBClient method) queue_size (openfactory.schemas.connectors.opcua.OPCUASubscriptionConfig attribute) (openfactory.schemas.connectors.opcua.OPCUAVariableConfig attribute) 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) register_assets() (openfactory.connectors.mtconnect.mtcagent_deployer.MTConnectAgentDeployer method) register_device_connector() (in module openfactory.utils.assets) remote_path (openfactory.schemas.filelayer.nfs_backend.NFSBackendConfig attribute) 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.openfactory_cluster.OpenFactoryCluster method) remove_workers() (openfactory.openfactory_cluster.OpenFactoryCluster method) replicas (openfactory.schemas.common.Deploy attribute) reservations (openfactory.schemas.common.Resources attribute) Resources (class in openfactory.schemas.common) resources (openfactory.schemas.common.Deploy attribute) ResourcesDefinition (class in openfactory.schemas.common) run() (openfactory.apps.ofaapp.OpenFactoryApp method) run_coro() (openfactory.assets.utils.AsyncLoopThread method) S samples() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) sampling_interval (openfactory.schemas.connectors.opcua.OPCUASubscriptionConfig attribute) (openfactory.schemas.connectors.opcua.OPCUAVariableConfig attribute) save_tokens() (openfactory.utils.github_tokenstore.GitHubTokenStore method) send_asset_attribute() (openfactory.kafka.asset_producer.AssetProducer method) separator (openfactory.schemas.uns.UNSSchema attribute) server (openfactory.schemas.connectors.opcua.OPCUAConnectorSchema attribute) (openfactory.schemas.filelayer.nfs_backend.NFSBackendConfig attribute) set_deploy_defaults() (openfactory.schemas.connectors.mtconnect.Adapter method) (openfactory.schemas.connectors.mtconnect.Agent method) shut_down_apps_from_config_file() (openfactory.openfactory_manager.OpenFactoryManager method) shut_down_devices_from_config_file() (openfactory.openfactory_manager.OpenFactoryManager method) signal_handler() (openfactory.apps.ofaapp.OpenFactoryApp method) start() (openfactory.assets.utils.NATSSubscriber method) statement_query() (openfactory.kafka.ksql.KSQLDBClient method) stop() (openfactory.assets.utils.AsyncLoopThread method) (openfactory.assets.utils.NATSSubscriber method) (openfactory.kafka.asset_consumer.KafkaAssetConsumer method) (openfactory.kafka.commands_consumer.KafkaCommandsConsumer method) stop_attribute_subscription() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS 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) storage (openfactory.apps.ofaapp.OpenFactoryApp attribute) (openfactory.schemas.apps.OpenFactoryAppSchema attribute) (openfactory.schemas.filelayer.storage.StorageBackendSchema attribute) StorageBackend (in module openfactory.schemas.filelayer.types) StorageBackendSchema (class in openfactory.schemas.filelayer.storage) streams() (openfactory.kafka.ksql.KSQLDBClient method) subnet (openfactory.schemas.infra.IPAMConfig attribute) subscribe_to_attribute() (openfactory.assets.Asset method) (openfactory.assets.asset_base.BaseAsset method) (openfactory.assets.AssetUNS method) 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) subscribers (openfactory.assets.asset_base.BaseAsset attribute) subscription (openfactory.schemas.connectors.opcua.OPCUAServerConfig attribute) Supervisor (class in openfactory.schemas.supervisors) supervisor (openfactory.schemas.devices.Device attribute) SupervisorAdapter (class in openfactory.schemas.supervisors) supervisors() (openfactory.openfactory.OpenFactory method) supervisors_uuid() (openfactory.openfactory.OpenFactory method) swarm_mount_to_container_mount() (openfactory.openfactory_deploy_strategy.LocalDockerDeploymentStrategy method) SwarmDeploymentStrategy (class in openfactory.openfactory_deploy_strategy) T tables() (openfactory.kafka.ksql.KSQLDBClient method) tag (openfactory.assets.utils.AssetAttribute attribute) (openfactory.schemas.connectors.opcua.OPCUAVariableConfig attribute) tear_down() (openfactory.connectors.base_connector.Connector method) (openfactory.connectors.mtconnect.mtc_connector.MTConnectConnector method) (openfactory.connectors.opcua.opcua_connector.OPCUAConnector method) tear_down_application() (openfactory.openfactory_manager.OpenFactoryManager method) template_fields (openfactory.schemas.uns.UNSSchema attribute) timestamp (openfactory.assets.utils.AssetAttribute attribute) topic (openfactory.kafka.asset_producer.AssetProducer attribute) type (openfactory.assets.Asset property) (openfactory.assets.asset_base.BaseAsset property) (openfactory.assets.AssetUNS property) (openfactory.assets.utils.AssetAttribute attribute) (openfactory.schemas.connectors.mtconnect.MTConnectConnectorSchema attribute) (openfactory.schemas.connectors.opcua.OPCUAConnectorSchema attribute) (openfactory.schemas.filelayer.base_backend.BaseBackendConfig attribute) (openfactory.schemas.filelayer.local_backend.LocalBackendConfig attribute) (openfactory.schemas.filelayer.nfs_backend.NFSBackendConfig attribute) U uns (openfactory.schemas.apps.OpenFactoryAppSchema attribute) (openfactory.schemas.devices.Device attribute) uns_template (openfactory.schemas.uns.UNSSchemaModel attribute) UNSSchema (class in openfactory.schemas.uns) UNSSchemaModel (class in openfactory.schemas.uns) uri (openfactory.schemas.connectors.opcua.OPCUAServerConfig attribute) uuid (openfactory.schemas.apps.OpenFactoryAppSchema attribute) (openfactory.schemas.devices.Device attribute) V validate_adapter() (openfactory.schemas.connectors.mtconnect.Adapter class method) (openfactory.schemas.supervisors.SupervisorAdapter class method) validate_agent() (openfactory.schemas.connectors.mtconnect.Agent class method) validate_and_parse_node_id() (openfactory.schemas.connectors.opcua.OPCUANodeConfig class method) validate_browse_path_format() (openfactory.schemas.connectors.opcua.OPCUANodeConfig class method) validate_devices() (openfactory.schemas.devices.DevicesConfig method) validate_export_path() (openfactory.schemas.filelayer.nfs_backend.NFSBackendConfig class method) validate_ksql_tables() (openfactory.schemas.devices.Device class method) validate_mount_point() (openfactory.schemas.filelayer.local_backend.LocalBackendConfig class method) (openfactory.schemas.filelayer.nfs_backend.NFSBackendConfig class method) validate_node_id_or_browse_path() (openfactory.schemas.connectors.opcua.OPCUANodeConfig class method) validate_path() (openfactory.schemas.filelayer.local_backend.LocalBackendConfig class method) validate_server() (openfactory.schemas.filelayer.nfs_backend.NFSBackendConfig class method) validate_uns_fields() (openfactory.schemas.uns.UNSSchema method) value (openfactory.assets.utils.AssetAttribute attribute) value() (openfactory.schemas.uns.NamespaceItem method) variables (openfactory.schemas.connectors.opcua.OPCUAConnectorSchema attribute) 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)