diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2010-07-19 14:11:48 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2010-07-19 14:11:48 +0100 |
| commit | b9019ea142d1e3e13f8e21388304cd7e85d8ac1b (patch) | |
| tree | a6a99071df2f27427791c9ed2324593243ab59b5 /include/rabbit.hrl | |
| parent | c4e94388e8b2c8f9544ea66e3e4c30b400e341ae (diff) | |
| download | rabbitmq-server-git-b9019ea142d1e3e13f8e21388304cd7e85d8ac1b.tar.gz | |
Emit events for connection and channel statistics and creation / deletion.
Diffstat (limited to 'include/rabbit.hrl')
| -rw-r--r-- | include/rabbit.hrl | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/include/rabbit.hrl b/include/rabbit.hrl index 1998de35b4..f400495ce3 100644 --- a/include/rabbit.hrl +++ b/include/rabbit.hrl @@ -70,10 +70,28 @@ -record(delivery, {mandatory, immediate, txn, sender, message}). -record(amqp_error, {name, explanation, method = none}). + +-record(event_connection_stats, {connection_pid, state, channels, + recv_oct, recv_cnt, + send_oct, send_cnt, send_pend}). + +-record(event_channel_stats, {channel_pid, per_exchange_statistics, + per_queue_statistics}). + -record(event_queue_stats, {qpid, messages_ready, messages_unacknowledged, consumers, memory, exclusive_consumer_pid, exclusive_consumer_tag, backing_queue_status}). +-record(event_connection_created, {connection_pid, address, port, + peer_address, peer_port, user, vhost, + timeout, frame_max, client_properties}). +-record(event_connection_closed, {connection_pid}). +-record(event_channel_created, {channel_pid, connection_pid, channel, user, + vhost}). +-record(event_channel_closed, {channel_pid}). + + + %%---------------------------------------------------------------------------- -define(COPYRIGHT_MESSAGE, "Copyright (C) 2007-2010 LShift Ltd., Cohesive Financial Technologies LLC., and Rabbit Technologies Ltd."). @@ -84,6 +102,7 @@ -define(HIBERNATE_AFTER_MIN, 1000). -define(DESIRED_HIBERNATE, 10000). +-define(STATISTICS_UPDATE_INTERVAL, 5000000). %% microseconds -ifdef(debug). -define(LOGDEBUG0(F), rabbit_log:debug(F)). |