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
↓ 4 callers
Function
User
User returns a ConnectionOption sets the user name for a connection
go/pkg/electron/connection.go:118
↓ 4 callers
Method
__init__
(self, u32: int)
python/proton/_data.py:197
↓ 4 callers
Method
__new__
:param value: integer port number or string service name.
python/proton/_url.py:70
↓ 4 callers
Method
__setitem__
Checks if the key is a :class:`symbol` type before setting the value
python/proton/_data.py:360
↓ 4 callers
Method
_check
(self, err: int)
python/proton/_transport.py:726
↓ 4 callers
Function
_check_is_symbol
(s: _T, raise_on_error: bool = True)
python/proton/_data.py:337
↓ 4 callers
Method
_flow
(self, link: Union['Sender', 'Receiver'])
python/proton/_handlers.py:1022
↓ 4 callers
Method
abort
Aborts the delivery. This indicates the application wishes to invalidate any data that may have already been sent on this delivery.
python/proton/_delivery.py:386
↓ 4 callers
Method
accept
Called in app goroutine to send an accept function to proton and return the resulting endpoint.
go/pkg/electron/endpoint.go:180
↓ 4 callers
Method
active
cpp/src/endpoint.cpp:43
↓ 4 callers
Method
add
tests/include/catch.hpp:11308
↓ 4 callers
Method
adjustString
tests/include/catch.hpp:11717
↓ 4 callers
Method
anonymous
cpp/src/terminus.cpp:51
↓ 4 callers
Function
app_inbytes_advance
c/src/ssl/schannel.cpp:1584
↓ 4 callers
Method
assertEqualTermini
(self, t1, t2)
python/tests/proton_tests/engine.py:646
↓ 4 callers
Function
assert_equalish
cpp/src/test_bits.hpp:49
↓ 4 callers
Method
assert_error
(self, name)
python/tests/proton_tests/transport.py:56
↓ 4 callers
Function
begin_accept
c/src/proactor/win_iocp.cpp:718
↓ 4 callers
Method
benchmarkNoAnalysis
tests/include/catch.hpp:10015
↓ 4 callers
Method
benchmarkSamples
tests/include/catch.hpp:10016
↓ 4 callers
Function
bin
cpp/src/types_internal.hpp:59
↓ 4 callers
Function
bothOrAll
tests/include/catch.hpp:15852
↓ 4 callers
Function
buf_unused
c/experimental/raw_plus_tls2.c:106
↓ 4 callers
Method
byte
If the current node is an byte, returns its value. Otherwise, it returns 0. @return [Integer] The byte value.
ruby/lib/codec/data.rb:299
↓ 4 callers
Function
bytes2string
(b, encoding='utf8')
python/cproton.py:203
↓ 4 callers
Function
cLen
(b []byte)
go/pkg/amqp/types.go:220
↓ 4 callers
Function
cPtr
(b []byte)
go/pkg/amqp/types.go:213
↓ 4 callers
Function
check_arg
cpp/examples/service_bus.cpp:112
↓ 4 callers
Function
check_array
c/tests/data_test.cpp:137
↓ 4 callers
Function
check_condition
c/tests/fuzz/fuzz-connection-driver.c:164
↓ 4 callers
Function
check_condition
c/tests/fuzz/fuzz-proactor-receive.c:73
↓ 4 callers
Function
check_condition
c/examples/send-abort.c:67
↓ 4 callers
Function
check_condition
c/examples/receive.c:51
↓ 4 callers
Function
check_condition
c/examples/send.c:49
↓ 4 callers
Function
check_condition
c/examples/send-ssl.c:51
↓ 4 callers
Method
clear
cpp/src/message.cpp:111
↓ 4 callers
Method
closed_write_count
c/tests/raw_connection_proactor_test.cpp:80
↓ 4 callers
Method
content_encoding
Returns the content encoding type.
ruby/lib/core/message.rb:394
↓ 4 callers
Method
content_type
cpp/src/message.cpp:182
↓ 4 callers
Function
convertInto
tests/include/catch.hpp:9072
↓ 4 callers
Method
count_objects
(self, message)
python/tests/integration/test_PROTON_2116_blocking_connection_object_leak.py:52
↓ 4 callers
Function
credit_topup
This must only be called for receiver links
cpp/src/messaging_adapter.cpp:57
↓ 4 callers
Method
current
Returns the current delivery. Each link maintains a sequence of deliveries in the order they were created, along with a reference to the *current* de
ruby/lib/core/link.rb:300
↓ 4 callers
Function
default_file
cpp/src/connect_config.cpp:258
↓ 4 callers
Function
delay_iter
iterator yielding the next delay in the sequence of delays. The first delay is 0 seconds, the second 0.1 seconds, and each subsequent cal
python/proton/_reactor.py:954
↓ 4 callers
Method
delivery
@deprecated use {Sender#send}
ruby/lib/core/link.rb:279
↓ 4 callers
Method
described?
()
ruby/lib/types/array.rb:34
↓ 4 callers
Function
dimColour
Colour::LightGrey
tests/include/catch.hpp:15850
↓ 4 callers
Method
dispatch
(self, consumer=None)
python/examples/broker.py:51
↓ 4 callers
Method
doLeak
(self, local, remote)
python/tests/proton_tests/engine.py:2677
↓ 4 callers
Function
doReceive
(rcv Receiver, results chan result)
go/pkg/electron/electron_test.go:165
↓ 4 callers
Function
do_complete
c/src/proactor/win_iocp.cpp:1804
↓ 4 callers
Method
do_request
(self)
python/examples/client_http.py:61
↓ 4 callers
Function
drain
c/tests/refcount_test.cpp:315
↓ 4 callers
Method
drain
cpp/src/receiver.cpp:69
↓ 4 callers
Function
drain_events_until_both
c/tests/raw_connection_test.cpp:280
↓ 4 callers
Method
dynamic_properties
cpp/src/terminus.cpp:64
↓ 4 callers
Method
each_link
Get the links on this Session. @overload each_link @yieldparam l [Link] pass each link to block @overload each_link @return [Enumerator] enumerator ov
ruby/lib/core/session.rb:132
↓ 4 callers
Method
each_sender
Get the {Sender} links - see {#each_link}
ruby/lib/core/session.rb:144
↓ 4 callers
Method
each_session
Get the sessions on this connection. @overload each_session @yieldparam s [Session] pass each session to block @overload each_session @return [Enumera
ruby/lib/core/connection.rb:229
↓ 4 callers
Function
emit_end_list
c/src/core/emitters.h:301
↓ 4 callers
Function
emit_list
c/src/core/emitters.h:266
↓ 4 callers
Function
enable_logging
c/tools/msgr-common.c:162
↓ 4 callers
Function
encode_succeeded
c/src/core/emitters.h:89
↓ 4 callers
Function
exampleArgs
(args ...string)
go/examples/example_test.go:153
↓ 4 callers
Function
exampleCommand
exampleCommand returns an exec.Cmd to run an example.
go/examples/example_test.go:111
↓ 4 callers
Method
expect
(events []EventType)
go/pkg/proton/proton_test.go:47
↓ 4 callers
Function
expect_char
(format: str, char: str)
c/tools/codec-generator/generate.py:256
↓ 4 callers
Method
expired
(self)
python/proton/_selectable.py:97
↓ 4 callers
Function
fatalIf
(err error)
go/examples/electron/selected_recv.go:106
↓ 4 callers
Method
fetch_instance
Retrieves the wrapper object with the supplied Proton struct. @param impl [Object] The wrapper for the Proton struct. @param attachment_method [Symbo
ruby/lib/util/wrapper.rb:87
↓ 4 callers
Function
field_kw
(field)
c/src/protocol.py:129
↓ 4 callers
Function
free_buffers
c/examples/raw_echo.c:130
↓ 4 callers
Method
gen_consume_code
(self, prefix: List[str], first_arg: int, indent: int)
c/tools/codec-generator/generate.py:44
↓ 4 callers
Method
getElapsedSeconds
tests/include/catch.hpp:14998
↓ 4 callers
Method
get_name
cpp/src/sender_options.cpp:126
↓ 4 callers
Function
get_reconnect_context
cpp/src/proactor_container_impl.cpp:292
↓ 4 callers
Function
get_tracer
cpp/src/tracing_opentelemetry.cpp:118
↓ 4 callers
Function
getopt
c/tools/include/pncompat/internal/getopt.c:97
↓ 4 callers
Method
group_id
cpp/src/message.cpp:214
↓ 4 callers
Method
handler
()
go/pkg/electron/link.go:216
↓ 4 callers
Method
hasFilters
tests/include/catch.hpp:14678
↓ 4 callers
Function
hexEscapeChar
tests/include/catch.hpp:15474
↓ 4 callers
Method
idle_timeout
cpp/src/connection.cpp:188
↓ 4 callers
Method
includeSuccessfulResults
tests/include/catch.hpp:10002
↓ 4 callers
Method
incoming
(in Incoming)
go/pkg/electron/handler.go:141
↓ 4 callers
Function
indent
(text)
python/tests/proton_tests/main.py:211
↓ 4 callers
Method
init
(s string)
go/pkg/electron/endpoint.go:90
↓ 4 callers
Method
initialIndent
tests/include/catch.hpp:8632
↓ 4 callers
Method
inspect
cpp/src/object.cpp:34
↓ 4 callers
Function
isWhitespace
tests/include/catch.hpp:8478
↓ 4 callers
Function
is_listener
c/src/proactor/win_iocp.cpp:654
↓ 4 callers
Function
is_null
c/tests/tls_test.cpp:269
↓ 4 callers
Method
is_remote_closed
Test if remote ``endpoint`` is closed (ie has state :const:`proton.Endpoint.REMOTE_CLOSED`). :param endpoint: The remote end
python/proton/_handlers.py:375
↓ 4 callers
Function
is_valid
c/tests/tls_test.cpp:273
↓ 4 callers
Function
jabber_tls_process
Return false if TLS error encountered.
c/experimental/raw_plus_tls2.c:209
↓ 4 callers
Method
linkError
(l proton.Link, msg string)
go/pkg/electron/handler.go:53
↓ 4 callers
Function
listener_accepted_next
c/src/proactor/epoll.c:700
↓ 4 callers
Function
listener_begin_close
Always call with lock held so it can be unlocked around overflow processing. */
c/src/proactor/epoll.c:1664
↓ 4 callers
Function
listener_final_free
Call with lock not held */
c/src/proactor/win_iocp.cpp:2885
← previous
next →
1,201–1,300 of 8,826, ranked by callers