Module rabbit_heartbeat

Data Types

heartbeat_callback()

heartbeat_callback() = fun(() -> any())

heartbeat_timeout()

heartbeat_timeout() = non_neg_integer()

heartbeaters()

heartbeaters() = {rabbit_types:maybe(pid()), rabbit_types:maybe(pid())}

Function Index

pause_monitor/1
resume_monitor/1
start/6
start/7
start_heartbeat_receiver/4
start_heartbeat_sender/4
system_code_change/4
system_continue/3
system_terminate/4

Function Details

pause_monitor/1

pause_monitor(X1::heartbeaters()) -> ok

resume_monitor/1

resume_monitor(X1::heartbeaters()) -> ok

start/6

start(SupPid::pid(), Sock::rabbit_net:socket(), SendTimeoutSec::heartbeat_timeout(), SendFun::heartbeat_callback(), ReceiveTimeoutSec::heartbeat_timeout(), ReceiveFun::heartbeat_callback()) -> heartbeaters()

start/7

start(SupPid::pid(), Sock::rabbit_net:socket(), Identity::rabbit_types:proc_name(), SendTimeoutSec::heartbeat_timeout(), SendFun::heartbeat_callback(), ReceiveTimeoutSec::heartbeat_timeout(), ReceiveFun::heartbeat_callback()) -> heartbeaters()

start_heartbeat_receiver/4

start_heartbeat_receiver(Sock::rabbit_net:socket(), TimeoutSec::heartbeat_timeout(), ReceiveFun::heartbeat_callback(), Identity::rabbit_types:proc_type_and_name()) -> rabbit_types:ok(pid())

start_heartbeat_sender/4

start_heartbeat_sender(Sock::rabbit_net:socket(), TimeoutSec::heartbeat_timeout(), SendFun::heartbeat_callback(), Identity::rabbit_types:proc_type_and_name()) -> rabbit_types:ok(pid())

system_code_change/4

system_code_change(Misc::term(), Module::term(), OldVsn::term(), Extra::term()) -> {ok, term()}

system_continue/3

system_continue(Parent::term(), Deb::term(), X3::{term(), term()}) -> any()

system_terminate/4

system_terminate(Reason::term(), Parent::term(), Deb::term(), State::term()) -> no_return()


Generated by EDoc