| Overview |  |
Copyright © 2014 Irina Guberman
Version: 1.5.0 Apr 12 2015 21:06:46 ------------------------------------------------------------------------
Behaviours: cloudi_service.
Authors: Irina Guberman (irina.guberman@gmail.com).
CloudI layer on top of erlcql from https://github.com/rpt/erlcql.git
NOTE: set service config count_process to desired pool size
erlcql_client results will be wrapped in cloudi:send_sync result: {ok, ErlcqlClientResult}
As a result all successful responses from erlcql_client will be of the form {ok, {ok, Response}} All failures from erlcql_client will be of the form {ok, {error, Reason}}
send_sync errors will be standard 'CloudI' errorsagent() = cloudi:agent()
args() = [{service_name, ServiceName::service_name()} | {connection_options, ConnectionOptions::connection_options()} | {consistency, Consistency::consistency()}]
connection_options() = {connection_options, [{host, Host::string()} | {port, Port::integer()} | {username, Username::binary()} | {password, Password::binary()} | {use, Keyspace::binary()} | {prepare, [query_definition()]} | {keepalive, Value::boolean()} | {auto_reconnect, Value::boolean()} | {reconnect_start, Value::integer()} | {reconnect_max, Value::integer()} | {cql_version, CqlVersion::binary()} | {event_fun, EventFun::pid() | function()} | {events, Events::[event()]} | {compression, Compression::compression()} | {tracing, Tracing::boolean()} | {parent, Parent::pid()}]}
cql_name() = atom()
external_response() = {response(), NewAgent::agent()} | {{error, Reason::cloudi:error_reason_sync()}, NewAgent::agent()}
query() = binary() | string()
query_definition() = {QueryName::cql_name(), Query::query()}
service_name() = cloudi:service_name()
| cloudi_service_handle_info/3 | |
| cloudi_service_handle_request/11 | |
| cloudi_service_init/4 | |
| cloudi_service_terminate/3 | |
| execute_prepared_query/4 | |
| execute_prepared_query/5 | |
| execute_query/3 | |
| execute_query/4 |
cloudi_service_handle_info(Request, State, Dispatcher) -> any()
cloudi_service_handle_request(Type, Name, Pattern, RequestInfo, Request, Timeout, Priority, TransId, Pid, State, Dispatcher) -> any()
cloudi_service_init(Args, Prefix, Timeout, Dispatcher) -> any()
cloudi_service_terminate(Reason, Timeout, State) -> any()
execute_prepared_query(Agent::agent(), Name::service_name(), QueryName::cql_name(), Values::values()) -> external_response()
execute_prepared_query(Agent::agent(), Name::service_name(), QueryName::cql_name(), Values::values(), Consistency::consistency()) -> external_response()
execute_query(Agent::agent(), Name::service_name(), Query::query()) -> external_response()
execute_query(Agent::agent(), Name::service_name(), Query::query(), Consistency::consistency()) -> external_response()
Generated by EDoc, Apr 12 2015, 21:06:46.