Searched refs:msg_rates (Results 1 – 5 of 5) sorted by relevance
| /dports/net/rabbitmq/rabbitmq-server-3.9.11/deps/rabbit/src/ |
| H A D | rabbit_priority_queue.erl | 35 handle_pre_hibernate/1, resume/1, msg_rates/1,
407 msg_rates(#state{bq = BQ, bqss = BQSs}) -> function
409 {In, Out} = BQ:msg_rates(BQSN),
412 msg_rates(#passthrough{bq = BQ, bqs = BQS}) -> function
413 BQ:msg_rates(BQS).
|
| H A D | rabbit_backing_queue.erl | 236 -callback msg_rates(state()) -> {float(), float()}.
|
| H A D | rabbit_mirror_queue_master.erl | 17 msg_rates/1, info/2, invoke/3, is_duplicate/2, set_queue_mode/2,
422 msg_rates(#state { backing_queue = BQ, backing_queue_state = BQS }) -> function
423 BQ:msg_rates(BQS).
|
| H A D | rabbit_variable_queue.erl | 18 handle_pre_hibernate/1, resume/1, msg_rates/1,
916 msg_rates(#vqstate { rates = #rates { in = AvgIngressRate, function
|
| H A D | rabbit_amqqueue_process.erl | 1241 case BQ:msg_rates(BQS) of
|