List of all items
Structs
- job::BlackList
- job::BlackListChangeMessage
- job::Job
- job::JobProgression
- job::JobResult
- message_exchange::local::ExternalLocalExchange
- message_exchange::local::InternalLocalExchange
- message_exchange::local::LocalExchange
- message_exchange::rabbitmq::CurrentState
- 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::Mutex
- prelude::OpenSourceLicense
- prelude::Version
- processor::ProcessStatus
- processor::Processor
- reexport::Package
- reexport::Version
- worker::SystemInformation
- worker::WorkerBlackList
- worker::WorkerConfiguration
- worker::WorkerStatus
- worker::system_instant_resources::SystemInstantResources
Enums
- MessageError
- config::AmqpClusterMode
- job::JobStatus
- mcai_worker::McaiWorkerDocumentation
- message_exchange::message::Feedback
- message_exchange::message::OrderMessage
- message_exchange::message::ResponseMessage
- prelude::McaiWorkerLicense
- worker::WorkerActivity
Traits
- mcai_worker::McaiWorker
- mcai_worker::McaiWorkerDescription
- message_exchange::ExternalExchange
- message_exchange::InternalExchange
- message_exchange::ResponseSender
- message_exchange::WorkerResponseSender
- parameter::ParameterValue
- parameter::container::ParametersContainer
- prelude::JsonSchema
- processor::Process
Macros
- default_rust_mcai_worker_description
- prelude::debug
- prelude::default_rust_mcai_worker_description
- prelude::error
- prelude::info
- prelude::trace
- prelude::warn
Derive Macros
Functions
- config::get_amqp_consumer_timeout
- config::get_amqp_delivery_mode
- config::get_amqp_queue
- config::get_amqp_server_configuration
- config::get_amqp_tls_certificate
- config::get_amqp_uri
- config::get_ffmpeg_waitmore_limit
- config::get_soft_reject_count_limit
- config::get_source_orders
- config::get_srt_latency
- config::get_srt_timeout_limit
- 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
- config::is_complex_stream
- message_exchange::message::publish_job_progression
- message_exchange::rabbitmq::channels::declare_consumer_channel
- parameter::store::request_value
- prelude::start_worker
- worker::docker::get_instance_id
Type Aliases
- McaiChannel
- Result
- message_exchange::SharedExternalExchange
- message_exchange::SharedInternalExchange
- parameter::media_segment::MediaSegments
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_BLACK_LIST
- 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