Method List

Classes Methods Files

Search:

#accepting_jobs? NatsWork::Worker
#active_count NatsWork::ThreadPool
#add NatsWork::Middleware::MiddlewareChain
#add NatsWork::Server::MiddlewareChain
#add_check NatsWork::HealthChecker
#add_collector NatsWork::Metrics
#add_error_handler NatsWork::JobExecutor
#add_job_filter NatsWork::JobExecutor
#add_middleware NatsWork::JobExecutor
#add_notifier NatsWork::ErrorTracker
#add_queue NatsWork::QueueManager
#add_reporter NatsWork::Monitoring::Coordinator
#after NatsWork::JobHooks
#args NatsWork::Middleware::Entry
#base_delay NatsWork::RetryHandler
#before NatsWork::JobHooks
#build NatsWork::Middleware::Entry
build_job_error NatsWork::Protocol::MessageBuilder
build_job_request NatsWork::Protocol::MessageBuilder
build_job_response NatsWork::Protocol::MessageBuilder
build_worker_heartbeat NatsWork::Protocol::MessageBuilder
#calculate_delay NatsWork::RetryHandler
#call NatsWork::Instrumentation::Subscription
#call NatsWork::Middleware::Timer
#call NatsWork::ErrorNotifiers::WebhookNotifier
#call NatsWork::Middleware::Retry
#call NatsWork::ErrorNotifiers::LogNotifier
#call NatsWork::Middleware::ErrorHandler
#call NatsWork::Middleware::Logger
#call NatsWork::ErrorNotifiers::MetricsNotifier
#callback NatsWork::Instrumentation::Subscription
#categorize_errors NatsWork::ErrorTracker
#check NatsWork::HealthChecker
#check! NatsWork::HealthCheck
#check_all! NatsWork::HealthChecker
#clear NatsWork::Server::MiddlewareChain
#clear NatsWork::Middleware::MiddlewareChain
#clear NatsWork::JobHooks
#clear_errors! NatsWork::ErrorTracker
#clear_subscribers! NatsWork::Instrumentation
#close NatsWork::Monitoring::StatsDReporter
#collect NatsWork::MetricsCollector
#collect NatsWork::StatsDCollector
compatible? NatsWork::Protocol::VersionNegotiator
#concurrency NatsWork::Worker
#concurrency_limits NatsWork::QueueManager
configure NatsWork::Logger
#connection NatsWork::Worker
#count NatsWork::RateTracker
#counter NatsWork::Metrics
#counters NatsWork::Metrics
#debug NatsWork::Logger
#degraded? NatsWork::HealthCheck
deserialize_from_language NatsWork::Protocol::TypeMapper
deserialize_from_python NatsWork::Protocol::TypeMapper
#disable! NatsWork::Monitoring::Coordinator
#disable! NatsWork::Instrumentation
#disable! NatsWork::Metrics
#drain NatsWork::QueueManager
#drain_all NatsWork::QueueManager
#empty? NatsWork::Server::MiddlewareChain
#enable! NatsWork::Monitoring::Coordinator
#enable! NatsWork::Metrics
#enable! NatsWork::Instrumentation
#enabled? NatsWork::Instrumentation
#entries NatsWork::Middleware::MiddlewareChain
#error NatsWork::Logger
#error_rates NatsWork::ErrorTracker
#error_stats NatsWork::ErrorTracker
errors NatsWork::ErrorTracker
#errors NatsWork::ErrorTracker
#event NatsWork::Instrumentation::Subscription
#execute_job NatsWork::JobExecutor
#export_metrics NatsWork::Monitoring::PrometheusExporter
#fatal NatsWork::Logger
#flush_metrics NatsWork::Monitoring::WebhookReporter
#gauge NatsWork::Metrics
#gauges NatsWork::Metrics
generate_uuid NatsWork::Protocol::MessageBuilder
#get_error NatsWork::ErrorTracker
#get_gauge NatsWork::Metrics
global NatsWork::Metrics
global NatsWork::HealthChecker
global NatsWork::ErrorTracker
global NatsWork::JobHooks
global NatsWork::Logger
global NatsWork::Monitoring::Coordinator
#graceful_shutdown NatsWork::Worker
#handle_failure NatsWork::RetryHandler
#healthy? NatsWork::HealthCheck
#healthy? NatsWork::HealthChecker
#heartbeat NatsWork::Worker
#histogram NatsWork::Metrics
#histogram_stats NatsWork::Metrics
#histograms NatsWork::Metrics
#id NatsWork::Server::SimpleWorker
included NatsWork::Instrumentation::ActiveSupportCompatibility
#increment NatsWork::RateTracker
#increment NatsWork::Metrics
#info NatsWork::Logger
#initialize NatsWork::StatsDCollector
#initialize NatsWork::JobHooks
#initialize NatsWork::Server::MiddlewareChain
#initialize NatsWork::Instrumentation::Subscription
#initialize NatsWork::Middleware::Entry
#initialize NatsWork::Middleware::MiddlewareChain
#initialize NatsWork::Monitoring::Coordinator
#initialize NatsWork::Monitoring::SystemMetrics
#initialize NatsWork::Metrics
#initialize NatsWork::ThreadPool
#initialize NatsWork::Server::WorkerManager
#initialize NatsWork::JobExecutor
#initialize NatsWork::ErrorNotifiers::MetricsNotifier
#initialize NatsWork::Worker
#initialize NatsWork::ErrorNotifiers::WebhookNotifier
#initialize NatsWork::Server::SimpleWorker
#initialize NatsWork::LoggerProxy
#initialize NatsWork::HealthChecker
#initialize NatsWork::Logger
#initialize NatsWork::CLI
#initialize NatsWork::HealthCheck
#initialize NatsWork::RetryHandler
#initialize NatsWork::ErrorNotifiers::LogNotifier
#initialize NatsWork::Monitoring::StatsDReporter
#initialize NatsWork::Middleware::Retry
#initialize NatsWork::Middleware::Logger
#initialize NatsWork::Middleware::ErrorHandler
#initialize NatsWork::Monitoring::PrometheusExporter
#initialize NatsWork::ErrorTracker
#initialize NatsWork::Monitoring::NewRelicReporter
#initialize NatsWork::QueueManager
#initialize NatsWork::Monitoring::WebhookReporter
#initialize NatsWork::RateTracker
#instrument NatsWork::Instrumentation
#instrument NatsWork::Instrumentation::ActiveSupportCompatibility::ClassMethods
#invoke NatsWork::Server::MiddlewareChain
#invoke NatsWork::Middleware::MiddlewareChain
#jitter NatsWork::RetryHandler
job_error NatsWork::Protocol::Schema
job_request NatsWork::Protocol::Schema
job_response NatsWork::Protocol::Schema
#klass NatsWork::Middleware::Entry
#last_checked NatsWork::HealthCheck
#level= NatsWork::Logger
#list_errors NatsWork::ErrorTracker
#logger NatsWork::JobExecutor
#logger NatsWork::Logger
#max_delay NatsWork::RetryHandler
#max_queue_size NatsWork::ThreadPool
#memory_usage NatsWork::ThreadPool
#message NatsWork::HealthCheck
#metadata NatsWork::HealthCheck
method_missing NatsWork::Metrics
#method_missing NatsWork::LoggerProxy
method_missing NatsWork::Logger
#metrics NatsWork::JobExecutor
#name NatsWork::HealthCheck
#name NatsWork::Worker
#namespace NatsWork::Logger
negotiate NatsWork::Protocol::VersionNegotiator
new_relic NatsWork::Monitoring::Setup
#on_failure NatsWork::JobHooks
#on_failure NatsWork::RetryHandler
#on_job_failure NatsWork::JobExecutor
#on_job_retry NatsWork::JobExecutor
#on_retry NatsWork::JobHooks
#on_retry NatsWork::RetryHandler
#on_success NatsWork::JobHooks
parse_major_version NatsWork::Protocol::VersionNegotiator
parse_queue_language NatsWork::Protocol::LanguageRouter
#pause NatsWork::QueueManager
#pause NatsWork::Worker
#pause_all NatsWork::QueueManager
#paused? NatsWork::QueueManager
#paused? NatsWork::Worker
#paused_queues NatsWork::QueueManager
#pool NatsWork::Server::WorkerManager
#pool NatsWork::Server::SimpleWorker
#priorities NatsWork::QueueManager
prometheus NatsWork::Monitoring::Setup
queue_for_language NatsWork::Protocol::LanguageRouter
#queue_size NatsWork::ThreadPool
#queues NatsWork::Server::SimpleWorker
#queues NatsWork::Worker
#rate NatsWork::RateTracker
#register NatsWork::JobHooks
#remove NatsWork::Middleware::MiddlewareChain
#remove_check NatsWork::HealthChecker
#remove_collector NatsWork::Metrics
#remove_queue NatsWork::QueueManager
#remove_reporter NatsWork::Monitoring::Coordinator
#report NatsWork::HealthChecker
#report_counter NatsWork::Monitoring::Coordinator
#report_counter NatsWork::Monitoring::NewRelicReporter
#report_counter NatsWork::Monitoring::StatsDReporter
#report_counter NatsWork::Monitoring::WebhookReporter
#report_gauge NatsWork::Monitoring::Coordinator
#report_gauge NatsWork::Monitoring::WebhookReporter
#report_gauge NatsWork::Monitoring::NewRelicReporter
#report_gauge NatsWork::Monitoring::StatsDReporter
#report_histogram NatsWork::Monitoring::Coordinator
#report_histogram NatsWork::Monitoring::StatsDReporter
#report_metric NatsWork::Monitoring::WebhookReporter
#report_timer NatsWork::Monitoring::WebhookReporter
#report_timer NatsWork::Monitoring::Coordinator
#report_timer NatsWork::Monitoring::NewRelicReporter
#report_timer NatsWork::Monitoring::StatsDReporter
#reset! NatsWork::Metrics
respond_to_missing? NatsWork::Metrics
respond_to_missing? NatsWork::Logger
#respond_to_missing? NatsWork::LoggerProxy
#resume NatsWork::QueueManager
#resume NatsWork::Worker
#resume_all NatsWork::QueueManager
route_job NatsWork::Protocol::LanguageRouter
#run NatsWork::JobHooks
#run NatsWork::CLI
#running NatsWork::Server::WorkerManager
#running? NatsWork::Server::WorkerManager
#running? NatsWork::Worker
running? NatsWork::Server
#schedule_retry NatsWork::RetryHandler
#send_to_dead_letter NatsWork::RetryHandler
serialize_for_go NatsWork::Protocol::TypeMapper
serialize_for_javascript NatsWork::Protocol::TypeMapper
serialize_for_language NatsWork::Protocol::TypeMapper
serialize_for_python NatsWork::Protocol::TypeMapper
#set_concurrency NatsWork::QueueManager
#set_priority NatsWork::QueueManager
#set_threshold NatsWork::HealthChecker
setup_worker_checks NatsWork::WorkerHealth
#should_retry? NatsWork::RetryHandler
#shutdown NatsWork::ThreadPool
#shutdown NatsWork::Monitoring::Coordinator
#shutdown! NatsWork::ThreadPool
#size NatsWork::ThreadPool
#snapshot NatsWork::Metrics
#start NatsWork::Server::WorkerManager
#start NatsWork::Server::SimpleWorker
#start NatsWork::Worker
start NatsWork::Server
#start_collection NatsWork::Monitoring::SystemMetrics
#start_server NatsWork::Monitoring::PrometheusExporter
#stats NatsWork::ThreadPool
#stats NatsWork::Worker
#stats NatsWork::QueueManager
#stats NatsWork::Server::WorkerManager
stats NatsWork::ErrorTracker
statsd NatsWork::Monitoring::Setup
#status NatsWork::HealthCheck
#status NatsWork::HealthChecker
#stop NatsWork::Worker
stop NatsWork::Server
#stop NatsWork::Server::SimpleWorker
#stop NatsWork::Server::WorkerManager
#stop_collection NatsWork::Monitoring::SystemMetrics
#stop_server NatsWork::Monitoring::PrometheusExporter
#stopping? NatsWork::Worker
#strategy NatsWork::RetryHandler
#structured NatsWork::Logger
#submit NatsWork::ThreadPool
#subscribe NatsWork::Instrumentation
#subscribe NatsWork::Instrumentation::ActiveSupportCompatibility::ClassMethods
#subscribe NatsWork::QueueManager
#subscriptions NatsWork::QueueManager
#time NatsWork::Metrics
#timer_stats NatsWork::Metrics
#timers NatsWork::Metrics
#to_h NatsWork::HealthCheck
track NatsWork::ErrorTracker
#track_error NatsWork::ErrorTracker
#unhealthy? NatsWork::HealthCheck
#unsubscribe NatsWork::Instrumentation
#unsubscribe NatsWork::QueueManager
#unsubscribe_all NatsWork::QueueManager
valid_job_error? NatsWork::Protocol::Validator
valid_job_request? NatsWork::Protocol::Validator
valid_job_response? NatsWork::Protocol::Validator
validate_message NatsWork::Protocol::Validator
#wait_for_termination NatsWork::ThreadPool
#warn NatsWork::Logger
webhook NatsWork::Monitoring::Setup
#with_namespace NatsWork::Logger
worker_heartbeat NatsWork::Protocol::Schema
worker_manager NatsWork::Server
#worker_name NatsWork::JobExecutor
#workers NatsWork::Server::WorkerManager