Index A | B | C | D | E | F | G | H | I | K | L | M | N | O | P | Q | R | S | T | U | V | W A AdapterMeta (class in titanfe.apps.brick_runner.adapter) add_logging_level() (in module titanfe.log) add_source() (titanfe.apps.brick_runner.input.Input method) add_sources() (titanfe.apps.brick_runner.input.Input method) address (titanfe.repository.Request attribute) address() (titanfe.apps.brick_runner.grid_manager.GridManager property) (titanfe.apps.control_peer.services.GridManager property) (titanfe.apps.control_peer.services.PackageManager property) (titanfe.apps.control_peer.webapi.app.WebApi property) (titanfe.messages.InputSource property) apply() (titanfe.apps.brick_runner.connection.MappingRules method) as_message() (titanfe.apps.brick_runner.packet.Packet method) asdict() (titanfe.log.FlowContext method) at_outlet (titanfe.apps.brick_runner.metrics.PacketMetricsAtBrick attribute) autoscale_max_instances() (titanfe.apps.control_peer.brick.RuntimeParameters property) autoscale_queue_level() (titanfe.apps.control_peer.brick.RuntimeParameters property) (titanfe.messages.OutputTarget property) B BasicConstant (class in titanfe.apps.brick_runner.connection) Brick (class in titanfe.apps.brick_runner.brick) brick (titanfe.apps.brick_runner.adapter.AdapterMeta attribute) (titanfe.apps.brick_runner.metrics.MetricsBase attribute) (titanfe.apps.control_peer.webapi.bricks.RequestBrickStart attribute) brick_code_endpoint() (titanfe.apps.control_peer.services.PackageManager property) brick_endpoint() (titanfe.apps.control_peer.services.PackageManager property) brick_family (titanfe.apps.brick_runner.metrics.MetricsBase attribute) brick_family() (titanfe.messages.BrickDescription property) brick_type (titanfe.apps.brick_runner.metrics.MetricsBase attribute) brick_type() (titanfe.messages.BrickDescription property) BrickAdapter (class in titanfe.apps.brick_runner.adapter) BrickBase (class in titanfe.brick) BrickBaseDefinition (class in titanfe.apps.control_peer.brick) BrickDescription (class in titanfe.messages) BrickInstanceDefinition (class in titanfe.apps.control_peer.brick) BrickMetrics (class in titanfe.apps.brick_runner.metrics) brickname (titanfe.log.FlowContext attribute) (titanfe.log.TitanLogRecord attribute) BrickRunner (class in titanfe.apps.control_peer.runner) bricks (titanfe.apps.control_peer.webapi.bricks.RequestInstallBricks attribute) brickuid (titanfe.log.FlowContext attribute) (titanfe.log.TitanLogRecord attribute) Buffer (class in titanfe.apps.brick_runner.connection) buffer (titanfe.apps.brick_runner.packet.Packet attribute) BufferDescription (class in titanfe.apps.brick_runner.connection) C cancel_tasks() (in module titanfe.utils) check_termination() (titanfe.apps.control_peer.runner.BrickRunner method) close() (titanfe.apps.brick_runner.input.Input method) (titanfe.apps.brick_runner.metrics.QueueWithMetrics method) (titanfe.connection.Connection method) (titanfe.log.KafkaLogHandler method) close_connection() (titanfe.apps.brick_runner.output.consumer.Consumer method) collection (titanfe.repository.RequestData attribute) Configuration (class in titanfe.config) ConfigurationError Connection (class in titanfe.connection) Connections (class in titanfe.apps.control_peer.brick) Constant (class in titanfe.apps.brick_runner.connection) Consumer (class in titanfe.apps.brick_runner.output.consumer) ConsumerRegistration (titanfe.messages.MessageType attribute) content (titanfe.repository.Request attribute) content() (titanfe.messages.Message property) content_type (titanfe.apps.brick_runner.metrics.BrickMetrics attribute) (titanfe.apps.brick_runner.metrics.PacketMetricsAtBrick attribute) (titanfe.apps.brick_runner.metrics.QueueMetrics attribute) context() (titanfe.log.TitanLogAdapter property) control_peer_endpoint() (titanfe.apps.control_peer.services.ControlPeerServiceRegistration property) (titanfe.apps.control_peer.services.GridManager property) (titanfe.apps.control_peer.services.PackageManager property) ControlPeer (class in titanfe.apps.control_peer.control_peer) ControlPeerServiceRegistration (class in titanfe.apps.control_peer.services) create() (titanfe.apps.control_peer.control_peer.ControlPeer class method) create_brick_router() (in module titanfe.apps.control_peer.webapi.bricks) create_flow_router() (in module titanfe.apps.control_peer.webapi.flows) create_from_brick_runner() (titanfe.apps.brick_runner.metrics.MetricEmitter class method) create_instance() (titanfe.apps.brick_runner.brick.Brick method) create_state_router() (in module titanfe.apps.control_peer.webapi.state) create_uid() (in module titanfe.utils) create_virtual_env() (titanfe.apps.control_peer.brick.BrickBaseDefinition method) D database (titanfe.repository.RequestData attribute) decode_ujo_message() (in module titanfe.connection) decrypt_parameter() (titanfe.apps.brick_runner.adapter.BrickAdapter method) default_port() (titanfe.messages.BrickDescription property) delete() (titanfe.repository.RepositoryService method) deregister() (titanfe.apps.control_peer.services.ControlPeerServiceRegistration method) deregister_runner() (titanfe.apps.brick_runner.grid_manager.GridManager method) DictConvertable (class in titanfe.utils) dicts_to_dataclasses() (titanfe.utils.DictConvertable method) document (titanfe.repository.RequestData attribute) E elapsed() (titanfe.utils.Timer property) elapsed_total() (titanfe.utils.Timer property) emit() (titanfe.apps.brick_runner.metrics.MetricEmitter method) (titanfe.log.KafkaLogHandler method) emit_brick_metrics() (titanfe.apps.brick_runner.metrics.MetricEmitter method) emit_metrics() (titanfe.apps.brick_runner.metrics.QueueWithMetrics method) emit_new_packet() (titanfe.apps.brick_runner.adapter.BrickAdapter method) emit_packet_metrics() (titanfe.apps.brick_runner.metrics.MetricEmitter method) emit_queue_metrics() (titanfe.apps.brick_runner.metrics.MetricEmitter method) enqueue_result_as_packet() (titanfe.apps.brick_runner.brick.Brick method) ensure_ujo_key() (in module titanfe.apps.brick_runner.connection) EnvBuilder (class in titanfe.apps.control_peer.brick) execute_brick() (titanfe.apps.brick_runner.brick.Brick method) execution_time (titanfe.apps.brick_runner.metrics.BrickMetrics attribute) (titanfe.apps.brick_runner.metrics.PacketMetricsAtBrick attribute) execution_time() (titanfe.apps.brick_runner.brick.Brick property) exit_after_idle_seconds() (titanfe.apps.control_peer.brick.RuntimeParameters property) (titanfe.messages.BrickDescription property) extract_from_runner() (titanfe.apps.brick_runner.metrics.MetricsBase static method) F find (titanfe.repository.RequestData attribute) first() (in module titanfe.utils) Flag (class in titanfe.utils) flatten() (in module titanfe.utils) Flow (class in titanfe.apps.control_peer.brick) flow (titanfe.apps.brick_runner.adapter.AdapterMeta attribute) (titanfe.apps.brick_runner.metrics.MetricsBase attribute) FlowContext (class in titanfe.log) flowname (titanfe.log.FlowContext attribute) (titanfe.log.TitanLogRecord attribute) flowname() (titanfe.messages.BrickDescription property) flowuid (titanfe.log.FlowContext attribute) (titanfe.log.TitanLogRecord attribute) flowuid() (titanfe.messages.BrickDescription property) flush() (titanfe.log.KafkaLogHandler method) flush_kafka_log_handler() (in module titanfe.log) format() (titanfe.log.UjoBinFormatter method) from_brick() (titanfe.log.FlowContext class method) from_dict() (titanfe.apps.brick_runner.connection.Buffer class method) (titanfe.repository.RequestData class method) (titanfe.utils.DictConvertable class method) from_flow() (titanfe.log.FlowContext class method) from_gridmanager() (titanfe.apps.control_peer.brick.BrickInstanceDefinition class method) from_json() (titanfe.repository.RequestData class method) G generate_key() (in module titanfe.utils) get() (titanfe.apps.brick_runner.adapter.State method) (titanfe.apps.brick_runner.input.Input method) (titanfe.apps.control_peer.services.PackageManager static method) (titanfe.repository.RepositoryService method) get_bricks() (titanfe.apps.control_peer.services.PackageManager method) get_constant() (in module titanfe.apps.brick_runner.connection) get_input() (titanfe.apps.brick_runner.input.Input method) get_ip_address() (in module titanfe.utils) get_module() (in module titanfe.utils) get_results() (titanfe.apps.brick_runner.brick.Brick method) get_source_files() (titanfe.apps.control_peer.services.PackageManager method) get_state() (in module titanfe.apps.control_peer.webapi.state) get_ujo_value() (in module titanfe.ujo_helper) get_venv_exe() (in module titanfe.apps.control_peer.brick) getChild() (titanfe.log.TitanLogAdapter method) (titanfe.log.TitanPlatformLogger method) getLogger() (in module titanfe.log) GridManager (class in titanfe.apps.brick_runner.grid_manager) (class in titanfe.apps.control_peer.services) guess_module_path() (titanfe.apps.control_peer.brick.BrickBaseDefinition method) H handle_input_loss() (titanfe.apps.brick_runner.input.Input method) HelloWorld (class in titanfe.apps.control_peer.webapi.app) host (titanfe.apps.brick_runner.metrics.MetricsBase attribute) host() (titanfe.connection.NetworkAddress property) hostname (titanfe.log.TitanLogRecord attribute) I initialize() (in module titanfe.log) InletBrickBase (class in titanfe.brick) Input (class in titanfe.apps.brick_runner.input) input() (titanfe.apps.control_peer.brick.Connections property) (titanfe.apps.control_peer.brick.Ports property) input_entry (titanfe.apps.brick_runner.packet.Packet attribute) input_exit (titanfe.apps.brick_runner.packet.Packet attribute) InputSource (class in titanfe.messages) install_bricks() (titanfe.apps.control_peer.control_peer.ControlPeer static method) install_or_update() (titanfe.apps.control_peer.brick.BrickBaseDefinition method) install_pip() (titanfe.apps.control_peer.brick.EnvBuilder method) install_requirements() (titanfe.apps.control_peer.brick.EnvBuilder method) install_signal_handlers() (titanfe.apps.control_peer.control_peer.ControlPeer method) is_buffer() (titanfe.apps.brick_runner.connection.Rule property) is_const() (titanfe.apps.brick_runner.connection.Rule property) is_empty() (titanfe.apps.brick_runner.input.Input property) is_inlet() (titanfe.messages.BrickDescription property) is_receptive() (titanfe.apps.brick_runner.output.consumer.Consumer method) iso_utc_time_string() (in module titanfe.utils) K KafkaLogHandler (class in titanfe.log) L listen() (titanfe.apps.brick_runner.output.consumer.Consumer method) log (titanfe.repository.Request attribute) log_stdout() (titanfe.apps.control_peer.brick.EnvBuilder method) M MappingRules (class in titanfe.apps.brick_runner.connection) Message (class in titanfe.messages) message (titanfe.apps.control_peer.webapi.app.HelloWorld attribute) MessageType (class in titanfe.messages) MetaData (class in titanfe.apps.brick_runner.adapter) method (titanfe.repository.Request attribute) metric() (titanfe.log.TitanLogAdapter method) MetricEmitter (class in titanfe.apps.brick_runner.metrics) MetricsBase (class in titanfe.apps.brick_runner.metrics) module titanfe titanfe.apps titanfe.apps.brick_runner titanfe.apps.brick_runner.adapter titanfe.apps.brick_runner.brick titanfe.apps.brick_runner.connection titanfe.apps.brick_runner.grid_manager titanfe.apps.brick_runner.input titanfe.apps.brick_runner.metrics titanfe.apps.brick_runner.output.consumer titanfe.apps.brick_runner.packet titanfe.apps.control_peer titanfe.apps.control_peer.brick titanfe.apps.control_peer.control_peer titanfe.apps.control_peer.runner titanfe.apps.control_peer.services titanfe.apps.control_peer.webapi titanfe.apps.control_peer.webapi.app titanfe.apps.control_peer.webapi.bricks titanfe.apps.control_peer.webapi.flows titanfe.apps.control_peer.webapi.state titanfe.apps.kafka_to_elastic titanfe.apps.kafka_viewer titanfe.brick titanfe.config titanfe.connection titanfe.constants titanfe.log titanfe.messages titanfe.repository titanfe.ujo_helper titanfe.utils N name() (titanfe.apps.brick_runner.adapter.MetaData property) (titanfe.apps.control_peer.brick.Flow property) (titanfe.messages.BrickDescription property) (titanfe.messages.InputSource property) (titanfe.messages.OutputTarget property) NetworkAddress (class in titanfe.connection) new_buffer_from_result() (titanfe.apps.brick_runner.connection.Buffer method) NotFound (class in titanfe.config) ns_to_ms() (in module titanfe.utils) O ObjectConstant (class in titanfe.apps.brick_runner.connection) open() (titanfe.connection.Connection class method) option_aliases (titanfe.config.Configuration attribute) output() (titanfe.apps.control_peer.brick.Connections property) (titanfe.apps.control_peer.brick.Ports property) output_entry (titanfe.apps.brick_runner.packet.Packet attribute) output_exit (titanfe.apps.brick_runner.packet.Packet attribute) OutputTarget (class in titanfe.messages) P PackageManager (class in titanfe.apps.control_peer.services) Packet (class in titanfe.apps.brick_runner.packet) packet (titanfe.apps.brick_runner.metrics.PacketMetricsAtBrick attribute) Packet (titanfe.messages.MessageType attribute) PacketMetricsAtBrick (class in titanfe.apps.brick_runner.metrics) PacketRequest (titanfe.messages.MessageType attribute) pairwise() (in module titanfe.utils) parameters() (titanfe.messages.BrickDescription property) path_to_module() (titanfe.messages.BrickDescription property) payload (titanfe.apps.brick_runner.packet.Packet attribute) perf_counter_since_last() (titanfe.utils.Timer property) perf_counter_total() (titanfe.utils.Timer property) port (titanfe.apps.brick_runner.packet.Packet attribute) port() (titanfe.connection.NetworkAddress property) (titanfe.messages.InputSource property) (titanfe.messages.OutputTarget property) PortMapping (class in titanfe.apps.brick_runner.brick) Ports (class in titanfe.apps.control_peer.brick) post_setup() (titanfe.apps.control_peer.brick.EnvBuilder method) process() (titanfe.apps.brick_runner.brick.Brick method) (titanfe.brick.BrickBase method) process_time_since_last() (titanfe.utils.Timer property) process_time_total() (titanfe.utils.Timer property) put() (titanfe.apps.brick_runner.input.Input method) (titanfe.apps.brick_runner.metrics.QueueWithMetrics method) py_to_ujo_bytes() (in module titanfe.ujo_helper) python_to_ujo() (in module titanfe.ujo_helper) Q queue_length (titanfe.apps.brick_runner.metrics.QueueMetrics attribute) queue_name (titanfe.apps.brick_runner.metrics.QueueMetrics attribute) queue_times() (titanfe.apps.brick_runner.packet.Packet property) QueueMetrics (class in titanfe.apps.brick_runner.metrics) QueueWithMetrics (class in titanfe.apps.brick_runner.metrics) R receive() (titanfe.connection.Connection method) RecordConstant (class in titanfe.apps.brick_runner.connection) register() (titanfe.apps.control_peer.services.ControlPeerServiceRegistration method) register_runner() (titanfe.apps.brick_runner.grid_manager.GridManager method) remove_runner() (titanfe.apps.control_peer.control_peer.ControlPeer method) RepositoryService (class in titanfe.repository) Request (class in titanfe.repository) request_scaling() (titanfe.apps.brick_runner.grid_manager.GridManager method) RequestBrickStart (class in titanfe.apps.control_peer.webapi.bricks) RequestData (class in titanfe.repository) RequestInstallBricks (class in titanfe.apps.control_peer.webapi.bricks) reset() (titanfe.apps.brick_runner.adapter.State method) response (titanfe.repository.Request attribute) Rule (class in titanfe.apps.brick_runner.connection) rules() (titanfe.apps.brick_runner.brick.PortMapping property) run() (titanfe.apps.control_peer.control_peer.ControlPeer method) run_instance_processing() (titanfe.apps.brick_runner.brick.Brick method) runner (titanfe.apps.brick_runner.metrics.MetricsBase attribute) RuntimeParameters (class in titanfe.apps.control_peer.brick) S schedule_shutdown() (titanfe.apps.control_peer.control_peer.ControlPeer method) schema() (titanfe.apps.control_peer.brick.Flow property) (titanfe.repository.RequestData class method) send() (titanfe.apps.brick_runner.output.consumer.Consumer method) (titanfe.connection.Connection method) (titanfe.repository.Request method) serve() (titanfe.apps.control_peer.webapi.app.WebApi method) ServiceError servicename (titanfe.log.TitanLogRecord attribute) set() (titanfe.apps.brick_runner.adapter.State method) set_metadata_from_runner() (titanfe.apps.brick_runner.metrics.MetricEmitter method) setup() (titanfe.brick.BrickBase method) shutdown() (titanfe.apps.control_peer.control_peer.ControlPeer method) start() (titanfe.apps.brick_runner.metrics.MetricEmitter method) (titanfe.apps.control_peer.runner.BrickRunner method) start_new_runner() (titanfe.apps.control_peer.control_peer.ControlPeer method) started (titanfe.apps.brick_runner.packet.Packet attribute) State (class in titanfe.apps.brick_runner.adapter) stop() (titanfe.apps.brick_runner.metrics.MetricEmitter method) (titanfe.apps.control_peer.runner.BrickRunner method) (titanfe.apps.control_peer.webapi.app.WebApi method) stop_processing() (titanfe.brick.InletBrickBase method) stop_runners() (titanfe.apps.control_peer.control_peer.ControlPeer method) store() (titanfe.repository.RepositoryService method) T teardown() (titanfe.brick.BrickBase method) terminate() (titanfe.apps.brick_runner.brick.Brick method) time_delta_in_ms() (in module titanfe.utils) time_in_input (titanfe.apps.brick_runner.metrics.PacketMetricsAtBrick attribute) time_in_output (titanfe.apps.brick_runner.metrics.PacketMetricsAtBrick attribute) time_on_wire (titanfe.apps.brick_runner.metrics.PacketMetricsAtBrick attribute) Timer (class in titanfe.utils) timestamp (titanfe.apps.brick_runner.metrics.MetricsBase attribute) titanfe module titanfe.apps module titanfe.apps.brick_runner module titanfe.apps.brick_runner.adapter module titanfe.apps.brick_runner.brick module titanfe.apps.brick_runner.connection module titanfe.apps.brick_runner.grid_manager module titanfe.apps.brick_runner.input module titanfe.apps.brick_runner.metrics module titanfe.apps.brick_runner.output.consumer module titanfe.apps.brick_runner.packet module titanfe.apps.control_peer module titanfe.apps.control_peer.brick module titanfe.apps.control_peer.control_peer module titanfe.apps.control_peer.runner module titanfe.apps.control_peer.services module titanfe.apps.control_peer.webapi module titanfe.apps.control_peer.webapi.app module titanfe.apps.control_peer.webapi.bricks module titanfe.apps.control_peer.webapi.flows module titanfe.apps.control_peer.webapi.state module titanfe.apps.kafka_to_elastic module titanfe.apps.kafka_viewer module titanfe.brick module titanfe.config module titanfe.connection module titanfe.constants module titanfe.log module titanfe.messages module titanfe.repository module titanfe.ujo_helper module titanfe.utils module TitanLogAdapter (class in titanfe.log) TitanLogRecord (class in titanfe.log) TitanPlatformLogger (class in titanfe.log) to_dict() (titanfe.repository.RequestData method) (titanfe.utils.DictConvertable method) to_json() (titanfe.repository.RequestData method) to_ujo() (titanfe.apps.brick_runner.connection.BasicConstant method) (titanfe.apps.brick_runner.connection.Constant method) (titanfe.apps.brick_runner.connection.ObjectConstant method) (titanfe.apps.brick_runner.connection.RecordConstant method) traveling_time (titanfe.apps.brick_runner.metrics.PacketMetricsAtBrick attribute) traveling_time() (titanfe.apps.brick_runner.packet.Packet property) type() (titanfe.apps.brick_runner.brick.PortMapping property) (titanfe.messages.Message property) U uid (titanfe.apps.brick_runner.packet.Packet attribute) uid() (titanfe.apps.brick_runner.adapter.MetaData property) (titanfe.apps.control_peer.brick.Flow property) (titanfe.messages.BrickDescription property) ujo_bytes_to_py() (in module titanfe.ujo_helper) UjoBinFormatter (class in titanfe.log) unfinished_tasks() (titanfe.apps.brick_runner.metrics.QueueWithMetrics property) update() (titanfe.config.Configuration method) update_from_yaml() (titanfe.config.Configuration method) update_input_entry() (titanfe.apps.brick_runner.packet.Packet method) update_input_exit() (titanfe.apps.brick_runner.packet.Packet method) update_last_access() (titanfe.utils.Timer method) update_output_entry() (titanfe.apps.brick_runner.packet.Packet method) update_output_exit() (titanfe.apps.brick_runner.packet.Packet method) V value (titanfe.repository.RequestData attribute) venv_path() (titanfe.apps.control_peer.brick.BrickBaseDefinition property) W WebApi (class in titanfe.apps.control_peer.webapi.app) with_context() (titanfe.log.TitanPlatformLogger property)