MCPcopy Create free account

hub / github.com/apache/qpid-proton / functions

Functions8,826 in github.com/apache/qpid-proton

↓ 18 callersMethodtotal
tests/include/catch.hpp:15275
↓ 17 callersMethodGoString
GoString for Map prints values with their types, useful for debugging.
go/pkg/amqp/types.go:136
↓ 17 callersFunctionMarshal
* Marshal encodes a Go value as AMQP data in buffer. If buffer is nil, or is not large enough, a new buffer is created. Returns the buffer used for
go/pkg/amqp/marshal.go:107
↓ 17 callersMethodconnect
(addr)
python/proton/_io.py:60
↓ 17 callersMethodcreate_sender
Initiates the establishment of a link over which messages can be sent. There are two patterns of use: 1. A connect
python/proton/_reactor.py:1425
↓ 17 callersMethodnext
@deprecated use {Session#each_link, Connection#each_link}
ruby/lib/core/link.rb:225
↓ 17 callersFunctionpn_buffer_append
c/src/core/buffer.c:142
↓ 17 callersFunctionpn_data_fill
c/src/core/codec.c:815
↓ 17 callersFunctionpn_encoder_writef8
c/src/core/encoder.c:152
↓ 17 callersFunctionpn_event_class
c/src/core/event.c:295
↓ 17 callersFunctionpn_event_type_name
c/src/core/event.c:314
↓ 17 callersFunctionpn_finspect
c/src/core/object/object.c:397
↓ 17 callersFunctionpn_i_error_from_errno
c/src/platform/platform.c:103
↓ 17 callersFunctionpn_listener_close
c/src/proactor/epoll.c:1697
↓ 17 callersMethodrewind
Clears current node and sets the parent to the root node. Clearing the current node sets it _before_ the first node, calling next()
python/proton/_data.py:707
↓ 17 callersMethodschedule
Schedule a task to run on this container after a given delay, and using the supplied handler. :param delay: :param h
python/proton/_reactor.py:289
↓ 17 callersFunctionssl_log_error
c/src/tls/openssl.c:527
↓ 16 callersMethodConnection
Connection is the connection associated with this endpoint.
go/pkg/electron/endpoint.go:56
↓ 16 callersMethodHandleMessagingEvent
HandleMessagingEvent is called with MessagingEvent. Typically HandleEvent() is implemented as a switch on e.Type()
go/pkg/proton/handlers.go:40
↓ 16 callersMethodReceive
Receive blocks until a message is available or until the Receiver is closed and has no more buffered messages.
go/pkg/electron/receiver.go:37
↓ 16 callersMethodType
Human readable endpoint type "sender-link", "session" etc.
go/pkg/proton/wrappers.go:191
↓ 16 callersMethod__repr__
(self)
python/proton/_data.py:121
↓ 16 callersMethodadd
(self, selectable: 'Selectable')
python/proton/_io.py:87
↓ 16 callersMethodappend
cpp/src/data.cpp:57
↓ 16 callersFunctionbyte_copy
cpp/src/types_internal.hpp:34
↓ 16 callersMethodclone
tests/include/catch.hpp:6720
↓ 16 callersMethodclose_tail
Indicate that the input has reached End Of Stream (EOS). This tells the transport that no more input will be forthcoming. :
python/proton/_transport.py:306
↓ 16 callersFunctiondoPanic
(data *C.pn_data_t, v interface{})
go/pkg/amqp/unmarshal.go:66
↓ 16 callersMethodid
cpp/src/message.cpp:124
↓ 16 callersFunctioniocp_log
c/src/reactor/io/windows/iocp.c:73
↓ 16 callersFunctionlist
tests/include/catch.hpp:11386
↓ 16 callersFunctionpn_class_decref
c/src/core/object/object.c:199
↓ 16 callersFunctionpn_collector_put
c/src/core/event.c:137
↓ 16 callersFunctionpn_connection_get_context
c/src/core/engine.c:204
↓ 16 callersFunctionpn_data_next
c/src/core/codec.c:1338
↓ 16 callersFunctionpn_data_put_int
c/src/core/codec.c:1702
↓ 16 callersFunctionpn_delivery_remote_state
c/src/core/engine.c:2208
↓ 16 callersFunctionpn_link_remote_condition
c/src/core/engine.c:2314
↓ 16 callersFunctionpn_list_remove
c/src/core/object/list.c:98
↓ 16 callersFunctionpn_proactor_wait
c/src/proactor/epoll.c:2739
↓ 16 callersFunctionpn_raw_connection_read_buffers_capacity
c/src/proactor/raw_connection.c:267
↓ 16 callersFunctionpn_raw_connection_write_buffers_capacity
c/src/proactor/raw_connection.c:273
↓ 16 callersFunctionpn_sasl
c/src/sasl/sasl.c:761
↓ 16 callersFunctionpn_ssl_domain_set_peer_authentication
c/src/ssl/openssl.c:865
↓ 16 callersFunctionpni_events_update
c/src/reactor/io/windows/selector.c:315
↓ 16 callersFunctionpnx_sasl_get_context
c/src/sasl/sasl.c:69
↓ 16 callersMethodprotocol_name
Get the name of the SSL protocol that is currently in use. Gets a text description of the SSL protocol that is currently active,
python/proton/_transport.py:897
↓ 16 callersMethodreplace
Replace the data in this Terminus with the contents of +other+ @param other [Terminus] The other instance.
ruby/lib/core/terminus.rb:210
↓ 16 callersMethodrespond_to?
(name, all=false)
ruby/lib/handler/adapter.rb:50
↓ 16 callersMethodsend
@!method send(message) Send a message. @param message [Message] The message to send. @return [Tracker] Tracks the outcome of the message.
ruby/lib/core/sender.rb:69
↓ 16 callersFunctionstartsWith
tests/include/catch.hpp:13821
↓ 15 callersFunctionNewMessageWith
NewMessageWith creates a message with value as the body.
go/pkg/amqp/message.go:195
↓ 15 callersMethodString
Human-readable string showing message contents and properties
go/pkg/amqp/message.go:184
↓ 15 callersMethodbool
If the current node is a boolean, then it returns the value. Otherwise, it returns false. @return [Boolean] The boolean value.
ruby/lib/codec/data.rb:265
↓ 15 callersFunctionemit_accumulated_nulls
c/src/core/emitters.h:180
↓ 15 callersFunctionerr
cpp/src/connect_config.cpp:64
↓ 15 callersMethoderror
Returns additional error information. Whenever a link operation fails (i.e., returns an error code) additional error details can be obtained from thi
ruby/lib/core/link.rb:220
↓ 15 callersFunctionnewPipe
AMQP pair linked by in-memory pipe
go/pkg/electron/common_test.go:74
↓ 15 callersFunctionpn_compare
c/src/core/object/object.c:356
↓ 15 callersFunctionpn_connection_driver_next_event
c/src/core/connection_driver.c:142
↓ 15 callersFunctionpn_connection_set_container
c/src/core/engine.c:615
↓ 15 callersFunctionpn_data_put_string
c/src/core/codec.c:1810
↓ 15 callersFunctionpn_delivery_readable
c/src/core/engine.c:2245
↓ 15 callersFunctionpn_logger_logf
c/src/core/logger.c:286
↓ 15 callersFunctionpn_message_decode
c/src/core/message.c:731
↓ 15 callersFunctionpn_message_error
c/src/core/message.c:441
↓ 15 callersFunctionpn_record_def
c/src/core/object/record.c:94
↓ 15 callersFunctionpn_terminus_get_address
c/src/core/engine.c:1373
↓ 15 callersFunctionpn_tls_take_encrypt_output_buffers
c/src/tls/openssl.c:1801
↓ 15 callersFunctionpni_parse_addr
c/src/proactor/proactor-internal.c:45
↓ 15 callersFunctionpni_raw_new_state
c/src/proactor/raw_connection.c:100
↓ 15 callersFunctionpni_win32_error
c/src/reactor/io/windows/io.c:48
↓ 15 callersMethodrun
cpp/src/reconnect_test.cpp:201
↓ 15 callersMethodsend
Thread safe
cpp/examples/multithreaded_client.cpp:74
↓ 15 callersFunctiontrim
tests/include/catch.hpp:13844
↓ 15 callersMethoduser_data
cpp/src/link.cpp:99
↓ 14 callersFunctionLOG
c/tools/msgr-common.c:167
↓ 14 callersMethodallowed_mechs
SASL mechanisms that are to be considered for authentication. This can be used on either the client or the server to restrict
python/proton/_transport.py:625
↓ 14 callersMethodconnection
(self)
python/tests/proton_tests/engine.py:51
↓ 14 callersMethodcreate_receiver
Initiates the establishment of a link over which messages can be received (aka a subscription). There are two patterns of us
python/proton/_reactor.py:1487
↓ 14 callersMethoddynamic
cpp/src/terminus.cpp:47
↓ 14 callersFunctionensureCanTestExtendedSASL
()
python/tests/proton_tests/common.py:148
↓ 14 callersMethodfree
Free this link object. When a link object is freed, all :class:`Delivery` objects associated with the session (**<-- CHECK THIS**)
python/proton/_endpoints.py:1101
↓ 14 callersMethodindent
tests/include/catch.hpp:8628
↓ 14 callersFunctioninspect
c/tests/pn_test.cpp:62
↓ 14 callersFunctionpn_collector
c/src/core/event.c:112
↓ 14 callersFunctionpn_condition_copy
c/src/core/engine.c:2514
↓ 14 callersFunctionpn_connection_attachments
c/src/core/engine.c:198
↓ 14 callersFunctionpn_connection_driver_destroy
c/src/core/connection_driver.c:82
↓ 14 callersFunctionpn_connection_state
c/src/core/engine.c:604
↓ 14 callersFunctionpn_hash_head
c/src/core/object/map.c:437
↓ 14 callersFunctionpn_hashcode
c/src/core/object/object.c:343
↓ 14 callersFunctionpn_i_now
c/src/platform/platform.c:60
↓ 14 callersFunctionpn_proactor
c/src/proactor/epoll.c:1982
↓ 14 callersFunctionpn_session_remote_condition
c/src/core/engine.c:2302
↓ 14 callersFunctionpn_session_remote_incoming_window
c/src/core/engine.c:1168
↓ 14 callersFunctionpn_ssl_domain
c/src/ssl/openssl.c:596
↓ 14 callersFunctionpn_streq
c/src/messenger/messenger.c:365
↓ 14 callersFunctionpn_transport_pending
output
c/src/core/transport.c:3009
↓ 14 callersFunctionpni_raw_write
c/src/proactor/raw_connection.c:569
← previousnext →301–400 of 8,826, ranked by callers