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: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()

decrypted_sasl() = none | anon | external | {plain, User::binary(), Pwd::binary()}

encrypted_sasl()

encrypted_sasl() = {plaintext, binary()} | {encrypted, binary()}

milliseconds()

milliseconds() = non_neg_integer()

sasl()

sasl() = encrypted_sasl() | decrypted_sasl()

Function Index

begin_session/1
callback_mode/0
close/2
close_sent/3
code_change/4
expecting_socket/3
format_status/1
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()

format_status/1

format_status(Context) -> any()

hdr_sent/3

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

heartbeat/1

heartbeat(Pid) -> any()

init/1

init(X1) -> any()

open/1

open(Config0::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