| Overview |  |
bucket() = binary() | {Type::binary(), Name::binary()}
index_name() = binary()
key() = binary()
obj() = riak_object:riak_object()
object_pair() = {obj(), obj() | no_old_object}
p() = non_neg_integer()
purge_strategy() = off | purge_one | purge_index
regname() = atom()
repair() = full_repair | tree_repair | failed_repair
size_resps() = same_size | {shrank, non_neg_integer()} | {grew, non_neg_integer()}
solrq_batch_flush_interval() = non_neg_integer() | infinity
solrq_batch_max() = pos_integer()
solrq_batch_min() = pos_integer()
solrq_hwm() = non_neg_integer()
write_reason() = delete | handoff | put | anti_entropy | {delete, repair()} | {anti_entropy, repair()} | {anti_entropy_delete, repair()} | anti_entropy_delete
| all_solrq_workers/0 | |
| blown_fuse/1 | Signal to all Solrqs that a fuse has blown for the the specified index. |
| get_flush_interval/0 | |
| get_max_batch_size/0 | |
| get_min_batch_size/0 | |
| healed_fuse/1 | Signal to all Solrqs that a fuse has healed for the the specified index. |
| helper_regname/2 | From the hash, return the registered name of a helper. |
| index/5 | |
| queue_total_length/0 | return the total length of all solrq workers on the node. |
| reload_appenv/0 | Request each solrq reloads from appenv - currently only affects HWM. |
| set_hwm/1 | Set the high water mark on all queues. |
| set_index/4 | Set the index parameters for all queues (note, index goes back to appenv queue is empty). |
| set_purge_strategy/1 | Set the purge strategy on all queues. |
| solrq_worker_names/0 | Return the list of solrq names registered with this supervisor. |
| solrq_worker_pairs_for_index/1 | |
| solrq_workers_for_partition/1 | |
| status/0 | Return the status of all solrq workers. |
| worker_regname/2 | From the hash, return the registered name of a queue. |
all_solrq_workers() -> [atom()]
blown_fuse(Index::index_name()) -> ok
Signal to all Solrqs that a fuse has blown for the the specified index.
get_flush_interval() -> any()
get_max_batch_size() -> any()
get_min_batch_size() -> any()
healed_fuse(Index::index_name()) -> ok
Signal to all Solrqs that a fuse has healed for the the specified index.
helper_regname(Index::index_name(), Partition::p()) -> regname()
From the hash, return the registered name of a helper
index(Index::index_name(), BKey::bkey(), ObjectPair::object_pair(), Reason::write_reason(), P::p()) -> ok
queue_total_length() -> non_neg_integer()
return the total length of all solrq workers on the node.
reload_appenv() -> [{{index_name(), p()}, ok}]
Request each solrq reloads from appenv - currently only affects HWM
set_hwm(HWM::solrq_hwm()) -> [{{index_name(), p()}, {ok | error, solrq_hwm() | bad_hwm_value}}]
Set the high water mark on all queues
set_index(Index::index_name(), Min::solrq_batch_min(), Max::solrq_batch_max(), DelayMsMax::solrq_batch_flush_interval()) -> [{{index_name(), p()}, {ok | error, {Params::number()} | bad_index_params}}]
Set the index parameters for all queues (note, index goes back to appenv queue is empty).
set_purge_strategy(PurgeStrategy::purge_strategy()) -> [{{index_name(), p()}, {ok | error, purge_strategy() | bad_purge_strategy}}]
Set the purge strategy on all queues
solrq_worker_names() -> [atom()]
Return the list of solrq names registered with this supervisor
solrq_worker_pairs_for_index(Index::index_name()) -> [{index_name(), p()}]
solrq_workers_for_partition(Partition::p()) -> [atom()]
status() -> [{atom(), yz_solrq_worker:status()}]
Return the status of all solrq workers.
worker_regname(Index::index_name(), Partition::p()) -> regname()
From the hash, return the registered name of a queue
Generated by EDoc