MCPcopy Create free account

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

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

↓ 4 callersFunctionUser
User returns a ConnectionOption sets the user name for a connection
go/pkg/electron/connection.go:118
↓ 4 callersMethod__init__
(self, u32: int)
python/proton/_data.py:197
↓ 4 callersMethod__new__
:param value: integer port number or string service name.
python/proton/_url.py:70
↓ 4 callersMethod__setitem__
Checks if the key is a :class:`symbol` type before setting the value
python/proton/_data.py:360
↓ 4 callersMethod_check
(self, err: int)
python/proton/_transport.py:726
↓ 4 callersFunction_check_is_symbol
(s: _T, raise_on_error: bool = True)
python/proton/_data.py:337
↓ 4 callersMethod_flow
(self, link: Union['Sender', 'Receiver'])
python/proton/_handlers.py:1022
↓ 4 callersMethodabort
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 callersMethodaccept
Called in app goroutine to send an accept function to proton and return the resulting endpoint.
go/pkg/electron/endpoint.go:180
↓ 4 callersMethodactive
cpp/src/endpoint.cpp:43
↓ 4 callersMethodadd
tests/include/catch.hpp:11308
↓ 4 callersMethodadjustString
tests/include/catch.hpp:11717
↓ 4 callersMethodanonymous
cpp/src/terminus.cpp:51
↓ 4 callersFunctionapp_inbytes_advance
c/src/ssl/schannel.cpp:1584
↓ 4 callersMethodassertEqualTermini
(self, t1, t2)
python/tests/proton_tests/engine.py:646
↓ 4 callersFunctionassert_equalish
cpp/src/test_bits.hpp:49
↓ 4 callersMethodassert_error
(self, name)
python/tests/proton_tests/transport.py:56
↓ 4 callersFunctionbegin_accept
c/src/proactor/win_iocp.cpp:718
↓ 4 callersMethodbenchmarkNoAnalysis
tests/include/catch.hpp:10015
↓ 4 callersMethodbenchmarkSamples
tests/include/catch.hpp:10016
↓ 4 callersFunctionbin
cpp/src/types_internal.hpp:59
↓ 4 callersFunctionbothOrAll
tests/include/catch.hpp:15852
↓ 4 callersFunctionbuf_unused
c/experimental/raw_plus_tls2.c:106
↓ 4 callersMethodbyte
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 callersFunctionbytes2string
(b, encoding='utf8')
python/cproton.py:203
↓ 4 callersFunctioncLen
(b []byte)
go/pkg/amqp/types.go:220
↓ 4 callersFunctioncPtr
(b []byte)
go/pkg/amqp/types.go:213
↓ 4 callersFunctioncheck_arg
cpp/examples/service_bus.cpp:112
↓ 4 callersFunctioncheck_array
c/tests/data_test.cpp:137
↓ 4 callersFunctioncheck_condition
c/tests/fuzz/fuzz-connection-driver.c:164
↓ 4 callersFunctioncheck_condition
c/tests/fuzz/fuzz-proactor-receive.c:73
↓ 4 callersFunctioncheck_condition
c/examples/send-abort.c:67
↓ 4 callersFunctioncheck_condition
c/examples/receive.c:51
↓ 4 callersFunctioncheck_condition
c/examples/send.c:49
↓ 4 callersFunctioncheck_condition
c/examples/send-ssl.c:51
↓ 4 callersMethodclear
cpp/src/message.cpp:111
↓ 4 callersMethodclosed_write_count
c/tests/raw_connection_proactor_test.cpp:80
↓ 4 callersMethodcontent_encoding
Returns the content encoding type.
ruby/lib/core/message.rb:394
↓ 4 callersMethodcontent_type
cpp/src/message.cpp:182
↓ 4 callersFunctionconvertInto
tests/include/catch.hpp:9072
↓ 4 callersMethodcount_objects
(self, message)
python/tests/integration/test_PROTON_2116_blocking_connection_object_leak.py:52
↓ 4 callersFunctioncredit_topup
This must only be called for receiver links
cpp/src/messaging_adapter.cpp:57
↓ 4 callersMethodcurrent
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 callersFunctiondefault_file
cpp/src/connect_config.cpp:258
↓ 4 callersFunctiondelay_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 callersMethoddelivery
@deprecated use {Sender#send}
ruby/lib/core/link.rb:279
↓ 4 callersMethoddescribed?
()
ruby/lib/types/array.rb:34
↓ 4 callersFunctiondimColour
Colour::LightGrey
tests/include/catch.hpp:15850
↓ 4 callersMethoddispatch
(self, consumer=None)
python/examples/broker.py:51
↓ 4 callersMethoddoLeak
(self, local, remote)
python/tests/proton_tests/engine.py:2677
↓ 4 callersFunctiondoReceive
(rcv Receiver, results chan result)
go/pkg/electron/electron_test.go:165
↓ 4 callersFunctiondo_complete
c/src/proactor/win_iocp.cpp:1804
↓ 4 callersMethoddo_request
(self)
python/examples/client_http.py:61
↓ 4 callersFunctiondrain
c/tests/refcount_test.cpp:315
↓ 4 callersMethoddrain
cpp/src/receiver.cpp:69
↓ 4 callersFunctiondrain_events_until_both
c/tests/raw_connection_test.cpp:280
↓ 4 callersMethoddynamic_properties
cpp/src/terminus.cpp:64
↓ 4 callersMethodeach_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 callersMethodeach_sender
Get the {Sender} links - see {#each_link}
ruby/lib/core/session.rb:144
↓ 4 callersMethodeach_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 callersFunctionemit_end_list
c/src/core/emitters.h:301
↓ 4 callersFunctionemit_list
c/src/core/emitters.h:266
↓ 4 callersFunctionenable_logging
c/tools/msgr-common.c:162
↓ 4 callersFunctionencode_succeeded
c/src/core/emitters.h:89
↓ 4 callersFunctionexampleArgs
(args ...string)
go/examples/example_test.go:153
↓ 4 callersFunctionexampleCommand
exampleCommand returns an exec.Cmd to run an example.
go/examples/example_test.go:111
↓ 4 callersMethodexpect
(events []EventType)
go/pkg/proton/proton_test.go:47
↓ 4 callersFunctionexpect_char
(format: str, char: str)
c/tools/codec-generator/generate.py:256
↓ 4 callersMethodexpired
(self)
python/proton/_selectable.py:97
↓ 4 callersFunctionfatalIf
(err error)
go/examples/electron/selected_recv.go:106
↓ 4 callersMethodfetch_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 callersFunctionfield_kw
(field)
c/src/protocol.py:129
↓ 4 callersFunctionfree_buffers
c/examples/raw_echo.c:130
↓ 4 callersMethodgen_consume_code
(self, prefix: List[str], first_arg: int, indent: int)
c/tools/codec-generator/generate.py:44
↓ 4 callersMethodgetElapsedSeconds
tests/include/catch.hpp:14998
↓ 4 callersMethodget_name
cpp/src/sender_options.cpp:126
↓ 4 callersFunctionget_reconnect_context
cpp/src/proactor_container_impl.cpp:292
↓ 4 callersFunctionget_tracer
cpp/src/tracing_opentelemetry.cpp:118
↓ 4 callersFunctiongetopt
c/tools/include/pncompat/internal/getopt.c:97
↓ 4 callersMethodgroup_id
cpp/src/message.cpp:214
↓ 4 callersMethodhandler
()
go/pkg/electron/link.go:216
↓ 4 callersMethodhasFilters
tests/include/catch.hpp:14678
↓ 4 callersFunctionhexEscapeChar
tests/include/catch.hpp:15474
↓ 4 callersMethodidle_timeout
cpp/src/connection.cpp:188
↓ 4 callersMethodincludeSuccessfulResults
tests/include/catch.hpp:10002
↓ 4 callersMethodincoming
(in Incoming)
go/pkg/electron/handler.go:141
↓ 4 callersFunctionindent
(text)
python/tests/proton_tests/main.py:211
↓ 4 callersMethodinit
(s string)
go/pkg/electron/endpoint.go:90
↓ 4 callersMethodinitialIndent
tests/include/catch.hpp:8632
↓ 4 callersMethodinspect
cpp/src/object.cpp:34
↓ 4 callersFunctionisWhitespace
tests/include/catch.hpp:8478
↓ 4 callersFunctionis_listener
c/src/proactor/win_iocp.cpp:654
↓ 4 callersFunctionis_null
c/tests/tls_test.cpp:269
↓ 4 callersMethodis_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 callersFunctionis_valid
c/tests/tls_test.cpp:273
↓ 4 callersFunctionjabber_tls_process
Return false if TLS error encountered.
c/experimental/raw_plus_tls2.c:209
↓ 4 callersMethodlinkError
(l proton.Link, msg string)
go/pkg/electron/handler.go:53
↓ 4 callersFunctionlistener_accepted_next
c/src/proactor/epoll.c:700
↓ 4 callersFunctionlistener_begin_close
Always call with lock held so it can be unlocked around overflow processing. */
c/src/proactor/epoll.c:1664
↓ 4 callersFunctionlistener_final_free
Call with lock not held */
c/src/proactor/win_iocp.cpp:2885
← previousnext →1,201–1,300 of 8,826, ranked by callers