| Overview |  |
Behaviours: gen_fsm.
format() = {format, term()} | {format, io:format(), [term()]}
| code_change/4 | The gen_server code_change/3 callback, called when performing a hot code upgrade on the server. |
| connected/2 | |
| connected/3 | |
| handle_event/3 | The handle_event/3 gen_fsm callback. |
| handle_info/3 | The handle_info/3 gen_fsm callback. |
| handle_sync_event/4 | |
| init/1 | The gen_server init/1 callback, initializes the riak_api_pb_server. |
| service_registered/2 | Notifies the server process of a newly registered PB service. |
| set_socket/2 | Sets the socket to service for this server. |
| start_link/0 | Starts a PB server, ready to service a single socket. |
| terminate/3 | The gen_server terminate/2 callback, called when shutting down the server. |
| wait_for_auth/2 | |
| wait_for_auth/3 | |
| wait_for_socket/2 | |
| wait_for_socket/3 | |
| wait_for_tls/2 | |
| wait_for_tls/3 |
code_change(OldVsn, StateName, State, Extra) -> {ok, StateName, State}
OldVsn = Vsn | {down, Vsn}Vsn = term()StateName = atom()State = #state{transport = {gen_tcp, inet} | {ssl, ssl}, socket = port() | ssl:sslsocket(), req = any(), states = orddict:orddict(), peername = undefined | {inet:ip_address(), pos_integer()}, common_name = undefined | string(), security = any(), retries = any(), inbuffer = any(), outbuffer = riak_api_pb_frame:buffer()}Extra = term()
The gen_server code_change/3 callback, called when performing a hot code upgrade on the server. Currently unused.
connected(Event, State) -> any()
connected(Event, From, State) -> any()
handle_event(Msg, StateName, State) -> any()
The handle_event/3 gen_fsm callback.
handle_info(StreamMessage, SN, State) -> any()
The handle_info/3 gen_fsm callback.
handle_sync_event(Event, From, StateName, State) -> any()
init(X1::list()) -> {ok, wait_for_socket, #state{transport = {gen_tcp, inet} | {ssl, ssl}, socket = port() | ssl:sslsocket(), req = any(), states = orddict:orddict(), peername = undefined | {inet:ip_address(), pos_integer()}, common_name = undefined | string(), security = any(), retries = any(), inbuffer = any(), outbuffer = riak_api_pb_frame:buffer()}}
The gen_server init/1 callback, initializes the riak_api_pb_server.
service_registered(Pid::pid(), Mod::module()) -> ok
Notifies the server process of a newly registered PB service.
set_socket(Pid::pid(), Socket::port()) -> ok
Sets the socket to service for this server.
start_link() -> {ok, pid()} | {error, term()}
Starts a PB server, ready to service a single socket.
terminate(Reason, StateName, State) -> ok
Reason = normal | shutdown | {shutdown, term()} | term()StateName = atom()State = #state{transport = {gen_tcp, inet} | {ssl, ssl}, socket = port() | ssl:sslsocket(), req = any(), states = orddict:orddict(), peername = undefined | {inet:ip_address(), pos_integer()}, common_name = undefined | string(), security = any(), retries = any(), inbuffer = any(), outbuffer = riak_api_pb_frame:buffer()}
The gen_server terminate/2 callback, called when shutting down the server.
wait_for_auth(Event, State) -> any()
wait_for_auth(Event, From, State) -> any()
wait_for_socket(Event, State) -> any()
wait_for_socket(Event, From, State) -> any()
wait_for_tls(Event, State) -> any()
wait_for_tls(Event, From, State) -> any()
Generated by EDoc