Module amqp10_client_types

Data Types

amqp10_event()

amqp10_event() = {amqp10_event, amqp10_event_detail()}

amqp10_event_detail()

amqp10_event_detail() = {connection, pid(), connection_event_detail()} | {session, pid(), session_event_detail()} | {link, {sender | receiver, Name::binary()}, link_event_detail()}

amqp10_msg_record()

amqp10_msg_record() = #'v1_0.transfer'{} | #'v1_0.header'{} | #'v1_0.delivery_annotations'{} | #'v1_0.message_annotations'{} | #'v1_0.properties'{} | #'v1_0.application_properties'{} | #'v1_0.data'{} | #'v1_0.amqp_sequence'{} | #'v1_0.amqp_value'{} | #'v1_0.footer'{}

amqp10_performative()

amqp10_performative() = #'v1_0.open'{} | #'v1_0.begin'{} | #'v1_0.attach'{} | #'v1_0.flow'{} | #'v1_0.transfer'{} | #'v1_0.disposition'{} | #'v1_0.detach'{} | #'v1_0.end'{} | #'v1_0.close'{}

amqp_error()

amqp_error() = internal_error | not_found | unauthorized_access | decode_error | resource_limit_exceeded | not_allowed | invalid_field | not_implemented | resource_locked | precondition_failed | resource_deleted | illegal_state | frame_size_too_small

channel()

channel() = non_neg_integer()

connection_error()

connection_error() = connection_forced | framing_error | redirect

connection_event_detail()

connection_event_detail() = opened | {closed, Reason::any()} | {error, {connection_error(), any()}}

delivery_state()

delivery_state() = accepted | rejected | modified | {modified, DeliveryFailed::boolean(), UndeliverableHere::boolean(), MessageAnnotations::#{amqp10_msg:annotations_key() => term()}} | received | released

link_error()

link_error() = atom()

TODO

link_event_detail()

link_event_detail() = attached | detached | {error, {link_error(), any()}}

session_error()

session_error() = atom()

TODO

session_event_detail()

session_event_detail() = begun | ended | {error, {session_error(), any()}}

source()

source() = #'v1_0.source'{}

target()

target() = #'v1_0.target'{}

Function Index

uint/1
unpack/1
utf8/1

Function Details

uint/1

uint(N) -> any()

unpack/1

unpack(Value) -> any()

utf8/1

utf8(S) -> any()


Generated by EDoc