Method List

Classes Methods Files

Search:

active_policies DispatchPolicy::Tick
#admin_partition_limit DispatchPolicy::Config
autoload_job_for DispatchPolicy::Tick
#batch_size DispatchPolicy::Config
#build_dedupe_key DispatchPolicy::Policy
#build_round_robin_key DispatchPolicy::Policy
#build_snapshot DispatchPolicy::Policy
config DispatchPolicy
configure DispatchPolicy
#configure DispatchPolicy::Gate
#configure DispatchPolicy::Gates::Throttle
#configure DispatchPolicy::Gates::GlobalCap
#configure DispatchPolicy::Gates::Concurrency
#configure DispatchPolicy::Gates::FairInterleave
#configure DispatchPolicy::Gates::AdaptiveConcurrency
#consume DispatchPolicy::ThrottleBucket
consumed_ms_by_partition DispatchPolicy::PartitionObservation
#context DispatchPolicy::Policy
#context_builder DispatchPolicy::Policy
context_for DispatchPolicy::StagedJob
current_max_for DispatchPolicy::AdaptiveConcurrencyStats
decrement DispatchPolicy::PartitionInflightCount
#dedupe_key DispatchPolicy::Policy
#dedupe_key_builder DispatchPolicy::Policy
#deserialize DispatchPolicy::Dispatchable
#enabled DispatchPolicy::Config
enabled? DispatchPolicy
#enqueue DispatchPolicy::Dispatchable
#ewma_alpha DispatchPolicy::Gates::AdaptiveConcurrency
#fail_factor DispatchPolicy::Gates::AdaptiveConcurrency
fetch_batch DispatchPolicy::Tick
fetch_many DispatchPolicy::PartitionInflightCount
fetch_many DispatchPolicy::AdaptiveConcurrencyStats
fetch_plain_batch DispatchPolicy::Tick
fetch_round_robin_batch DispatchPolicy::Tick
fetch_time_weighted_batch DispatchPolicy::Tick
#filter DispatchPolicy::Gate
#filter DispatchPolicy::Gates::Throttle
#filter DispatchPolicy::Gates::GlobalCap
#filter DispatchPolicy::Gates::Concurrency
#filter DispatchPolicy::Gates::FairInterleave
#filter DispatchPolicy::Gates::AdaptiveConcurrency
#for DispatchPolicy::DispatchContext
#gate DispatchPolicy::Policy
#gates DispatchPolicy::Policy
increment DispatchPolicy::PartitionInflightCount
#index DispatchPolicy::PoliciesController
#initial_max DispatchPolicy::Gates::AdaptiveConcurrency
#initialize DispatchPolicy::Gate
#initialize DispatchPolicy::Policy
#initialize DispatchPolicy::DispatchContext
#instantiate_active_job DispatchPolicy::StagedJob
interruptible_sleep DispatchPolicy::TickLoop
#job_class DispatchPolicy::Policy
#lease_duration DispatchPolicy::Config
lock DispatchPolicy::ThrottleBucket
lookup_policy DispatchPolicy::Tick
#mark_admitted! DispatchPolicy::StagedJob
mark_completed_by_active_job_id DispatchPolicy::StagedJob
#min DispatchPolicy::Gates::AdaptiveConcurrency
#name DispatchPolicy::Gate
#name DispatchPolicy::Policy
observe! DispatchPolicy::PartitionObservation
#partition_by DispatchPolicy::Gate
#partition_idle_ttl DispatchPolicy::Config
#partition_key_for DispatchPolicy::Gate
#partitions_for DispatchPolicy::DispatchContext
#perform_all_later DispatchPolicy::ActiveJobPerformAllLaterPatch
#policy DispatchPolicy::Gate
#primary_partition_for DispatchPolicy::DispatchContext
prune! DispatchPolicy::PartitionObservation
prune_idle_partitions DispatchPolicy::Tick
prune_orphan_gate_rows DispatchPolicy::Tick
reap DispatchPolicy::Tick
#record_observation DispatchPolicy::Gates::AdaptiveConcurrency
record_observation! DispatchPolicy::AdaptiveConcurrencyStats
#record_partitions DispatchPolicy::DispatchContext
#refill! DispatchPolicy::ThrottleBucket
register DispatchPolicy::Gate
registry DispatchPolicy
registry DispatchPolicy::Gate
release DispatchPolicy::Tick
reset_registry! DispatchPolicy
revert_admission DispatchPolicy::Tick
#round_robin? DispatchPolicy::Policy
#round_robin_by DispatchPolicy::Policy
#round_robin_quantum DispatchPolicy::Config
#round_robin_weight DispatchPolicy::Policy
#round_robin_window DispatchPolicy::Policy
run DispatchPolicy::Tick
run DispatchPolicy::TickLoop
run_policy DispatchPolicy::Tick
seed! DispatchPolicy::AdaptiveConcurrencyStats
#serialize DispatchPolicy::Dispatchable
#show DispatchPolicy::PoliciesController
#slow_factor DispatchPolicy::Gates::AdaptiveConcurrency
#snapshot DispatchPolicy::Policy
#snapshots DispatchPolicy::Policy
stage! DispatchPolicy::StagedJob
stage_many! DispatchPolicy::StagedJob
#target_lag_ms DispatchPolicy::Gates::AdaptiveConcurrency
#tick_max_duration DispatchPolicy::Config
#tick_sleep DispatchPolicy::Config
#tick_sleep_busy DispatchPolicy::Config
total_for DispatchPolicy::PartitionInflightCount
#tracks_inflight? DispatchPolicy::Gate
#tracks_inflight? DispatchPolicy::Gates::Throttle
#tracks_inflight? DispatchPolicy::Gates::GlobalCap
#tracks_inflight? DispatchPolicy::Gates::Concurrency
#tracks_inflight? DispatchPolicy::Gates::AdaptiveConcurrency