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
↓ 14 callers
Method
sender
The sender link associated with the event, or ``None`` if none is associated with it. This is essentially an alias for ``link
python/proton/_events.py:567
↓ 14 callers
Function
unmarshal
Unmarshal from data into value pointed at by v. Returns v. NOTE: If you update this you also need to update getInterface()
go/pkg/amqp/unmarshal.go:291
↓ 14 callers
Method
update
(transport: Transport, selectable: Selectable, now: float)
python/proton/_handlers.py:1304
↓ 13 callers
Method
_test
(self, dtype, *values, **kwargs)
python/tests/proton_tests/codec.py:357
↓ 13 callers
Method
add_credit
cpp/src/receiver.cpp:61
↓ 13 callers
Method
decode
(self, data: bytes)
python/proton/_message.py:489
↓ 13 callers
Method
get_cert_fingerprint
Get the fingerprint of the certificate. The certificate fingerprint (as displayed in the Fingerprints section when looking at a certi
python/proton/_transport.py:1030
↓ 13 callers
Method
impl
Returns the underlying message implementation.
ruby/lib/core/message.rb:110
↓ 13 callers
Method
int
If the current node is an integer, returns its value. Otherwise, returns 0. @return [Integer] The integer value.
ruby/lib/codec/data.rb:370
↓ 13 callers
Function
iocp_log
c/src/proactor/win_iocp.cpp:538
↓ 13 callers
Method
mk_funcall
(name: str, args: List[str])
c/tools/codec-generator/generate.py:32
↓ 13 callers
Function
panicUnless
(ok bool, data *C.pn_data_t, v interface{})
go/pkg/amqp/unmarshal.go:83
↓ 13 callers
Function
pn_data_error
c/src/core/codec.c:416
↓ 13 callers
Function
pn_data_put_binary
c/src/core/codec.c:1801
↓ 13 callers
Function
pn_data_put_null
c/src/core/codec.c:1640
↓ 13 callers
Function
pn_equals
c/src/core/object/object.c:369
↓ 13 callers
Function
pn_error
c/src/core/error.c:42
↓ 13 callers
Function
pn_error_free
c/src/core/error.c:54
↓ 13 callers
Function
pn_event_raw_connection
c/src/proactor/raw_connection.c:847
↓ 13 callers
Function
pn_list_del
c/src/core/object/list.c:111
↓ 13 callers
Function
pn_proactor_set_timeout
c/src/proactor/epoll.c:2803
↓ 13 callers
Function
pn_raw_connection_write_buffers
c/src/proactor/raw_connection.c:347
↓ 13 callers
Function
pn_receiver
c/src/core/engine.c:1546
↓ 13 callers
Function
pn_record
c/src/core/object/record.c:63
↓ 13 callers
Function
pn_ssl_domain_free
c/src/ssl/openssl.c:609
↓ 13 callers
Function
pn_transport_set_max_frame
c/src/core/transport.c:2866
↓ 13 callers
Method
read
c/tests/pn_test.cpp:137
↓ 13 callers
Function
ssl_failed
unrecoverable SSL failure occured, notify transport and generate error code.
c/src/ssl/schannel.cpp:426
↓ 13 callers
Method
target
cpp/src/sender.cpp:59
↓ 13 callers
Method
to_s
@return [String] Convert to string
ruby/lib/core/url.rb:66
↓ 12 callers
Function
_sslConnection
(domain, transport, connection)
python/tests/proton_tests/sasl.py:379
↓ 12 callers
Method
_test
(self, name, default, values)
python/tests/proton_tests/message.py:40
↓ 12 callers
Method
assertRaises
(self, exception, function, *args, **kwargs)
python/tests/proton_tests/url.py:102
↓ 12 callers
Method
assertUrl
(self, u, scheme, username, password, host, port, path)
python/tests/proton_tests/url.py:32
↓ 12 callers
Method
cleanup
(self)
python/tests/proton_tests/engine.py:95
↓ 12 callers
Method
closed
Called in handler goroutine when endpoint is remotely closed.
go/pkg/electron/endpoint.go:78
↓ 12 callers
Method
getResultType
tests/include/catch.hpp:8325
↓ 12 callers
Method
link_count
cpp/src/connection_driver_test.cpp:172
↓ 12 callers
Method
listen
(self, container)
python/tests/proton_tests/reactor.py:670
↓ 12 callers
Function
pmutex_finalize
c/src/proactor/epoll-internal.h:342
↓ 12 callers
Function
pn_buffer_size
c/src/core/buffer.c:74
↓ 12 callers
Function
pn_collector_free
c/src/core/event.c:118
↓ 12 callers
Function
pn_collector_next
c/src/core/event.c:212
↓ 12 callers
Function
pn_condition_set_name
c/src/core/engine.c:2345
↓ 12 callers
Function
pn_connection_driver_init
c/src/core/connection_driver.c:51
↓ 12 callers
Function
pn_connection_wake
c/src/proactor/epoll.c:1488
↓ 12 callers
Function
pn_data_put_map
c/src/core/codec.c:1608
↓ 12 callers
Function
pn_delivery_update
c/src/core/engine.c:2230
↓ 12 callers
Function
pn_ep_decref
c/src/core/engine.c:466
↓ 12 callers
Function
pn_framing_send_amqp
c/src/core/framing.c:143
↓ 12 callers
Function
pn_listener
c/src/proactor/epoll.c:1526
↓ 12 callers
Function
pn_map_put
c/src/core/object/map.c:248
↓ 12 callers
Function
pn_modified
c/src/core/engine.c:820
↓ 12 callers
Function
pn_proactor_free
c/src/proactor/epoll.c:2026
↓ 12 callers
Function
pn_proactor_get
c/src/proactor/epoll.c:2743
↓ 12 callers
Function
pn_reactor_update
c/src/reactor/reactor.c:212
↓ 12 callers
Function
pn_session_close
c/src/core/engine.c:281
↓ 12 callers
Function
pn_transport_close_tail
input stream has closed
c/src/core/transport.c:3000
↓ 12 callers
Function
pn_transport_get_max_frame
c/src/core/transport.c:2861
↓ 12 callers
Function
pni_mem_subdeallocate
c/src/core/memory.c:253
↓ 12 callers
Method
rngSeed
tests/include/catch.hpp:10008
↓ 12 callers
Method
schedule
(see WorkQueue#schedule)
ruby/lib/core/container.rb:249
↓ 12 callers
Method
sender
Return a client sender and server receiver
go/pkg/electron/common_test.go:106
↓ 12 callers
Method
session
The session associated with the event, or ``None`` if none is associated with it.
python/proton/_events.py:551
↓ 12 callers
Method
session_head
Retrieve the first session from a given connection that matches the specified state mask. Examines the state of each session
python/proton/_endpoints.py:438
↓ 12 callers
Method
set
cpp/src/scalar_base.cpp:50
↓ 12 callers
Method
sleep
(t: float)
python/proton/_io.py:75
↓ 12 callers
Method
tick
Process any pending transport timer events (like heartbeat generation). This method should be called after all pending input has bee
python/proton/_transport.py:257
↓ 12 callers
Method
transport
@return [Transport, nil] transport for this event
ruby/lib/core/event.rb:109
↓ 12 callers
Method
update
(self, selectable: Selectable)
python/proton/_reactor.py:399
↓ 12 callers
Method
value
cpp/src/map.cpp:137
↓ 12 callers
Method
virtual_host
cpp/src/connection.cpp:70
↓ 12 callers
Function
wakeup
Call wih lock held
c/src/proactor/win_iocp.cpp:1862
↓ 11 callers
Method
Done
Done returns a channel that will close when the endpoint closes. After Done() has closed, Error() will return the reason for closing.
go/pkg/electron/endpoint.go:60
↓ 11 callers
Method
Inject
Inject a function into the engine goroutine. f() will be called in the same goroutine as event handlers, so it can safely use values belonging to eve
go/pkg/proton/engine.go:64
↓ 11 callers
Method
Open
Open an endpoint.
go/pkg/proton/wrappers.go:181
↓ 11 callers
Method
__init__
(self, p)
python/tests/proton_tests/reactor.py:200
↓ 11 callers
Method
_do_handshake
Attempt to connect client to server. Will throw a TransportException if the SSL handshake fails.
python/tests/proton_tests/ssl.py:84
↓ 11 callers
Function
check
cpp/src/message.cpp:119
↓ 11 callers
Function
checkDecodeInterface
checkDecodeValue: want is the expected value, decode into a reflect.Value
go/pkg/amqp/interop_test.go:163
↓ 11 callers
Method
execute
tests/include/catch.hpp:13348
↓ 11 callers
Method
extend
Add all elements of an iterable t to the end of the list
python/proton/_data.py:533
↓ 11 callers
Method
get
c/tests/pn_test.hpp:57
↓ 11 callers
Function
getReader
(t *testing.T, name string)
go/pkg/amqp/interop_test.go:39
↓ 11 callers
Function
handle
c/tests/threaderciser.c:407
↓ 11 callers
Function
iocpdesc_fail
c/src/proactor/win_iocp.cpp:573
↓ 11 callers
Method
name
tests/include/catch.hpp:10001
↓ 11 callers
Method
object
Gets the current node, based on how it was encoded. @return [Object] The current node.
ruby/lib/codec/data.rb:240
↓ 11 callers
Method
password
cpp/src/url.cpp:244
↓ 11 callers
Function
pn_code
c/src/core/error.c:126
↓ 11 callers
Function
pn_condition
c/src/core/engine.c:231
↓ 11 callers
Function
pn_condition_format
c/src/core/engine.c:2392
↓ 11 callers
Function
pn_condition_set_description
c/src/core/engine.c:2366
↓ 11 callers
Function
pn_data_free
c/src/core/codec.c:406
↓ 11 callers
Function
pn_fixed_string
c/src/core/fixed_string.h:45
↓ 11 callers
Function
pn_hash
c/src/core/object/map.c:409
↓ 11 callers
Function
pn_link_set_drain
c/src/core/engine.c:2134
↓ 11 callers
Function
pn_message_is_inferred
c/src/core/message.c:447
↓ 11 callers
Function
pn_proactor_listen
c/src/proactor/epoll.c:1543
↓ 11 callers
Function
pn_session_state
c/src/core/engine.c:1196
← previous
next →
401–500 of 8,826, ranked by callers