Method List

Classes Methods Files

Search:

#[] DispatchPolicy::Context
#[] DispatchPolicy::Registry
active? DispatchPolicy::Bypass
#adapter_throughput_target DispatchPolicy::Config
adaptive_current_max DispatchPolicy::Repository
adaptive_record! DispatchPolicy::Repository
adaptive_seed! DispatchPolicy::Repository
#admission_batch_size DispatchPolicy::Config
#admission_batch_size DispatchPolicy::Policy
#admission_batch_size DispatchPolicy::PolicyDSL
#admit DispatchPolicy::PartitionsController
#admit_count DispatchPolicy::Pipeline::Result
#allowed DispatchPolicy::Decision
apply DispatchPolicy::CursorPagination
around_enqueue_for DispatchPolicy::JobExtension
build DispatchPolicy::PolicyDSL
#build_context DispatchPolicy::Policy
bulk_record_partition_denies! DispatchPolicy::Repository
#busy_pause DispatchPolicy::Config
#bypass_retries? DispatchPolicy::Policy
#call DispatchPolicy::Tick
#call DispatchPolicy::Pipeline
claim_partitions DispatchPolicy::Repository
claim_staged_jobs! DispatchPolicy::Repository
#clear DispatchPolicy::Registry
#clock DispatchPolicy::Config
config DispatchPolicy
configure DispatchPolicy
connection DispatchPolicy::Repository
#consume DispatchPolicy::Gate
#context DispatchPolicy::PolicyDSL
#context_proc DispatchPolicy::Policy
#copy_migration DispatchPolicy::Generators::InstallGenerator
count_inflight DispatchPolicy::Repository
#create_initializer DispatchPolicy::Generators::InstallGenerator
#create_tick_loop_job DispatchPolicy::Generators::InstallGenerator
#data DispatchPolicy::Context
#database_role DispatchPolicy::Config
decode DispatchPolicy::CursorPagination
delete_inflight! DispatchPolicy::Repository
denied_reasons_summary DispatchPolicy::Repository
deny DispatchPolicy::Decision
deserialize DispatchPolicy::Serializer
dispatch DispatchPolicy::Forwarder
#drain DispatchPolicy::PoliciesController
#drain DispatchPolicy::PartitionsController
drain_partition! DispatchPolicy::PartitionsController
dump_jsonb DispatchPolicy::Serializer
#each DispatchPolicy::Registry
#enabled DispatchPolicy::Config
encode DispatchPolicy::CursorPagination
enqueue_wait_until DispatchPolicy::Forwarder
ensure_arguments_materialized! DispatchPolicy::JobExtension
#evaluate DispatchPolicy::Gate
#evaluate DispatchPolicy::Gates::Throttle
#evaluate DispatchPolicy::Gates::Concurrency
#evaluate DispatchPolicy::Gates::AdaptiveConcurrency
#ewma_alpha DispatchPolicy::Gates::AdaptiveConcurrency
extract DispatchPolicy::CursorPagination
#fail_factor DispatchPolicy::Gates::AdaptiveConcurrency
#fairness DispatchPolicy::PolicyDSL
#fairness_half_life_seconds DispatchPolicy::Config
#fairness_half_life_seconds DispatchPolicy::Policy
#fetch DispatchPolicy::Context
#fetch DispatchPolicy::Registry
for DispatchPolicy::OperatorHints
#full_backoff DispatchPolicy::Gates::Concurrency
#full_backoff DispatchPolicy::Gates::AdaptiveConcurrency
#gate DispatchPolicy::PolicyDSL
#gate_state_patch DispatchPolicy::Decision
#gate_state_patch DispatchPolicy::Pipeline::Result
#gates DispatchPolicy::Policy
heartbeat_inflight! DispatchPolicy::Repository
#idle_pause DispatchPolicy::Config
#index DispatchPolicy::PoliciesController
#index DispatchPolicy::DashboardController
#index DispatchPolicy::PartitionsController
#inflight_heartbeat_interval DispatchPolicy::Config
#inflight_partition_key DispatchPolicy::Gates::Concurrency
#inflight_partition_key DispatchPolicy::Gates::AdaptiveConcurrency
#inflight_stale_after DispatchPolicy::Config
#initial_max DispatchPolicy::Gates::AdaptiveConcurrency
#initialize DispatchPolicy::Tick
#initialize DispatchPolicy::Config
#initialize DispatchPolicy::Policy
#initialize DispatchPolicy::Context
#initialize DispatchPolicy::Decision
#initialize DispatchPolicy::Pipeline
#initialize DispatchPolicy::Registry
#initialize DispatchPolicy::PolicyDSL
#initialize DispatchPolicy::Gates::Throttle
#initialize DispatchPolicy::InflightTracker::ThreadSafeFlag
#initialize DispatchPolicy::Gates::Concurrency
#initialize DispatchPolicy::Gates::AdaptiveConcurrency
insert_inflight! DispatchPolicy::Repository
#jobs_admitted DispatchPolicy::Tick::Result
#level DispatchPolicy::OperatorHints::Hint
load_jsonb DispatchPolicy::Serializer
#logger DispatchPolicy::Config
lookup_admitted_at DispatchPolicy::InflightTracker
#make_true DispatchPolicy::InflightTracker::ThreadSafeFlag
#max_proc DispatchPolicy::Gates::Concurrency
#message DispatchPolicy::OperatorHints::Hint
#metrics_retention DispatchPolicy::Config
#min DispatchPolicy::Gates::AdaptiveConcurrency
#name DispatchPolicy::Gate
#name DispatchPolicy::Policy
#name DispatchPolicy::Gates::Throttle
#name DispatchPolicy::Gates::Concurrency
#name DispatchPolicy::Gates::AdaptiveConcurrency
#names DispatchPolicy::Registry
next_eligible_clause DispatchPolicy::Repository
next_migration_number DispatchPolicy::Generators::InstallGenerator
normalize_partition DispatchPolicy::Repository
normalize_staged DispatchPolicy::Repository
#now DispatchPolicy::Config
#pagination_params DispatchPolicy::PartitionsController
parse_jsonb DispatchPolicy::Repository
#partition_batch_size DispatchPolicy::Config
#partition_by DispatchPolicy::PolicyDSL
#partition_by_proc DispatchPolicy::Policy
#partition_for DispatchPolicy::Policy
#partition_inactive_after DispatchPolicy::Config
#partition_key_for DispatchPolicy::Policy
partition_round_trip_stats DispatchPolicy::Repository
#partitions_seen DispatchPolicy::Tick::Result
#pause DispatchPolicy::PoliciesController
#paused? DispatchPolicy::Partition
#per DispatchPolicy::Gates::Throttle
#perform_all_later DispatchPolicy::JobExtension::BulkEnqueue
policy_names DispatchPolicy::TickLoop
#queue_name DispatchPolicy::Policy
#queue_name DispatchPolicy::PolicyDSL
#rate_proc DispatchPolicy::Gates::Throttle
#real_adapter DispatchPolicy::Config
#reason DispatchPolicy::Decision
#reasons DispatchPolicy::Pipeline::Result
record_adaptive_observations DispatchPolicy::InflightTracker
#record_observation DispatchPolicy::Gates::AdaptiveConcurrency
record_partition_admit! DispatchPolicy::Repository
record_tick_sample! DispatchPolicy::Repository
#register DispatchPolicy::Registry
registry DispatchPolicy
reset_config! DispatchPolicy
reset_registry! DispatchPolicy
#restage_retries? DispatchPolicy::Policy
#resume DispatchPolicy::PoliciesController
#retry_after DispatchPolicy::Decision
#retry_after DispatchPolicy::Pipeline::Result
retry_attempt? DispatchPolicy::JobExtension
#retry_strategy DispatchPolicy::Policy
#retry_strategy DispatchPolicy::PolicyDSL
run DispatchPolicy::Tick
run DispatchPolicy::TickLoop
sample_filter DispatchPolicy::Repository
scheduled_time DispatchPolicy::JobExtension
serialize DispatchPolicy::Serializer
serialize_value DispatchPolicy::CursorPagination
#shard_by DispatchPolicy::PolicyDSL
#shard_by_proc DispatchPolicy::Policy
#shard_for DispatchPolicy::Policy
#show DispatchPolicy::PoliciesController
#show DispatchPolicy::PartitionsController
#show DispatchPolicy::StagedJobsController
#show_readme DispatchPolicy::Generators::InstallGenerator
#size DispatchPolicy::Registry
#slow_factor DispatchPolicy::Gates::AdaptiveConcurrency
sort_for DispatchPolicy::CursorPagination
stage! DispatchPolicy::Repository
stage_many! DispatchPolicy::Repository
start_heartbeat DispatchPolicy::InflightTracker
#stop_flag DispatchPolicy::InflightTracker::Heartbeat
stop_heartbeat DispatchPolicy::InflightTracker
sweep! DispatchPolicy::TickLoop
#sweep_every_ticks DispatchPolicy::Config
sweep_inactive_partitions! DispatchPolicy::Repository
sweep_old_tick_samples! DispatchPolicy::Repository
sweep_stale_inflight! DispatchPolicy::Repository
#target_lag_ms DispatchPolicy::Gates::AdaptiveConcurrency
#thread DispatchPolicy::InflightTracker::Heartbeat
#tick_admission_budget DispatchPolicy::Config
#tick_admission_budget DispatchPolicy::Policy
#tick_admission_budget DispatchPolicy::PolicyDSL
#tick_max_duration DispatchPolicy::Config
tick_samples_buckets DispatchPolicy::Repository
tick_summary DispatchPolicy::Repository
#to_h DispatchPolicy::Context
#to_jsonb DispatchPolicy::Context
#to_policy DispatchPolicy::PolicyDSL
track DispatchPolicy::InflightTracker
trend_direction DispatchPolicy::Repository
#true? DispatchPolicy::InflightTracker::ThreadSafeFlag
unlimited DispatchPolicy::Decision
upsert_partition! DispatchPolicy::Repository
warn_unsupported_adapter DispatchPolicy
with DispatchPolicy::Bypass
with_connection DispatchPolicy::Repository
wrap DispatchPolicy::Context