List of all items[−]
Structs
- job::DataResponseBody
- job::Job
- job::JobProgression
- job::JobResult
- job::Session
- job::SessionBody
- job::SessionResponseBody
- job::ValueResponseBody
- message_exchange::LocalExchange
- message_exchange::RabbitmqExchange
- message_exchange::local::LocalExchange
- message_exchange::rabbitmq::CurrentOrders
- message_exchange::rabbitmq::RabbitmqConnection
- message_exchange::rabbitmq::RabbitmqConsumer
- message_exchange::rabbitmq::RabbitmqExchange
- message_exchange::rabbitmq::RabbitmqPublisher
- message_exchange::rabbitmq::channels::BindDescription
- message_exchange::rabbitmq::channels::ExchangeDescription
- message_exchange::rabbitmq::channels::QueueDescription
- parameter::Parameter
- parameter::Requirement
- parameter::media_segment::MediaSegment
- prelude::Arc
- prelude::Channel
- prelude::JobProgression
- prelude::JobResult
- prelude::LocalExchange
- prelude::Mutex
- prelude::ProcessStatus
- prelude::RabbitmqExchange
- prelude::SystemInformation
- prelude::Version
- prelude::WorkerConfiguration
- prelude::WorkerParameter
- prelude::WorkerStatus
- processor::ProcessStatus
- processor::Processor
- worker::SystemInformation
- worker::WorkerConfiguration
- worker::WorkerParameter
- worker::WorkerStatus
Enums
- MessageError
- job::JobStatus
- message_exchange::message::Feedback
- message_exchange::message::OrderMessage
- message_exchange::message::ResponseMessage
- prelude::Feedback
- prelude::JobStatus
- prelude::MessageError
- prelude::OrderMessage
- prelude::ResponseMessage
- prelude::WorkerActivity
- prelude::WorkerParameterType
- worker::WorkerActivity
- worker::WorkerParameterType
Traits
- message_event::MessageEvent
- message_exchange::ExternalExchange
- message_exchange::InternalExchange
- message_exchange::ResponseSender
- message_exchange::WorkerResponseSender
- parameter::ParameterValue
- parameter::container::ParametersContainer
- prelude::JsonSchema
- processor::Process
Macros
Derive Macros
Functions
- config::get_amqp_queue
- config::get_amqp_tls_certificate
- config::get_amqp_uri
- config::get_soft_reject_count_limit
- config::get_source_orders
- config::get_store_hostname
- config::get_store_hostname_with_default
- config::get_store_password
- config::get_store_token
- config::get_store_username
- config::get_x_death_count_limit
- message::publish_job_progression
- message_exchange::rabbitmq::channels::declare_consumer_channel
- parameter::store::request_value
- prelude::start_worker
- worker::docker::get_instance_id
Typedefs
- McaiChannel
- Result
- message_exchange::SharedExternalExchange
- message_exchange::SharedInternalExchange
- parameter::media_segment::MediaSegments
- prelude::Result
Statics
- message_exchange::rabbitmq::DIRECT_MESSAGING_NOT_FOUND
- message_exchange::rabbitmq::EXCHANGE_NAME_DELAYED
- message_exchange::rabbitmq::EXCHANGE_NAME_DIRECT_MESSAGING
- message_exchange::rabbitmq::EXCHANGE_NAME_JOB_RESPONSE
- message_exchange::rabbitmq::EXCHANGE_NAME_RESPONSE_DELAYED
- message_exchange::rabbitmq::EXCHANGE_NAME_SUBMIT
- message_exchange::rabbitmq::EXCHANGE_NAME_WORKER_RESPONSE
- message_exchange::rabbitmq::JOB_QUEUE_NOT_FOUND
- message_exchange::rabbitmq::JOB_RESPONSE_NOT_FOUND
- message_exchange::rabbitmq::QUEUE_JOB_COMPLETED
- message_exchange::rabbitmq::QUEUE_JOB_ERROR
- message_exchange::rabbitmq::QUEUE_JOB_PROGRESSION
- message_exchange::rabbitmq::QUEUE_JOB_STOPPED
- message_exchange::rabbitmq::QUEUE_WORKER_CREATED
- message_exchange::rabbitmq::QUEUE_WORKER_DISCOVERY
- message_exchange::rabbitmq::QUEUE_WORKER_INITIALIZED
- message_exchange::rabbitmq::QUEUE_WORKER_STARTED
- message_exchange::rabbitmq::QUEUE_WORKER_STATUS
- message_exchange::rabbitmq::QUEUE_WORKER_TERMINATED
- message_exchange::rabbitmq::QUEUE_WORKER_UPDATED
- message_exchange::rabbitmq::WORKER_RESPONSE_NOT_FOUND
Constants
- worker::built_info::CFG_ENDIAN
- worker::built_info::CFG_ENV
- worker::built_info::CFG_FAMILY
- worker::built_info::CFG_OS
- worker::built_info::CFG_POINTER_WIDTH
- worker::built_info::CFG_TARGET_ARCH
- worker::built_info::CI_PLATFORM
- worker::built_info::DEBUG
- worker::built_info::FEATURES
- worker::built_info::FEATURES_STR
- worker::built_info::HOST
- worker::built_info::NUM_JOBS
- worker::built_info::OPT_LEVEL
- worker::built_info::PKG_AUTHORS
- worker::built_info::PKG_DESCRIPTION
- worker::built_info::PKG_HOMEPAGE
- worker::built_info::PKG_LICENSE
- worker::built_info::PKG_NAME
- worker::built_info::PKG_REPOSITORY
- worker::built_info::PKG_VERSION
- worker::built_info::PKG_VERSION_MAJOR
- worker::built_info::PKG_VERSION_MINOR
- worker::built_info::PKG_VERSION_PATCH
- worker::built_info::PKG_VERSION_PRE
- worker::built_info::PROFILE
- worker::built_info::RUSTC
- worker::built_info::RUSTC_VERSION
- worker::built_info::RUSTDOC
- worker::built_info::RUSTDOC_VERSION
- worker::built_info::TARGET