Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/zeromq/pyzmq
/ functions
Functions
1,090 in github.com/zeromq/pyzmq
⨍
Functions
1,090
◇
Types & classes
164
↳
Endpoints
1
↓ 1 callers
Method
get_target
Return the target function Allows modifying args/kwargs to be passed.
zmq/decorators.py:84
↓ 1 callers
Method
handle_heart_failure
(self, heart)
examples/heartbeat/heartbeater.py:74
↓ 1 callers
Method
handle_new_heart
(self, heart)
examples/heartbeat/heartbeater.py:70
↓ 1 callers
Method
hello_world_pub
(self)
examples/asyncio/helloworld_pubsub_dealerrouter.py:75
↓ 1 callers
Method
hello_world_sub
(self)
examples/asyncio/helloworld_pubsub_dealerrouter.py:111
↓ 1 callers
Function
initialize_opt_pointer
(option, value, length=0)
zmq/backend/cffi/socket.py:88
↓ 1 callers
Method
is_alive
Is the ZAP thread currently running?
zmq/auth/thread.py:131
↓ 1 callers
Method
lang_changer_dealer
(self)
examples/asyncio/helloworld_pubsub_dealerrouter.py:146
↓ 1 callers
Method
lang_changer_router
(self)
examples/asyncio/helloworld_pubsub_dealerrouter.py:181
↓ 1 callers
Function
load_certificate
Load public and secret key from a zmq certificate. Returns (public_key, secret_key) If the certificate file only contains the public key,
zmq/auth/certs.py:89
↓ 1 callers
Function
load_certificates
Load public keys from all certificates in a directory
zmq/auth/certs.py:124
↓ 1 callers
Function
load_certs
Return server and client certificate keys
tests/test_auth.py:67
↓ 1 callers
Method
log
Log 'msg % args' with level and topic. To pass exception information, use the keyword argument exc_info with a True value::
zmq/log/handlers.py:206
↓ 1 callers
Function
main
()
tools/collect_cmake.py:57
↓ 1 callers
Function
main
()
tools/circle_wheels.py:68
↓ 1 callers
Function
main
()
perf/perf.py:244
↓ 1 callers
Function
main
()
perf/collect.py:83
↓ 1 callers
Function
main
()
mypy_tests/test_socket_async.py:9
↓ 1 callers
Function
main
print version for easier consumption by non-python
buildutils/bundle.py:45
↓ 1 callers
Function
main
()
examples/mongodb/client.py:38
↓ 1 callers
Function
main
()
examples/mongodb/controller.py:94
↓ 1 callers
Function
main
()
examples/serialization/serialsocket.py:92
↓ 1 callers
Function
main
()
examples/eventloop/coroutines.py:53
↓ 1 callers
Function
main
()
examples/asyncio/tornado_asyncio.py:29
↓ 1 callers
Function
main
()
examples/asyncio/coroutines.py:49
↓ 1 callers
Function
main
()
examples/asyncio/helloworld_pubsub_dealerrouter.py:211
↓ 1 callers
Function
main
()
examples/asyncio/router_router.py:68
↓ 1 callers
Function
main
(addrs: List[str])
examples/win32-interrupt/display.py:10
↓ 1 callers
Function
main
()
examples/cython/example.py:26
↓ 1 callers
Function
main
()
examples/pubsub/topics_sub.py:25
↓ 1 callers
Function
main
()
examples/pubsub/subscriber.py:36
↓ 1 callers
Function
main
()
examples/pubsub/topics_pub.py:27
↓ 1 callers
Function
main
()
examples/pubsub/publisher.py:32
↓ 1 callers
Function
main
()
examples/recv_into/recv_into_array.py:13
↓ 1 callers
Function
main
()
examples/recv_into/discard.py:81
↓ 1 callers
Method
main
(self)
examples/asyncio/helloworld_pubsub_dealerrouter.py:61
↓ 1 callers
Method
make_auth
(self)
tests/test_auth.py:137
↓ 1 callers
Function
make_summary
Render a list of files as a markdown table For use summarizing wheel outputs
tools/wheel_summary.py:9
↓ 1 callers
Function
monitored_queue
Start a monitored queue device. A monitored queue is very similar to the zmq.proxy device (monitored queue came first). Differences fro
zmq/backend/cython/_zmq.py:1957
↓ 1 callers
Method
msg_pub
(self)
examples/asyncio/helloworld_pubsub_dealerrouter.py:35
↓ 1 callers
Method
msg_sub
(self, msg: str)
examples/asyncio/helloworld_pubsub_dealerrouter.py:43
↓ 1 callers
Method
multi_skts_method
(self, ctx, pub, sub, foo='bar')
tests/test_decorators.py:364
↓ 1 callers
Function
new_binary_data
(length)
zmq/backend/cffi/socket.py:33
↓ 1 callers
Function
new_int64_pointer
()
zmq/backend/cffi/socket.py:25
↓ 1 callers
Function
new_int_pointer
()
zmq/backend/cffi/socket.py:29
↓ 1 callers
Method
on_recv_stream
( self, callback: Callable[[ZMQStream, list[bytes]], Any], )
zmq/eventloop/zmqstream.py:225
↓ 1 callers
Function
open_tunnel
Open a tunneled connection from a 0MQ url. For use inside tunnel_connection. Returns ------- (url, tunnel) : (str, object)
zmq/ssh/tunnel.py:171
↓ 1 callers
Function
parse_args
(argv=None)
perf/perf.py:24
↓ 1 callers
Function
ping
print dots to indicate idleness
examples/eventloop/coroutines.py:17
↓ 1 callers
Function
print_every
(s: str, t: float | None = None)
examples/gevent/simple.py:37
↓ 1 callers
Function
publisher
(url)
examples/recv_into/discard.py:52
↓ 1 callers
Function
receiver
receive messages with poll and timeout
examples/eventloop/coroutines.py:24
↓ 1 callers
Method
recv_array
recv a numpy array
examples/serialization/serialsocket.py:78
↓ 1 callers
Method
recv_multipart
( self, flags: int = ..., *, copy: Literal[True], track: bool = ... )
zmq/sugar/socket.py:754
↓ 1 callers
Function
render_constants
render generated constant files from templates
buildutils/constants.py:118
↓ 1 callers
Function
report_version
Report the bundled version of the dependency
buildutils/bundle.py:19
↓ 1 callers
Function
run
Run Ironhouse example
examples/security/asyncio-ironhouse.py:26
↓ 1 callers
Function
run
Run strawhouse client
examples/security/strawhouse.py:22
↓ 1 callers
Function
run
Run Ironhouse example
examples/security/ioloop-ironhouse.py:86
↓ 1 callers
Function
run
Run woodhouse example
examples/security/woodhouse.py:21
↓ 1 callers
Function
run
Run Stonehouse example
examples/security/stonehouse.py:23
↓ 1 callers
Method
run_device
The runner method. Do not call me directly, instead call ``self.start()``, just like a Thread.
zmq/devices/basedevice.py:230
↓ 1 callers
Function
run_loop
()
examples/monitoring/zmq_monitor_class.py:69
↓ 1 callers
Function
send_array
( socket: zmq.Socket, array: numpy.ndarray, flags=0, copy=True, track=False )
examples/pubsub/publisher.py:20
↓ 1 callers
Method
send_array
send a numpy array with metadata
examples/serialization/serialsocket.py:67
↓ 1 callers
Method
send_multipart
Send a sequence of buffers as a multipart message. The zmq.SNDMORE flag is added to all msg parts before the last. Parameters
zmq/sugar/socket.py:700
↓ 1 callers
Function
sender
send a message every second
examples/eventloop/coroutines.py:40
↓ 1 callers
Function
serialize
(msg)
tests/test_asyncio.py:204
↓ 1 callers
Method
set
(self, option, value)
zmq/backend/cffi/socket.py:213
↓ 1 callers
Method
set
Override in subclass
zmq/sugar/attrsettr.py:74
↓ 1 callers
Function
setup_client
setup a simple client with CURVE auth
examples/security/ioloop-ironhouse.py:60
↓ 1 callers
Function
setup_server
setup a simple echo server with CURVE auth
examples/security/ioloop-ironhouse.py:37
↓ 1 callers
Method
shadow
Shadow an existing libzmq context address is a zmq.Context or an integer (or FFI pointer) representing the address of the libzmq cont
zmq/sugar/context.py:175
↓ 1 callers
Method
start
Start a new garbage collection thread. Creates a new zmq Context used for garbage collection. Under most circumstances, this will onl
zmq/utils/garbage.py:158
↓ 1 callers
Method
start
Start the device. Override me in subclass for other launchers.
zmq/devices/basedevice.py:258
↓ 1 callers
Method
start
Start the counter
zmq/sugar/stopwatch.py:29
↓ 1 callers
Method
start_auth
(self)
tests/test_auth.py:140
↓ 1 callers
Method
start_zap
(self)
tests/test_security.py:79
↓ 1 callers
Method
stop
Stop ZAP authentication
zmq/auth/asyncio.py:56
↓ 1 callers
Method
stop_on_recv
Disable callback and automatic receiving.
zmq/eventloop/zmqstream.py:142
↓ 1 callers
Method
stop_on_send
Disable callback on sending.
zmq/eventloop/zmqstream.py:146
↓ 1 callers
Method
stop_zap
(self)
tests/test_security.py:83
↓ 1 callers
Function
sub_logger
(port: int, level: int = logging.DEBUG)
examples/logger/zmqlogger.py:28
↓ 1 callers
Function
summarize_cmake
Collect summarized cmake -LH output from a repo
tools/collect_cmake.py:42
↓ 1 callers
Function
summarize_cmake_output
Summarize cmake -LH output Formats help strings nicer, excludes common
tools/collect_cmake.py:17
↓ 1 callers
Method
tearDown
(self)
zmq/tests/__init__.py:231
↓ 1 callers
Method
tearDown
(self)
tests/zmq_test_utils.py:226
↓ 1 callers
Function
term_context
Terminate a context with a timeout
zmq/tests/__init__.py:53
↓ 1 callers
Function
term_context
Terminate a context with a timeout
tests/conftest.py:58
↓ 1 callers
Function
test
()
tests/test_asyncio.py:375
↓ 1 callers
Function
timer
()
perf/collect.py:32
↓ 1 callers
Method
underlying
The address of the underlying libzmq socket
zmq/backend/cython/_zmq.py:745
↓ 1 callers
Method
unsubscribe
Unsubscribe from a topic Only for SUB sockets. .. versionadded:: 15.3
zmq/sugar/socket.py:414
↓ 1 callers
Function
value_binary_data
(val, length)
zmq/backend/cffi/socket.py:49
↓ 1 callers
Function
value_from_opt_pointer
(option, opt_pointer, length=0)
zmq/backend/cffi/socket.py:71
↓ 1 callers
Function
value_int64_pointer
(val)
zmq/backend/cffi/socket.py:41
↓ 1 callers
Function
value_int_pointer
(val)
zmq/backend/cffi/socket.py:45
↓ 1 callers
Function
zmq_version
return the version of libzmq as a string
zmq/sugar/version.py:55
↓ 1 callers
Function
zmq_version_info
Get libzmq version as tuple of ints
zmq/backend/cffi/__init__.py:15
Function
Context
(request)
tests/test_monitor.py:15
← previous
next →
301–400 of 1,090, ranked by callers