amqp_error() = #amqp_error{name = rabbit_framing:amqp_exception(), explanation = string(), method = rabbit_framing:amqp_method_name()}
auth_user() = #auth_user{username = username(), tags = [atom()], impl = any()}
authz_context() = map()
authz_data() = #{peeraddr := inet:ip_address() | binary(), term() => term()} | undefined
basic_message() = #basic_message{exchange_name = rabbit_exchange:name(), routing_keys = [rabbit_router:routing_key()], content = content(), id = msg_id(), is_persistent = boolean()}
binding() = #binding{source = rabbit_exchange:name(), destination = binding_destination(), key = rabbit_binding:key(), args = rabbit_framing:amqp_table()}
binding_destination() = rabbit_amqqueue:name() | rabbit_exchange:name()
binding_source() = rabbit_exchange:name()
channel() = pid()
channel_exit() = no_return()
channel_name() = binary()
connection() = pid()
connection_exit() = no_return()
connection_name() = binary()
content() = undecoded_content() | decoded_content()
ctag() = binary()
decoded_content() = #content{class_id = rabbit_framing:amqp_class_id(), properties = rabbit_framing:amqp_property_record(), properties_bin = maybe(binary()), payload_fragments_rev = [binary()]}
delivery() = #delivery{mandatory = boolean(), sender = pid(), message = message()}
encoded_content() = #content{class_id = rabbit_framing:amqp_class_id(), properties = maybe(rabbit_framing:amqp_property_record()), properties_bin = binary(), payload_fragments_rev = [binary()]}
error(A, B) = {error, A, B}
error(A) = {error, A}
exchange() = #exchange{name = rabbit_exchange:name(), type = rabbit_exchange:type(), durable = boolean(), auto_delete = boolean(), arguments = rabbit_framing:amqp_table()}
info() = {info_key(), any()}
info_key() = atom()
info_keys() = [info_key()]
infos() = [info()]
listener() = #listener{node = node(), protocol = atom(), host = rabbit_net:hostname(), port = rabbit_net:ip_port()}
maybe(T) = T | none
message() = basic_message()
message_properties() = #message_properties{expiry = pos_integer() | undefined, needs_confirming = boolean()}
mfargs() = {atom(), atom(), [any()]}
msg_id() = rabbit_guid:guid()
node_type() = disc | ram
ok(A) = {ok, A}
ok_or_error(A) = ok | error(A)
ok_or_error2(A, B) = ok(A) | error(B)
ok_pid_or_error() = ok_or_error2(pid(), any())
password() = binary()
password_hash() = binary()
proc_name() = term()
proc_type_and_name() = {atom(), proc_name()}
protocol() = rabbit_framing:protocol()
protocol_name() = amqp0_8 | amqp0_9_1 | amqp1_0 | mqtt | stomp | any()
r2(VirtualHost, Kind) = r3(VirtualHost, Kind, rabbit_misc:resource_name())
r3(VirtualHost, Kind, Name) = #resource{virtual_host = VirtualHost, kind = Kind, name = Name}
timestamp() = {non_neg_integer(), non_neg_integer(), non_neg_integer()}
topic_access_context() = #{routing_key => rabbit_router:routing_key(), variable_map => map(), term() => term()}
tracked_channel() = #tracked_channel{id = tracked_channel_id(), node = node(), vhost = vhost(), name = channel_name(), pid = channel(), username = username(), connection = connection()}
tracked_channel_id() = {node(), channel_name()}
tracked_connection() = #tracked_connection{id = tracked_connection_id(), node = node(), vhost = vhost(), name = connection_name(), pid = connection(), protocol = protocol_name(), peer_host = rabbit_networking:hostname(), peer_port = rabbit_networking:ip_port(), username = username(), connected_at = integer()}
tracked_connection_id() = {node(), connection_name()}
undecoded_content() = #content{class_id = rabbit_framing:amqp_class_id(), properties = none, properties_bin = binary(), payload_fragments_rev = [binary()]} | #content{class_id = rabbit_framing:amqp_class_id(), properties = rabbit_framing:amqp_property_record(), properties_bin = none, payload_fragments_rev = [binary()]}
unencoded_content() = undecoded_content()
user() = #user{username = username(), tags = [atom()], authz_backends = [{atom(), any()}]}
username() = binary()
vhost() = vhost:name()
Generated by EDoc