List of all items

Structs

• center::connector::CenterConnectorParameters
• center::dispatcher::CenterDispatcher
• center::dispatcher::RegisterEntity
• center::message::CenterMessagePayload
• center::task_state::TaskState
• center::task_state::TaskStatusReport
• control::message::CloseTask
• control::message::ControlMessage
• control::message::RestartTask
• control::message::StopTask
• control::message_tracker::ControlMessageTracker
• control::message_tracker::TrackerItem
• control::registry::ControlRegistry
• control::registry::RegisterEntity
• core::app_state::AppState
• core::app_state::AppStatusReport
• core::env::PATOKA_ROOT_DIR
• core::env::PATOKA_X_DIR
• core::monitor::RegularCheckMessage
• core::monitor::ReportStatusMessage
• core::proxy::Proxies
• core::proxy::Proxy
• core::timer::Timer
• core::user_agent::UserAgents
• storage::db_executor::DbExecutor
• storage::db_executor::DbExecutorPool
• transport::connector::Connector
• transport::message::GenMessage
• transport::message::RawMessage
• transport::router::CONTEXT
• transport::router::MessageRouter
• transport::router_registry::RegisterRouterControlLinkMessage
• transport::router_registry::RouterRegistry
• transport::router_registry::StopRouterMessage
• worker::backend_connector::WorkerBackendConnectorParameters
• worker::client::ClientContext
• worker::controller::HeartbeatIntervalMessage
• worker::controller::HeartbeatResponseReceivedMessage
• worker::controller::HeartbeatTimeoutMessage
• worker::controller::ReserveForTask
• worker::controller::WorkerController
• worker::controller_message::ControllerMessage
• worker::controller_message::ControllerMessageBody
• worker::controller_pool::ControllerPool
• worker::dispatcher::RegisterController
• worker::dispatcher::TaskDispatcher
• worker::error_handler::TaskErrorHandler
• worker::error_handler::TaskErrorHandlerParams
• worker::external::ExternalDispatcher
• worker::external::KeepAliveRequestMessage
• worker::external::KeepAliveResponseMessage
• worker::external::RegularUpdateMessage
• worker::external_message::ExternalMessagePayload
• worker::plugin::PluginSettings
• worker::processor::CONTROLLER_POOL
• worker::processor::TaskProcessor
• worker::processor::TaskWrapperItemMessage
• worker::reprocessor::ReprocessTask
• worker::reprocessor::TaskReprocessor
• worker::reprocessor::WorkerReady
• worker::state::WorkerState
• worker::task::GenTaskDefinition
• worker::task::TaskExecutionContext
• worker::task::WorkerTask
• worker::task_assistant::TaskAssistant
• worker::task_assistant::TaskAssistantItem
• worker::task_assistant::TaskRecovery
• worker::task_reader::TaskReader
• worker::task_tree::NewTask
• worker::task_tree::TaskTree
• worker::tracker::TaskSubscription
• worker::tracker::TaskTracker
• worker::tracker::TaskUpdate
• worker::unique_task::UniqueTask
• worker::unique_task::UniqueTaskGroup
• worker::worker_message::WorkerMessagePayload

Enums

• center::message::Dest
• center::message::Subject
• control::message::Type
• core::app_state::AppStatus
• transport::router_registry::RegistryValue
• worker::controller_message::Subject
• worker::external_message::ExternalSubject
• worker::plugin::WorkerPlugin
• worker::state::WS
• worker::task::ControllerAddr
• worker::task::TaskStatus
• worker::tracker::TaskUpdateTag
• worker::worker_message::Dest

Traits

• transport::connector::ConnectorParameters
• worker::client::WorkerClient
• worker::link::Link
• worker::task::TaskDefinition
• worker::task::TaskWrapper

Macros

• define_link
• handler_impl_close_task
• handler_impl_control_message
• handler_impl_restart_task
• handler_impl_stop_task
• handler_impl_task_update
• handler_impl_worker_message

Functions

• center::connector::start
• center::dispatcher::start
• center::message::create
• center::message::create_no_data
• center::message::create_no_data_with_identity
• center::message::create_with_identity
• center::router::start
• center::send::send_center_task_closed
• center::send::send_center_task_finished
• center::send::send_center_task_question
• center::send::send_center_task_result
• center::send::send_center_task_started
• center::send::send_center_task_updated
• center::send::send_control_msg
• control::aux::update_task_params
• control::registry::register
• control::registry::send
• control::registry::start
• core::app_state::start
• core::arbiter_pool::next
• core::env::full_path
• core::env::full_path_curr_dir
• core::env::get_config
• core::env::get_opt_var
• core::env::get_var
• core::env::load
• core::env::load_error
• core::env::load_opt
• core::env::load_params
• core::env::set_key_value
• core::logger::create_logger
• core::proxy::next
• core::proxy::no_proxy
• core::timestamp::now
• core::user_agent::random_ua
• run_app
• storage::db_executor::init
• storage::db_executor::run
• transport::message::clone_identity
• transport::message::is_empty
• transport::message::new_identity
• transport::router_registry::start
• utils::csv::load_from_file
• utils::str::remove_whitespace
• worker::backend_connector::start
• worker::controller::start_task
• worker::controller_message::create_control_request
• worker::dispatcher::start
• worker::external::start
• worker::plugin::setup_plugin_message
• worker::processor::start
• worker::reprocessor::start
• worker::router::start
• worker::setup::setup
• worker::setup::setup_with_controller
• worker::task_assistant::register
• worker::task_assistant::start
• worker::task_reader::get_reader
• worker::task_reader::register_task
• worker::task_tree::restart_task
• worker::task_tree::start
• worker::task_writer::get_writer
• worker::tracker::dismiss_task_question
• worker::tracker::register_task_update_recipient
• worker::tracker::send
• worker::tracker::start
• worker::tracker::subscribe
• worker::tracker::subscribe_by_name
• worker::tracker::subscribe_no_addr
• worker::tracker::unregister_task_update_recipient
• worker::tracker::unsubscribe
• worker::tracker::unsubscribe_by_name

Type Aliases

• center::connector::CenterConnector
• center::message::CenterMessage
• core::monitor::RegularCheckTimer
• core::monitor::ReportStatusTimer
• core::timestamp::Timestamp
• storage::db_executor::Pool
• transport::message::Identity
• transport::router::RawMessageRecipient
• worker::backend_connector::WorkerBackendConnector
• worker::client::GenClientContext
• worker::external_message::ExternalMessage
• worker::processor::TaskWrapperItem
• worker::worker_message::WorkerMessage