activity_status() = up | single_active | waiting | suspected_down
---------------------------------------------------------------------------- Specs ----------------------------------------------------------------------------
channel_stats_id() = pid() | {pid(), {rabbit_amqqueue:name(), rabbit_exchange:name()}} | {pid(), rabbit_amqqueue:name()} | {pid(), rabbit_exchange:name()}
channel_stats_type() = queue_exchange_stats | queue_stats | exchange_stats | reductions
auth_attempt_failed(RemoteAddress, Username, Protocol) -> any()
auth_attempt_succeeded(RemoteAddress, Username, Protocol) -> any()
channel_closed(Pid::pid()) -> ok
channel_created(Pid::pid(), Infos::rabbit_types:infos()) -> ok
channel_exchange_down(Id::{pid(), rabbit_exchange:name()}) -> ok
channel_queue_down(Id::{pid(), rabbit_amqqueue:name()}) -> ok
channel_queue_exchange_down(Id::{pid(), {rabbit_amqqueue:name(), rabbit_exchange:name()}}) -> ok
channel_stats(Pid::pid(), Infos::rabbit_types:infos()) -> ok
channel_stats(X1::channel_stats_type(), Id::channel_stats_id(), Value::rabbit_types:infos() | integer()) -> ok
channel_stats(X1, X2, Id, Value) -> any()
connection_closed(Pid::pid()) -> ok
connection_created(Pid::pid(), Infos::rabbit_types:infos()) -> ok
connection_stats(Pid::pid(), Infos::rabbit_types:infos()) -> ok
connection_stats(Pid::pid(), Recv_oct::integer(), Send_oct::integer(), Reductions::integer()) -> ok
consumer_created(ChPid::pid(), ConsumerTag::binary(), ExclusiveConsume::boolean(), AckRequired::boolean(), QName::rabbit_amqqueue:name(), PrefetchCount::integer(), Active::boolean(), ActivityStatus::activity_status(), Args::list()) -> ok
consumer_deleted(ChPid::pid(), ConsumerTag::binary(), QName::rabbit_amqqueue:name()) -> ok
consumer_updated(ChPid::pid(), ConsumerTag::binary(), ExclusiveConsume::boolean(), AckRequired::boolean(), QName::rabbit_amqqueue:name(), PrefetchCount::integer(), Active::boolean(), ActivityStatus::activity_status(), Args::list()) -> ok
create_table(X1) -> any()
delete(Table::atom(), Key::any()) -> ok
gen_server2_deleted(Pid::pid()) -> ok
gen_server2_stats(Pid::pid(), BufferLength::integer()) -> ok
get_auth_attempts() -> any()
get_auth_attempts_by_source() -> any()
get_gen_server2_stats(Pid::pid()) -> integer() | not_found
init() -> ok
node_node_stats(Id::{node(), node()}, Infos::rabbit_types:infos()) -> ok
node_stats(X1::atom(), Infos::rabbit_types:infos()) -> ok
queue_created(Name) -> any()
queue_declared(Name) -> any()
queue_deleted(Name) -> any()
queue_stats(Name::rabbit_amqqueue:name(), Infos::rabbit_types:infos()) -> ok
queue_stats(Name::rabbit_amqqueue:name(), MessagesReady::integer(), MessagesUnacknowledge::integer(), Messages::integer(), Reductions::integer()) -> ok
queues_deleted(Queues) -> any()
reset_auth_attempt_metrics() -> any()
terminate() -> any()
Generated by EDoc