Module rabbit_core_metrics

Data Types

activity_status()

activity_status() = up | single_active | waiting | suspected_down

---------------------------------------------------------------------------- Specs ----------------------------------------------------------------------------

channel_stats_id()

channel_stats_id() = pid() | {pid(), {rabbit_amqqueue:name(), rabbit_exchange:name()}} | {pid(), rabbit_amqqueue:name()} | {pid(), rabbit_exchange:name()}

channel_stats_type()

channel_stats_type() = queue_exchange_stats | queue_stats | exchange_stats | reductions

Function Index

auth_attempt_failed/3
auth_attempt_succeeded/3
channel_closed/1
channel_created/2
channel_exchange_down/1
channel_queue_down/1
channel_queue_exchange_down/1
channel_stats/2
channel_stats/3
channel_stats/4
connection_closed/1
connection_created/2
connection_stats/2
connection_stats/4
consumer_created/9
consumer_deleted/3
consumer_updated/9
create_table/1
delete/2
gen_server2_deleted/1
gen_server2_stats/2
get_auth_attempts/0
get_auth_attempts_by_source/0
get_gen_server2_stats/1
init/0
node_node_stats/2
node_stats/2
queue_created/1
queue_declared/1
queue_deleted/1
queue_stats/2
queue_stats/5
queues_deleted/1
reset_auth_attempt_metrics/0
terminate/0

Function Details

auth_attempt_failed/3

auth_attempt_failed(RemoteAddress, Username, Protocol) -> any()

auth_attempt_succeeded/3

auth_attempt_succeeded(RemoteAddress, Username, Protocol) -> any()

channel_closed/1

channel_closed(Pid::pid()) -> ok

channel_created/2

channel_created(Pid::pid(), Infos::rabbit_types:infos()) -> ok

channel_exchange_down/1

channel_exchange_down(Id::{pid(), rabbit_exchange:name()}) -> ok

channel_queue_down/1

channel_queue_down(Id::{pid(), rabbit_amqqueue:name()}) -> ok

channel_queue_exchange_down/1

channel_queue_exchange_down(Id::{pid(), {rabbit_amqqueue:name(), rabbit_exchange:name()}}) -> ok

channel_stats/2

channel_stats(Pid::pid(), Infos::rabbit_types:infos()) -> ok

channel_stats/3

channel_stats(X1::channel_stats_type(), Id::channel_stats_id(), Value::rabbit_types:infos() | integer()) -> ok

channel_stats/4

channel_stats(X1, X2, Id, Value) -> any()

connection_closed/1

connection_closed(Pid::pid()) -> ok

connection_created/2

connection_created(Pid::pid(), Infos::rabbit_types:infos()) -> ok

connection_stats/2

connection_stats(Pid::pid(), Infos::rabbit_types:infos()) -> ok

connection_stats/4

connection_stats(Pid::pid(), Recv_oct::integer(), Send_oct::integer(), Reductions::integer()) -> ok

consumer_created/9

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/3

consumer_deleted(ChPid::pid(), ConsumerTag::binary(), QName::rabbit_amqqueue:name()) -> ok

consumer_updated/9

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/1

create_table(X1) -> any()

delete/2

delete(Table::atom(), Key::any()) -> ok

gen_server2_deleted/1

gen_server2_deleted(Pid::pid()) -> ok

gen_server2_stats/2

gen_server2_stats(Pid::pid(), BufferLength::integer()) -> ok

get_auth_attempts/0

get_auth_attempts() -> any()

get_auth_attempts_by_source/0

get_auth_attempts_by_source() -> any()

get_gen_server2_stats/1

get_gen_server2_stats(Pid::pid()) -> integer() | not_found

init/0

init() -> ok

node_node_stats/2

node_node_stats(Id::{node(), node()}, Infos::rabbit_types:infos()) -> ok

node_stats/2

node_stats(X1::atom(), Infos::rabbit_types:infos()) -> ok

queue_created/1

queue_created(Name) -> any()

queue_declared/1

queue_declared(Name) -> any()

queue_deleted/1

queue_deleted(Name) -> any()

queue_stats/2

queue_stats(Name::rabbit_amqqueue:name(), Infos::rabbit_types:infos()) -> ok

queue_stats/5

queue_stats(Name::rabbit_amqqueue:name(), MessagesReady::integer(), MessagesUnacknowledge::integer(), Messages::integer(), Reductions::integer()) -> ok

queues_deleted/1

queues_deleted(Queues) -> any()

reset_auth_attempt_metrics/0

reset_auth_attempt_metrics() -> any()

terminate/0

terminate() -> any()


Generated by EDoc