Module amqp10_client_connection

Behaviours: gen_statem.

Data Types

address()

address() = inet:socket_address() | inet:hostname()

amqp10_socket()

amqp10_socket() = {tcp, gen_tcp:socket()} | {ssl, ssl:sslsocket()}

connection_config()

connection_config() = #{container_id => binary(), hostname => binary(), addresses => [address()], address => address(), port => inet:port_number(), tls_opts => {secure_port, [ssl:ssl_option()]}, notify => pid() | none, notify_when_opened => pid() | none, notify_when_closed => pid() | none, max_frame_size => non_neg_integer(), outgoing_max_frame_size => non_neg_integer() | undefined, idle_time_out => milliseconds(), transfer_limit_margin => 0 | neg_integer(), sasl => none | anon | {plain, User::binary(), Pwd::binary()}, notify => pid(), notify_when_opened => pid() | none, notify_when_closed => pid() | none}

milliseconds()

milliseconds() = non_neg_integer()

Function Index

begin_session/1
callback_mode/0
close/2
close_sent/3
code_change/4
expecting_socket/3
hdr_sent/3
heartbeat/1
init/1
open/1
open_sent/3
opened/3
protocol_header_received/5
sasl_hdr_rcvds/3
sasl_hdr_sent/3
sasl_init_sent/3
socket_ready/2
start_link/2
terminate/3

Function Details

begin_session/1

begin_session(Pid::pid()) -> supervisor:startchild_ret()

callback_mode/0

callback_mode() -> any()

close/2

close(Pid::pid(), Reason::{amqp10_client_types:amqp_error() | amqp10_client_types:connection_error(), binary()} | none) -> ok

close_sent/3

close_sent(EvtType, X2, State) -> any()

code_change/4

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

expecting_socket/3

expecting_socket(EvtType, X2, State) -> any()

hdr_sent/3

hdr_sent(EvtType, X2, State) -> any()

heartbeat/1

heartbeat(Pid) -> any()

init/1

init(X1) -> any()

open/1

open(Config::connection_config()) -> supervisor:startchild_ret()

open_sent/3

open_sent(EvtType, X2, State) -> any()

opened/3

opened(EvtType, Frame, State) -> any()

protocol_header_received/5

protocol_header_received(Pid::pid(), Protocol::0 | 3, Maj::non_neg_integer(), Min::non_neg_integer(), Rev::non_neg_integer()) -> ok

sasl_hdr_rcvds/3

sasl_hdr_rcvds(EvtType, X2, State) -> any()

sasl_hdr_sent/3

sasl_hdr_sent(EvtType, X2, State) -> any()

sasl_init_sent/3

sasl_init_sent(EvtType, X2, State) -> any()

socket_ready/2

socket_ready(Pid::pid(), Socket::amqp10_socket()) -> ok

start_link/2

start_link(Sup, Config) -> any()

terminate/3

terminate(Reason, StateName, State) -> any()


Generated by EDoc