Module yz_solrq_helper

Data Types

bkey()

bkey() = {bucket(), key()}

bucket()

bucket() = binary() | {Type::binary(), Name::binary()}

hash()

hash() = binary()

index_name()

index_name() = binary()

key()

key() = binary()

n()

n() = pos_integer()

obj()

obj() = riak_object:riak_object()

object_pair()

object_pair() = {obj(), obj() | no_old_object}

p()

p() = non_neg_integer()

repair()

repair() = full_repair | tree_repair | failed_repair

short_preflist()

short_preflist() = {p(), n()}

solr_entries()

solr_entries() = [solr_entry()]

solr_entry()

solr_entry() = {bkey(), object_pair(), write_reason(), p(), short_preflist(), hash()}

solrq_helper_id()

solrq_helper_id() = pid() | atom()

solrq_id()

solrq_id() = pid() | atom()

write_reason()

write_reason() = delete | handoff | put | anti_entropy | {delete, repair()} | {anti_entropy, repair()} | {anti_entropy_delete, repair()} | anti_entropy_delete

Function Index

code_change/3
handle_call/3
handle_cast/2
handle_info/2
index_batch/5Index a batch.
init/1
start_link/2
status/1
status/2
terminate/2

Function Details

code_change/3

code_change(OldVsn, State, Extra) -> any()

handle_call/3

handle_call(BadMsg, From, State) -> any()

handle_cast/2

handle_cast(X1, State) -> any()

handle_info/2

handle_info(Msg, State) -> any()

index_batch/5

index_batch(HPid::solrq_helper_id(), Index::index_name(), BatchMax::non_neg_integer(), QPid::solrq_id(), Entries::solr_entries()) -> ok

Index a batch

init/1

init(X1) -> any()

start_link/2

start_link(Index, Partition) -> any()

status/1

status(Pid) -> any()

status/2

status(Pid, Timeout) -> any()

terminate/2

terminate(Reason, State) -> any()


Generated by EDoc