This is the complete list of members for kcenon::thread::backpressure_job_queue, including all inherited members.

apply_backpressure(std::unique_ptr< job > &&value) -> common::VoidResult	kcenon::thread::backpressure_job_queue	private
apply_rate_limiting() -> bool	kcenon::thread::backpressure_job_queue	private
atomic_size_	kcenon::thread::job_queue	private
backpressure_job_queue(std::size_t max_size, backpressure_config config=backpressure_config{})	kcenon::thread::backpressure_job_queue	explicit
backpressure_job_queue(const backpressure_job_queue &)=delete	kcenon::thread::backpressure_job_queue
backpressure_job_queue(backpressure_job_queue &&)=delete	kcenon::thread::backpressure_job_queue
clear(void) -> void	kcenon::thread::job_queue	virtual
condition_	kcenon::thread::job_queue	protected
config_	kcenon::thread::backpressure_job_queue	private
config_mutex_	kcenon::thread::backpressure_job_queue	mutableprivate
current_pressure_	kcenon::thread::backpressure_job_queue	private
current_pressure_ratio_	kcenon::thread::backpressure_job_queue	private
dequeue(void) -> common::Result< std::unique_ptr< job > >	kcenon::thread::job_queue	virtual
dequeue_batch(void) -> std::deque< std::unique_ptr< job > >	kcenon::thread::job_queue	virtual
dequeue_batch_limited(std::size_t max_count) -> std::deque< std::unique_ptr< job > >	kcenon::thread::job_queue	virtual
direct_enqueue(std::unique_ptr< job > &&value) -> common::VoidResult	kcenon::thread::backpressure_job_queue	private
empty(void) const -> bool	kcenon::thread::job_queue
enqueue(std::unique_ptr< job > &&value) -> common::VoidResult override	kcenon::thread::backpressure_job_queue	virtual
kcenon::thread::job_queue::enqueue(std::unique_ptr< JobType > &&value) -> common::VoidResult	kcenon::thread::job_queue	inline
enqueue_batch(std::vector< std::unique_ptr< job > > &&jobs) -> common::VoidResult override	kcenon::thread::backpressure_job_queue	virtual
get_available_tokens() const -> std::size_t	kcenon::thread::backpressure_job_queue
get_backpressure_config() const -> const backpressure_config &	kcenon::thread::backpressure_job_queue
get_backpressure_stats() const -> backpressure_stats_snapshot	kcenon::thread::backpressure_job_queue
get_capabilities() const -> queue_capabilities override	kcenon::thread::job_queue	inlinevirtual
get_max_size() const -> std::optional< std::size_t >	kcenon::thread::job_queue
get_memory_stats() const -> memory_stats	kcenon::thread::job_queue
get_next_job() -> common::Result< std::unique_ptr< job > > override	kcenon::thread::job_queue	inlinevirtual
get_pressure_level() const -> pressure_level	kcenon::thread::backpressure_job_queue
get_pressure_ratio() const -> double	kcenon::thread::backpressure_job_queue
get_ptr(void) -> std::shared_ptr< job_queue >	kcenon::thread::job_queue
handle_adaptive_policy(std::unique_ptr< job > &&value) -> common::VoidResult	kcenon::thread::backpressure_job_queue	private
handle_block_policy(std::unique_ptr< job > &&value) -> common::VoidResult	kcenon::thread::backpressure_job_queue	private
handle_callback_policy(std::unique_ptr< job > &&value) -> common::VoidResult	kcenon::thread::backpressure_job_queue	private
handle_drop_oldest_policy(std::unique_ptr< job > &&value) -> common::VoidResult	kcenon::thread::backpressure_job_queue	private
has_atomic_empty() const -> bool	kcenon::thread::queue_capabilities_interface	inline
has_exact_size() const -> bool	kcenon::thread::queue_capabilities_interface	inline
inspect_pending_jobs(std::size_t limit=100) const -> std::vector< diagnostics::job_info >	kcenon::thread::job_queue	virtual
is_bounded() const -> bool	kcenon::thread::job_queue
is_full() const -> bool	kcenon::thread::job_queue
is_lock_free() const -> bool	kcenon::thread::queue_capabilities_interface	inline
is_rate_limited() const -> bool	kcenon::thread::backpressure_job_queue
is_stopped() const -> bool	kcenon::thread::job_queue
is_wait_free() const -> bool	kcenon::thread::queue_capabilities_interface	inline
job_queue(std::optional< std::size_t > max_size=std::nullopt)	kcenon::thread::job_queue	explicit
max_size_	kcenon::thread::job_queue	private
mutex_	kcenon::thread::job_queue	mutableprotected
notify_	kcenon::thread::job_queue	protected
operator=(const backpressure_job_queue &)=delete	kcenon::thread::backpressure_job_queue
operator=(backpressure_job_queue &&)=delete	kcenon::thread::backpressure_job_queue
queue_	kcenon::thread::job_queue	private
rate_limiter_	kcenon::thread::backpressure_job_queue	private
reset_stats() -> void	kcenon::thread::backpressure_job_queue
schedule(std::unique_ptr< job > &&value) -> common::VoidResult override	kcenon::thread::job_queue	inlinevirtual
set_backpressure_config(backpressure_config config) -> void	kcenon::thread::backpressure_job_queue
set_max_size(std::optional< std::size_t > max_size) -> void	kcenon::thread::job_queue
set_notify(bool notify) -> void	kcenon::thread::job_queue
size(void) const -> std::size_t	kcenon::thread::job_queue
space_available_	kcenon::thread::backpressure_job_queue	private
stats_	kcenon::thread::backpressure_job_queue	private
stop(void) -> void	kcenon::thread::job_queue
stop_	kcenon::thread::job_queue	protected
supports_batch() const -> bool	kcenon::thread::queue_capabilities_interface	inline
supports_blocking_wait() const -> bool	kcenon::thread::queue_capabilities_interface	inline
supports_stop() const -> bool	kcenon::thread::queue_capabilities_interface	inline
to_string() const -> std::string override	kcenon::thread::backpressure_job_queue	virtual
try_dequeue(void) -> common::Result< std::unique_ptr< job > >	kcenon::thread::job_queue	virtual
update_pressure_state() -> void	kcenon::thread::backpressure_job_queue	private
~backpressure_job_queue() override	kcenon::thread::backpressure_job_queue
~job_queue(void)	kcenon::thread::job_queue	virtual
~queue_capabilities_interface()=default	kcenon::thread::queue_capabilities_interface	virtual
~scheduler_interface()=default	kcenon::thread::scheduler_interface	virtual