Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/qpid-proton
/ functions
Functions
8,826 in github.com/apache/qpid-proton
⨍
Functions
8,826
◇
Types & classes
1,881
↓ 18 callers
Method
total
tests/include/catch.hpp:15275
↓ 17 callers
Method
GoString
GoString for Map prints values with their types, useful for debugging.
go/pkg/amqp/types.go:136
↓ 17 callers
Function
Marshal
* 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 callers
Method
connect
(addr)
python/proton/_io.py:60
↓ 17 callers
Method
create_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 callers
Method
next
@deprecated use {Session#each_link, Connection#each_link}
ruby/lib/core/link.rb:225
↓ 17 callers
Function
pn_buffer_append
c/src/core/buffer.c:142
↓ 17 callers
Function
pn_data_fill
c/src/core/codec.c:815
↓ 17 callers
Function
pn_encoder_writef8
c/src/core/encoder.c:152
↓ 17 callers
Function
pn_event_class
c/src/core/event.c:295
↓ 17 callers
Function
pn_event_type_name
c/src/core/event.c:314
↓ 17 callers
Function
pn_finspect
c/src/core/object/object.c:397
↓ 17 callers
Function
pn_i_error_from_errno
c/src/platform/platform.c:103
↓ 17 callers
Function
pn_listener_close
c/src/proactor/epoll.c:1697
↓ 17 callers
Method
rewind
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 callers
Method
schedule
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 callers
Function
ssl_log_error
c/src/tls/openssl.c:527
↓ 16 callers
Method
Connection
Connection is the connection associated with this endpoint.
go/pkg/electron/endpoint.go:56
↓ 16 callers
Method
HandleMessagingEvent
HandleMessagingEvent is called with MessagingEvent. Typically HandleEvent() is implemented as a switch on e.Type()
go/pkg/proton/handlers.go:40
↓ 16 callers
Method
Receive
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 callers
Method
Type
Human readable endpoint type "sender-link", "session" etc.
go/pkg/proton/wrappers.go:191
↓ 16 callers
Method
__repr__
(self)
python/proton/_data.py:121
↓ 16 callers
Method
add
(self, selectable: 'Selectable')
python/proton/_io.py:87
↓ 16 callers
Method
append
cpp/src/data.cpp:57
↓ 16 callers
Function
byte_copy
cpp/src/types_internal.hpp:34
↓ 16 callers
Method
clone
tests/include/catch.hpp:6720
↓ 16 callers
Method
close_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 callers
Function
doPanic
(data *C.pn_data_t, v interface{})
go/pkg/amqp/unmarshal.go:66
↓ 16 callers
Method
id
cpp/src/message.cpp:124
↓ 16 callers
Function
iocp_log
c/src/reactor/io/windows/iocp.c:73
↓ 16 callers
Function
list
tests/include/catch.hpp:11386
↓ 16 callers
Function
pn_class_decref
c/src/core/object/object.c:199
↓ 16 callers
Function
pn_collector_put
c/src/core/event.c:137
↓ 16 callers
Function
pn_connection_get_context
c/src/core/engine.c:204
↓ 16 callers
Function
pn_data_next
c/src/core/codec.c:1338
↓ 16 callers
Function
pn_data_put_int
c/src/core/codec.c:1702
↓ 16 callers
Function
pn_delivery_remote_state
c/src/core/engine.c:2208
↓ 16 callers
Function
pn_link_remote_condition
c/src/core/engine.c:2314
↓ 16 callers
Function
pn_list_remove
c/src/core/object/list.c:98
↓ 16 callers
Function
pn_proactor_wait
c/src/proactor/epoll.c:2739
↓ 16 callers
Function
pn_raw_connection_read_buffers_capacity
c/src/proactor/raw_connection.c:267
↓ 16 callers
Function
pn_raw_connection_write_buffers_capacity
c/src/proactor/raw_connection.c:273
↓ 16 callers
Function
pn_sasl
c/src/sasl/sasl.c:761
↓ 16 callers
Function
pn_ssl_domain_set_peer_authentication
c/src/ssl/openssl.c:865
↓ 16 callers
Function
pni_events_update
c/src/reactor/io/windows/selector.c:315
↓ 16 callers
Function
pnx_sasl_get_context
c/src/sasl/sasl.c:69
↓ 16 callers
Method
protocol_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 callers
Method
replace
Replace the data in this Terminus with the contents of +other+ @param other [Terminus] The other instance.
ruby/lib/core/terminus.rb:210
↓ 16 callers
Method
respond_to?
(name, all=false)
ruby/lib/handler/adapter.rb:50
↓ 16 callers
Method
send
@!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 callers
Function
startsWith
tests/include/catch.hpp:13821
↓ 15 callers
Function
NewMessageWith
NewMessageWith creates a message with value as the body.
go/pkg/amqp/message.go:195
↓ 15 callers
Method
String
Human-readable string showing message contents and properties
go/pkg/amqp/message.go:184
↓ 15 callers
Method
bool
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 callers
Function
emit_accumulated_nulls
c/src/core/emitters.h:180
↓ 15 callers
Function
err
cpp/src/connect_config.cpp:64
↓ 15 callers
Method
error
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 callers
Function
newPipe
AMQP pair linked by in-memory pipe
go/pkg/electron/common_test.go:74
↓ 15 callers
Function
pn_compare
c/src/core/object/object.c:356
↓ 15 callers
Function
pn_connection_driver_next_event
c/src/core/connection_driver.c:142
↓ 15 callers
Function
pn_connection_set_container
c/src/core/engine.c:615
↓ 15 callers
Function
pn_data_put_string
c/src/core/codec.c:1810
↓ 15 callers
Function
pn_delivery_readable
c/src/core/engine.c:2245
↓ 15 callers
Function
pn_logger_logf
c/src/core/logger.c:286
↓ 15 callers
Function
pn_message_decode
c/src/core/message.c:731
↓ 15 callers
Function
pn_message_error
c/src/core/message.c:441
↓ 15 callers
Function
pn_record_def
c/src/core/object/record.c:94
↓ 15 callers
Function
pn_terminus_get_address
c/src/core/engine.c:1373
↓ 15 callers
Function
pn_tls_take_encrypt_output_buffers
c/src/tls/openssl.c:1801
↓ 15 callers
Function
pni_parse_addr
c/src/proactor/proactor-internal.c:45
↓ 15 callers
Function
pni_raw_new_state
c/src/proactor/raw_connection.c:100
↓ 15 callers
Function
pni_win32_error
c/src/reactor/io/windows/io.c:48
↓ 15 callers
Method
run
cpp/src/reconnect_test.cpp:201
↓ 15 callers
Method
send
Thread safe
cpp/examples/multithreaded_client.cpp:74
↓ 15 callers
Function
trim
tests/include/catch.hpp:13844
↓ 15 callers
Method
user_data
cpp/src/link.cpp:99
↓ 14 callers
Function
LOG
c/tools/msgr-common.c:167
↓ 14 callers
Method
allowed_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 callers
Method
connection
(self)
python/tests/proton_tests/engine.py:51
↓ 14 callers
Method
create_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 callers
Method
dynamic
cpp/src/terminus.cpp:47
↓ 14 callers
Function
ensureCanTestExtendedSASL
()
python/tests/proton_tests/common.py:148
↓ 14 callers
Method
free
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 callers
Method
indent
tests/include/catch.hpp:8628
↓ 14 callers
Function
inspect
c/tests/pn_test.cpp:62
↓ 14 callers
Function
pn_collector
c/src/core/event.c:112
↓ 14 callers
Function
pn_condition_copy
c/src/core/engine.c:2514
↓ 14 callers
Function
pn_connection_attachments
c/src/core/engine.c:198
↓ 14 callers
Function
pn_connection_driver_destroy
c/src/core/connection_driver.c:82
↓ 14 callers
Function
pn_connection_state
c/src/core/engine.c:604
↓ 14 callers
Function
pn_hash_head
c/src/core/object/map.c:437
↓ 14 callers
Function
pn_hashcode
c/src/core/object/object.c:343
↓ 14 callers
Function
pn_i_now
c/src/platform/platform.c:60
↓ 14 callers
Function
pn_proactor
c/src/proactor/epoll.c:1982
↓ 14 callers
Function
pn_session_remote_condition
c/src/core/engine.c:2302
↓ 14 callers
Function
pn_session_remote_incoming_window
c/src/core/engine.c:1168
↓ 14 callers
Function
pn_ssl_domain
c/src/ssl/openssl.c:596
↓ 14 callers
Function
pn_streq
c/src/messenger/messenger.c:365
↓ 14 callers
Function
pn_transport_pending
output
c/src/core/transport.c:3009
↓ 14 callers
Function
pni_raw_write
c/src/proactor/raw_connection.c:569
← previous
next →
301–400 of 8,826, ranked by callers