| Overview |  |
Behaviours: gen_server.
index_name() = binary()
stat_name() = list()
| batch_end/1 | Send stat updates for a batch completion. |
| blocked_vnode/1 | Count of times the solrq had to block a vnode pass the vnode From into the function for redbugging, cannot see any value in overhead of doing stats by worker pool. |
| code_change/3 | |
| create_dynamic_stats/2 | Create dynamic stats for search index. |
| delete_dynamic_stats/2 | Delete dynamic stats for search index. |
| detected_repairs/1 | Send updates for aae repairs. |
| drain_cancel_timeout/0 | Send stat updates for a drain cancel timeout. |
| drain_end/1 | Send stat updates for a drain completion. |
| drain_fail/0 | Send stat updates for a drain failure. |
| drain_timeout/0 | Send stat updates for a drain timeout. |
| fuse_blown/1 | Update fuse recovered statistic. |
| fuse_recovered/1 | Update fuse recovered statistic. |
| get_stat/1 | Return the value for the stat with the given Name, or undefined if
not found. |
| get_stat/2 | |
| get_stats/0 | Return current aggregation of all stats. |
| handle_call/3 | |
| handle_cast/2 | |
| handle_info/2 | |
| hwm_purged/1 | update the the number of purges that have occurred. |
| index_bad_entry/0 | Send stat updates for an index failure. |
| index_end/3 | Send stat updates for an index completion. |
| index_extract_fail/0 | Send stat updates for an index failure. |
| index_fail/0 | Send stat updates for an index failure. |
| init/1 | |
| initialize_fuse_stats/1 | Initialize the Fuse stats subsystem for a given fuse. |
| perform_update/1 | Notify specific metrics in exometer based on the StatUpdate term
passed in. |
| queue_total_length/1 | update the total queue length to the specified value. |
| reset/0 | |
| search_end/1 | Send stat updates for search completion. |
| search_fail/0 | Send stat updates for a search failure. |
| start_link/0 | |
| stat_name/1 | |
| terminate/2 |
batch_end(ElapsedTime::integer()) -> ok
Send stat updates for a batch completion. ElapsedTime
should be microseconds.
blocked_vnode(From) -> any()
Count of times the solrq had to block a vnode pass the vnode From into the function for redbugging, cannot see any value in overhead of doing stats by worker pool
code_change(OldVsn, State, Extra) -> any()
create_dynamic_stats(Index::index_name(), Stats::[atom()]) -> [ok]
Create dynamic stats for search index.
delete_dynamic_stats(Index::index_name(), Stats::[atom()]) -> [ok]
Delete dynamic stats for search index.
detected_repairs(Count::integer()) -> ok
Send updates for aae repairs.
drain_cancel_timeout() -> ok
Send stat updates for a drain cancel timeout.
drain_end(ElapsedTime::integer()) -> ok
Send stat updates for a drain completion. ElapsedTime
should be microseconds.
drain_fail() -> ok
Send stat updates for a drain failure.
drain_timeout() -> ok
Send stat updates for a drain timeout.
fuse_blown(Index::index_name()) -> ok
Update fuse recovered statistic.
fuse_recovered(Index::index_name()) -> ok
Update fuse recovered statistic.
get_stat(Name::[atom(), ...]) -> undefined | term()
Return the value for the stat with the given Name, or undefined if
not found.
get_stat(Name, SummaryName) -> any()
get_stats() -> proplists:proplist() | {error, Reason::term()}
Return current aggregation of all stats.
handle_call(Req, From, State) -> any()
handle_cast(Req, State) -> any()
handle_info(Info, State) -> any()
hwm_purged(NumPurged::non_neg_integer()) -> ok
update the the number of purges that have occurred
index_bad_entry() -> ok
Send stat updates for an index failure.
index_end(Index::index_name(), BatchSize::integer(), ElapsedTime::integer()) -> ok
Send stat updates for an index completion. ElapsedTime
should be microseconds.
index_extract_fail() -> ok
Send stat updates for an index failure.
index_fail() -> ok
Send stat updates for an index failure.
init(X1) -> any()
initialize_fuse_stats(Name::atom()) -> ok
Initialize the Fuse stats subsystem for a given fuse.
perform_update(StatUpdate::term()) -> ok
Notify specific metrics in exometer based on the StatUpdate term
passed in.
queue_total_length(Length::non_neg_integer()) -> ok
update the total queue length to the specified value
reset() -> [{stat_name(), ok | {error, any()}}]
search_end(ElapsedTime::integer()) -> ok
Send stat updates for search completion. ElapsedTime should
be microseconds.
search_fail() -> ok
Send stat updates for a search failure.
start_link() -> any()
stat_name(Name::riak_core_stat_q:path()) -> riak_core_stat_q:stat_name()
terminate(Reason, State) -> any()
Generated by EDoc