Behaviours: gen_statem
.
address() = inet:socket_address() | inet:hostname()
amqp10_socket() = {tcp, gen_tcp:socket()} | {ssl, ssl:sslsocket()}
connection_config() = #{container_id => binary(), hostname => binary(), addresses => [address()], address => address(), port => inet:port_number(), tls_opts => {secure_port, [ssl:tls_option()]}, notify => pid() | none, notify_when_opened => pid() | none, notify_when_closed => pid() | none, max_frame_size => pos_integer(), outgoing_max_frame_size => pos_integer() | undefined, idle_time_out => milliseconds(), transfer_limit_margin => 0 | neg_integer(), sasl => sasl(), properties => amqp10_client_types:properties()}
decrypted_sasl() = none | anon | external | {plain, User::binary(), Pwd::binary()}
encrypted_sasl() = {plaintext, binary()} | {encrypted, binary()}
milliseconds() = non_neg_integer()
sasl() = encrypted_sasl() | decrypted_sasl()
begin_session(Pid::pid()) -> supervisor:startchild_ret()
callback_mode() -> any()
close(Pid::pid(), Reason::{amqp10_client_types:amqp_error() | amqp10_client_types:connection_error(), binary()} | none) -> ok
close_sent(EvtType, X2, State) -> any()
code_change(OldVsn, StateName, State, Extra) -> any()
expecting_socket(EvtType, X2, State) -> any()
format_status(Context) -> any()
hdr_sent(EvtType, X2, State) -> any()
heartbeat(Pid) -> any()
init(X1) -> any()
open(Config0::connection_config()) -> supervisor:startchild_ret()
open_sent(EvtType, X2, State) -> any()
opened(EvtType, Frame, State) -> any()
protocol_header_received(Pid::pid(), Protocol::0 | 3, Maj::non_neg_integer(), Min::non_neg_integer(), Rev::non_neg_integer()) -> ok
sasl_hdr_rcvds(EvtType, X2, State) -> any()
sasl_hdr_sent(EvtType, X2, State) -> any()
sasl_init_sent(EvtType, X2, State) -> any()
socket_ready(Pid::pid(), Socket::amqp10_socket()) -> ok
start_link(Sup, Config) -> any()
terminate(Reason, StateName, State) -> any()
Generated by EDoc