!

miq_widget.rb [1]

-

[:id] miq_queue.rb [1]

[]

:queue_name console_methods.rb [1]

any?

[:block_pass, :unfinished?] miq_widget.rb [1]

arel_table

console_methods.rb [1]

column_names

miq_queue.rb [1]

columns_for_requeue

miq_queue.rb [1]

count

storage.rb [1]

create!

:options miq_queue.rb [1]

create_with

:attributes job.rb [1]
:callback miq_widget.rb [1]
"options.slice(...)" authentication_mixin.rb [1]
args miq_callback msg_timeout priority ref file ref
[:options] options.delet options.delet HIGH_PRIORITY log_management.rb
HIGH_PRIORITY log_management.rb

delay_queue_delivery_for_vim_broker?

runner.rb [1]

destroy_all

stop.rb [1]

each

yields miq_queue.rb miq_provision_quota_mixin.rb [1] [1]
yields jobs.rb [1]
yields miq_provision_quota_mixin.rb [1]

exists?

class_name state task_id zone ref file ref
MiqServer ["dequeue", " job.guid job.rb
STATE_DEQUEUE msg.task_id [nil, "MiqSer runner.rb

find_by

id ref file ref
msg_id runner.rb
qitem_id storage.rb

first

console_methods.rb [1]

format_full_log_msg

:msg miq_queue.rb [2] [3] runner.rb queue_management.rb [1] [2] [3] [1] [1]
:self miq_queue.rb [1]
:m miq_worker.rb [2] [1] [2]

format_short_log_msg

:msg miq_queue.rb [2] [3] [4] runner.rb [2] [1] [2] [3] [4] [1] [2]
:self miq_queue.rb [2] [3] [4] [5] [6] [7] [8] [9] [10] [11] [12] [13] [14] [1] [2] [3] [4] [5] [6] [7] [8] [9] [10] [11] [12] [13] [14]

get

priority queue_name role zone ref file ref
@worker.class @worker.queue @active_roles runner.rb
miq_server my_zone queue_management.rb [2]

get_worker

"guid" job.rb [1]

higher_priority?

:priority "msg.priority" capture.rb [1]

in_my_region

jobs.rb [1]

includes

:handler jobs.rb [1]
:handler validation.rb [1]

index_by

[:block_pass, :args] capture.rb [1]

limit

:prefetch_max_per_worker miq_queue.rb [1]
[:or, :limit, 1] miq_queue.rb [1]

lower_priority

"get_queue_priority_for_worker(...)" "options[1]" dequeue.rb [1]

lower_priority?

"msg[priority]" "get_queue_priority_for_worker(...)" dequeue.rb [1]

map

[:block_pass, :to_sym] miq_queue.rb [1]

nested_count_by

["state", "zone", "role"] status_management.rb [1]

new

deliver_on ref file ref
Time.now.utc. storage.rb

not

method_name ref file ref
perf_capture_ capture.rb

not_eq

"miq_server" console_methods.rb [1]

order

:priority :id miq_queue.rb [1]
:created_on capture.rb [1]
:id console_methods.rb [1]
"priority, id" miq_queue.rb [1]

peek

conditions limit select ref file ref
{:queue_name= limit id, lock_vers dequeue.rb

priority

:normal :higher 10 runner.rb [1]
"msg[priority]" :higher 1 dequeue.rb [1]

put

:item capture.rb [1]
:put_options miq_queue.rb [1]
:queue_options miq_ae_service_ems_operations_mixin.rb miq_request_task.rb miq_task.rb [1] [1] [1]
:options miq_ae_engine.rb authentication_mixin.rb [1] [1]
:nh service.rb [1]
"queue_opts(...)" custom_button.rb [1]
"options.slice(...)" miq_queue.rb [1]
args class_name data deliver_on instance_id method_name miq_callback msg_timeout priority queue_name role server_guid task_id tracking_label zone ref file ref
args @object.class @object.id migrate_via_i ems_operation @object.my_zo miq_ae_service_vm_or_template.rb
args NativeOperati deliver_on id signal priority role guid zone native_operation_workflow.rb
args StateMachine. id method_name my_role my_task_id my_zone state_machine.rb
target_args [:if, :static [:if, :static target_method HIGH_PRIORITY role zone miq_action.rb
["ems.id", :t name refresh_new_t queue_timeout MiqEmsRefresh ems_inventory nil ems.my_zone ems_refresh.rb
["ems.id"] name deliver_on reconnect_ems miq_vim_broker_worker.rb
["host.id"] @object.class @object.id register_host ems_operation @object.my_zo miq_ae_service_ems_cluster.rb miq_ae_service_ems_folder.rb
["server_ntp_ MiqServer id ntp_reload HIGH_PRIORITY guid my_zone queue_management.rb
["task.id", : Generator.nam id build_report_ queue_timeout reporting reporting generator.rb
["task.id", : Generator.nam id _async_genera queue_timeout reporting generator.rb
["task.id"] Host.name id scan_from_que cb timeout my_zone host.rb
[:args] MiqAeEngine deliver automate #{ServiceReco zone service_reconfigure_task.rb
[:args] MiqAeEngine deliver automate #{ServiceTemp options.fetch service_template_provision_task.rb
[:args] MiqAeEngine deliver automate my_task_id options.fetch miq_request_task.rb
[:attribute, @object.class @object.id set_custom_fi ems_operation @object.my_zo miq_ae_service_host.rb miq_ae_service_vm_or_template.rb
[:description Snapshot.name Time.now.utc. id remove_snapsh smartstate my_zone snapshot.rb
[:device] @object.class @object.id vim_disable_v ems_operation @object.my_zo miq_ae_service_manageiq-providers-vmware-infra_manager-host_esx.rb
[:device] @object.class @object.id vim_enable_vm ems_operation @object.my_zo miq_ae_service_manageiq-providers-vmware-infra_manager-host_esx.rb
[:event, ["ta MiqAeEvent raise_evm_eve HIGH_PRIORITY automate [:if, "target miq_alert.rb
[:event_name] MiqRequest.na id call_automate 3600 options.fetch miq_request.rb
[:force] @object.class @object.id vim_reboot ems_operation @object.my_zo miq_ae_service_manageiq-providers-vmware-infra_manager-host_esx.rb
[:force] @object.class @object.id vim_shutdown ems_operation @object.my_zo miq_ae_service_manageiq-providers-vmware-infra_manager-host_esx.rb
[:inputs] MiqSnmp trap_v1 notifier nil miq_ae_service_methods.rb
[:inputs] MiqSnmp trap_v2 notifier nil miq_ae_service_methods.rb
[:miq_task_id name scan_watchdog scan_watchdog MiqServer.my_ storage.rb
[:options] name _request_logs cb LOG_REQUEST_T HIGH_PRIORITY zone log_file.rb
[:start_snaps VmScan.to_s id signal smartstate from_zone vm_scan.rb
[:timeout, :e @object.class @object.id vim_enter_mai ems_operation @object.my_zo miq_ae_service_manageiq-providers-vmware-infra_manager-host_esx.rb
[:timeout, :e @object.class @object.id vim_power_dow ems_operation @object.my_zo miq_ae_service_manageiq-providers-vmware-infra_manager-host_esx.rb
[:timeout] @object.class @object.id vim_exit_main ems_operation @object.my_zo miq_ae_service_manageiq-providers-vmware-infra_manager-host_esx.rb
[:timeout] @object.class @object.id vim_power_up_ ems_operation @object.my_zo miq_ae_service_manageiq-providers-vmware-infra_manager-host_esx.rb
[["target.cla name scan_and_chec ems_inventory vc-refresher target.ext_ma compliance.rb
[["target.cla name raise_evm_eve nil miq_event.rb
[["target.cla name raise_evm_eve miq_event.rb
@object.class @object.id m ems_operation @object.my_zo miq_ae_service_host.rb miq_ae_service_vm_or_template.rb
Host Marshal.dump( discoverHost MiqServer.my_ host.rb
MiqRequest.na deliver_on id create_reques 3600 my_role #{MiqRequest. options.fetch miq_request.rb
PostInstallCa id provision_com my_role my_task_id my_zone post_install_callback.rb
StateMachine. 10.seconds.fr id phase {:class_name= my_role my_task_id my_zone state_machine.rb
MiqServer s.id sync_blacklis HIGH_PRIORITY miq_server s.guid blacklisted_event.rb
RetirementMan check retirement_mixin.rb
ServiceTempla 1.minutes.fro id do_post_provi {:class_name= #{ServiceTemp service_template_provision_task.rb
TimeProfile.n id destroy_metri 1.hour time_profile.rb
TimeProfile.n id rebuild_daily 1.hour time_profile.rb
name deliver_on id orchestrate_d ext_management_system.rb
name id task.to_s 3600 async_delete_mixin.rb

put_deprecated

args class_name instance_id method_name priority queue_name server_guid zone ref file ref
["id", :messa MiqServer miq_server.id message_for_w miq_server miq_server.gu miq_server.zo miq_worker.rb
["ntp_setting MiqServer s.id ntp_reload HIGH_PRIORITY s.guid name zone.rb
["worker.id", Stop.name id stop_worker miq_server guid zone.name stop.rb

put_or_update

:queue_options yields ems_refresh.rb [1]
:queue_item_options yields capture.rb [1]

put_unless_exists

:options yields job_proxy_dispatcher.rb [1]
:options no yield jobs.rb [1]
"options.except(...)" yields authentication_mixin.rb [1]
args class_name deliver_on instance_id method_name msg_timeout priority queue_name role server_guid task_id zone yield? ref file ref
[[:splat, :ar MiqWidget.to_ id generate_cont 3600 reporting reporting false miq_widget.rb
Job.base_clas id signal_abort smartstate MiqServer.my_ false job.rb
LogManagement id delete_active guid true log_management.rb
LogManagement id post_logs guid my_zone true log_management.rb
args Rollup.name deliver_on id perf_rollup TIMEOUT_PROCE Capture.const ems_metrics_p ems_metrics_p my_zone true rollup.rb
[:snapshot_id Snapshot.name id remove_evm_sn ems_operation task_id my_zone false snapshot.rb
[:snapshot_id Snapshot.name id remove_snapsh ems_operation task_id my_zone false snapshot.rb
[:start] Job job.id signal HIGH_PRIORITY smartstate job.guid job.zone false job_proxy_dispatcher.rb
[:start_time, Rollup.name id perf_rollup_r priority ems_metrics_p ems_metrics_p my_zone false rollup.rb
[:start_time, name perf_rollup_g HIGH_PRIORITY false rollup.rb
[["target.cla MiqAlert.name id evaluate zone false miq_alert.rb
[["target.cla MiqAlert evaluate_aler false miq_event.rb
ExtManagement id stop_event_mo HIGH_PRIORITY event my_zone false ext_management_system.rb
IsoDatastore. id synchronize_a ems_operation ext_managemen false iso_datastore.rb
QueueManageme id method_name miq_server guid zone.name false queue_management.rb
UpdateManagem id apply_updates guid my_zone false update_management.rb
UpdateManagem id check_updates guid my_zone false update_management.rb
UpdateManagem id update_regist guid my_zone false update_management.rb
PxeServer.nam id sync_images false pxe_server.rb
PxeServer.nam id synchronize_a false pxe_server.rb
ems.class ems_id sync_cloud_te ems.my_zone false cloud_tenant.rb

select

:method_name :created_on capture.rb [1]

submit_job

affinity args class_name data deliver_on instance_id method_name miq_callback msg_timeout priority role server_guid service target_id task_id ref file ref
ext_managemen [:miq_task_id Storage.name id smartstate_an cb Storage.scan_ ems_operation storage.rb
ext_managemen EmsCluster.to id save_drift_st smartstate ems_cluster.rb
ext_managemen ScanningOpera Marshal.dump( save_metadata smartstate id jobid scanning_operations_mixin.rb
rec.ext_manag inputs[policy rec.class.nam rec.id annotate_deny HIGH_PRIORITY ems_operation miq_action.rb
rec.ext_manag Host rec.id scan_from_que HIGH_PRIORITY smartstate miq_action.rb
vm.ext_manage args base_class.na vm.id options[task] cb [:if, "option vm_or_template.rb
args base_class.na vm.id options[task] cb vm_or_template.rb
args name instance.id options[task] cb process_tasks_mixin.rb
options Service.name id generate_char reporting service.rb
ost ServerSmartPr id ost.method_na worker_settin guid smartproxy server_smart_proxy.rb
["config", "t Base.to_s authorize {:class_name= HIGH_PRIORITY MiqServer.my_ base.rb
["ost.taskid" Job update_messag smartstate job_message_# scanning_mixin.rb
["task.id", " MiqReportResu id _async_genera report.queue_ HIGH_PRIORITY reporting miq_report_result.rb
["task.id", : Async.to_s id _async_genera cb queue_timeout HIGH_PRIORITY reporting async.rb
["task.id", : to_s _async_genera default_queue HIGH_PRIORITY reporting async.rb
["task.id", : Async.to_s _async_genera cb queue_timeout HIGH_PRIORITY reporting reporting async.rb
["task.id"] to_s _async_datast 3600 HIGH_PRIORITY automate miq_automate.rb
[:action, :at name sched.id invoke_action 1200 miq_schedule.rb
[:add] VmOrTemplate. id classify_with MIN_PRIORITY vm_or_template.rb
[:event] EmsEvent meth event ems_id ems_event.rb
[:ids] name destroy HIGH_PRIORITY job.rb
[:ids] name destroy miq_task.rb
[:method, :op name deliver notifier generic_mailer.rb
[:options] name invoke_tasks process_tasks_mixin.rb
[:remote_opti name Time.now.utc. invoke_tasks_ process_tasks_mixin.rb
[:ts, :condit name destroy_older miq_task.rb
[:ts] name purge_#{inter msg_timeout purging.rb
[:userid, :op ScanningMixin id scan scanning_mixin.rb
[:value] name purge_#{inter msg_timeout purging.rb
[:value] name purge_by_#{mo purging_mixin.rb
[:vm_ids] name assign_ems_cr MIN_PRIORITY vm_or_template.rb
[["target.cla name check_complia compliance.rb
[["userid IN name destroy_all HIGH_PRIORITY miq_report_result.rb
VmOrTemplate. id post_create_a vm_or_template.rb

try

:update_heartbeat job.rb [1]

where

:queue_item capture.rb [1]
:cond miq_queue.rb [2] [1] [2]
:conds miq_queue.rb [2] [1] [2]
["args = ?", :args] miq_queue.rb [1]
"updated_on < ?" :threshold jobs.rb [1]
"tracking_label like ?" "%miq_provision_%" miq_provision_quota_mixin.rb [1]
"MiqQueue.arel_table[queue_name].not_eq(...)" console_methods.rb [1]
capture.rb [1]
class_name deliver_on instance_id method_name queue_name role server_guid state target_id zone ref file ref
class_n method_n dequeue zone jobs.rb
["perf_captur ems_metrics_c ready zone.name capture.rb
MiqAeEngine deliver ["ready", "de miq_provision_quota_mixin.rb
MiqProvisionR scheduled_ran create_provis ready miq_provision_quota_mixin.rb
MiqProvisionR create_provis dequeue miq_provision_quota_mixin.rb
Stop.name stop_worker miq_server guid stop.rb
MiqWidget.nam id generate_cont miq_widget.rb
Storage.name id smartstate_an dequeue host_id storage.rb
dequeue validation.rb
STATE_DEQUEUE miq_queue.rb