| Overview |  |
bucket() = binary() | {Type::binary(), Name::binary()}
drain_info() = {pid(), Token::reference(), DrainFSMMonitor::reference()} | undefined
index_name() = binary()
key() = binary()
obj() = riak_object:riak_object()
object_pair() = {obj(), obj() | no_old_object}
p() = non_neg_integer()
pending_processes() = {pid(), atom()}
purge_strategy() = off | purge_one | purge_index
repair() = full_repair | tree_repair | failed_repair
solrq_batch_flush_interval() = non_neg_integer() | infinity
solrq_batch_max() = pos_integer()
solrq_batch_min() = pos_integer()
solrq_hwm() = non_neg_integer()
solrq_id() = pid() | atom()
solrq_message() = tuple()
{BKey, Docs, Reason, P}.
status() = [worker_state_status()]
timestamp() = erlang:timestamp()
worker_state_status() = {all_queue_len, non_neg_integer()} | {queue_hwm, non_neg_integer()} | {pending_processes, pending_processes()} | {drain_info, drain_info()} | {purge_strategy, purge_strategy() | {queue, yz_queue()} | {queue_len, non_neg_integer()} | {timer_ref, reference() | undefined} | {batch_min, solrq_batch_min()} | {batch_max, solrq_batch_max()} | {delayms_max, solrq_batch_flush_interval()} | {aux_queue, yz_queue()} | {draining, boolean() | wait_for_drain_complete} | {fuse_blown, boolean()} | {in_flight_len, non_neg_integer()} | {batch_start, timestamp() | undefined}}
write_reason() = delete | handoff | put | anti_entropy | {delete, repair()} | {anti_entropy, repair()} | {anti_entropy_delete, repair()} | anti_entropy_delete
yz_queue() = queue()
| all_queue_len/2 | return the sum of the length of all queues in each indexq. |
| batch_complete/2 | |
| blown_fuse/1 | Signal to the solrq that a fuse has blown for the the specified index. |
| cancel_drain/1 | |
| code_change/3 | |
| drain/2 | |
| drain_complete/1 | |
| get_hwm/1 | return the sum of the length of all queues in each indexq. |
| handle_call/3 | |
| handle_cast/2 | |
| handle_info/2 | Timer has fired - request a helper. |
| healed_fuse/1 | Signal to the solrq that a fuse has healed for the the specified index. |
| index/5 | |
| reload_appenv/2 | |
| set_hwm/3 | |
| set_index/5 | |
| set_purge_strategy/3 | |
| start_link/2 | |
| status/1 | |
| stop/2 | |
| terminate/2 |
all_queue_len(Index::index_name(), Partition::p()) -> non_neg_integer()
return the sum of the length of all queues in each indexq
batch_complete(QPid::solrq_id(), Message::{NumDelivered::non_neg_integer(), ok} | {NumDelivered::non_neg_integer(), {retry, [Undelivered::solrq_message()]}}) -> ok
blown_fuse(QPid::solrq_id()) -> ok
Signal to the solrq that a fuse has blown for the the specified index.
cancel_drain(QPid::solrq_id()) -> ok
code_change(OldVsn, State, Extra) -> any()
drain(QPid::solrq_id(), Partition::p() | undefined) -> reference()
drain_complete(QPid::solrq_id()) -> ok
get_hwm(QPid::solrq_id()) -> HWM::non_neg_integer()
return the sum of the length of all queues in each indexq
handle_call(X1, From, State0) -> any()
handle_cast(X1, State) -> any()
handle_info(X1, State) -> any()
Timer has fired - request a helper.
healed_fuse(QPid::solrq_id()) -> ok
Signal to the solrq that a fuse has healed for the the specified index.
index(QPid::solrq_id(), BKey::bkey(), Objects::object_pair(), Reason::write_reason(), P::p()) -> ok
reload_appenv(Index::index_name(), Partition::p()) -> ok
set_hwm(Index::index_name(), Partition::p(), HWM::solrq_hwm()) -> {ok, OldHWM::solrq_hwm()} | {error, bad_hwm_value}
set_index(Index::index_name(), Partition::p(), Min::solrq_batch_min(), Max::solrq_batch_max(), DelayMax::solrq_batch_flush_interval()) -> {ok, {solrq_batch_min(), solrq_batch_max(), solrq_batch_flush_interval()}}
set_purge_strategy(Index::index_name(), Partition::p(), PurgeStrategy::purge_strategy()) -> {ok, OldPurgeStrategy::purge_strategy()} | {error, bad_purge_strategy}
start_link(Index, Partition) -> any()
status(QPid::solrq_id()) -> status()
stop(Index::index_name(), Partition::p()) -> any()
terminate(Reason, State) -> any()
Generated by EDoc