Types & classes — github.com/mosquito/aio-pika

CodeHub MCPcopy Index your code

hub / github.com/mosquito/aio-pika / types & classes

Types & classes101 in github.com/mosquito/aio-pika

⨍ Functions 699◇ Types & classes 101↳ Endpoints 9

↓ 72 callersClassMessage

AMQP message abstraction

aio_pika/message.py:131

↓ 7 callersClassCallbackCollection

aio_pika/tools.py:109

↓ 5 callersClassRobustConnection

Robust connection

aio_pika/robust_connection.py:28

↓ 4 callersClassConnection

Connection abstraction

aio_pika/connection.py:41

↓ 4 callersClassConnectionParameter

aio_pika/abc.py:765

↓ 4 callersClassDockerHostInfo

Parsed DOCKER_HOST connection info.

tests/docker_client.py:17

↓ 4 callersClassMessageProcessError

aio_pika/exceptions.py:36

↓ 4 callersClassPool

aio_pika/pool.py:41

↓ 4 callersClassPoolInvalidStateError

aio_pika/pool.py:37

↓ 3 callersClassDockerNotAvailableError

Raised when Docker is not available.

tests/docker_client.py:12

↓ 3 callersClassIncomingMessage

Incoming message is seems like Message but has additional methods for message acknowledgement. Depending on the acknowledgement mode used, Ra

aio_pika/message.py:322

↓ 3 callersClassMessageInfo

aio_pika/abc.py:133

↓ 3 callersClassRejectMessage

aio_pika/patterns/master.py:37

↓ 2 callersClassMaster

aio_pika/patterns/master.py:71

↓ 2 callersClassMethod

aio_pika/patterns/base.py:9

↓ 2 callersClassNackMessage

aio_pika/patterns/master.py:32

↓ 2 callersClassOneShotCallback

aio_pika/tools.py:295

↓ 2 callersClassProxy

aio_pika/patterns/base.py:26

↓ 1 callersClassBadNetwork

tests/test_amqp_robust_proxy.py:617

↓ 1 callersClassBadNetwork5KB

tests/test_amqp_robust_proxy.py:531

↓ 1 callersClassCallable

tests/test_tools.py:139

↓ 1 callersClassContainerInfo

tests/docker_client.py:146

↓ 1 callersClassDeliveryMode

aio_pika/abc.py:76

↓ 1 callersClassDockerClient

tests/docker_client.py:164

↓ 1 callersClassFibonacciRpcClient

docs/source/rabbitmq-tutorial/examples/6-rpc/rpc_client.py:14

↓ 1 callersClassJsonRPCError

aio_pika/patterns/rpc.py:525

↓ 1 callersClassProcessContext

aio_pika/message.py:550

↓ 1 callersClassQueueIterator

aio_pika/queue.py:445

↓ 1 callersClassRPCException

aio_pika/patterns/rpc.py:31

↓ 1 callersClassRobustQueueIterator

Queue iterator that survives channel reconnection. This iterator handles channel disconnection/reconnection gracefully by waiting for channel

aio_pika/robust_queue.py:164

↓ 1 callersClassSSLOptions

aio_pika/abc.py:55

↓ 1 callersClassStubAwaitable

aio_pika/tools.py:99

↓ 1 callersClassTransaction

aio_pika/transaction.py:15

↓ 1 callersClassUnixHTTPConnection

HTTP connection over Unix socket for Docker API.

tests/docker_client.py:152

↓ 1 callersClassWorker

aio_pika/patterns/master.py:42

ClassAbstractChannel

aio_pika/abc.py:547

ClassAbstractConnection

aio_pika/abc.py:780

ClassAbstractExchange

aio_pika/abc.py:441

ClassAbstractIncomingMessage

aio_pika/abc.py:201

ClassAbstractMessage

aio_pika/abc.py:156

ClassAbstractProcessContext

aio_pika/abc.py:247

ClassAbstractQueue

aio_pika/abc.py:262

ClassAbstractQueueIterator

aio_pika/abc.py:401

ClassAbstractRobustChannel

aio_pika/abc.py:912

ClassAbstractRobustConnection

aio_pika/abc.py:955

ClassAbstractRobustExchange

aio_pika/abc.py:894

ClassAbstractRobustQueue

aio_pika/abc.py:861

ClassAbstractTransaction

aio_pika/abc.py:95

aio_pika/patterns/base.py:36

docs/source/examples/tornado-pubsub.py:9

ClassCallbackType

aio_pika/tools.py:89

Channel abstraction

aio_pika/channel.py:61

ClassChannelContext

aio_pika/channel.py:42

ClassCompressedJsonMaster

aio_pika/patterns/master.py:231

ClassDeclarationResult

aio_pika/abc.py:90

Exchange abstraction

aio_pika/exchange.py:21

ClassExchangeType

aio_pika/abc.py:65

ClassFakeConnection

tests/test_connect.py:27

tests/test_pool.py:37

ClassJsonMaster

aio_pika/patterns/master.py:223

aio_pika/patterns/rpc.py:529

ClassMessageProcessingError

aio_pika/patterns/master.py:28

ClassMockConnection

tests/test_connection_params.py:12

ClassMockConnectionRobust

tests/test_connection_params.py:17

ClassMsgpackMaster

docs/source/examples/extend-patterns.py:18

ClassMsgpackRPC

docs/source/examples/extend-patterns.py:8

ClassPoolInstance

aio_pika/pool.py:24

ClassPoolItemContextManager

aio_pika/pool.py:146

ClassPublisherHandler

docs/source/examples/tornado-pubsub.py:19

AMQP queue abstraction

aio_pika/queue.py:54

ClassQueueEmpty

aio_pika/exceptions.py:40

aio_pika/patterns/rpc.py:46

ClassRPCMessageType

aio_pika/patterns/rpc.py:35

ClassReturnedMessage

aio_pika/message.py:543

ClassRobustChannel

Channel abstraction

aio_pika/robust_channel.py:29

ClassRobustExchange

Exchange abstraction

aio_pika/robust_exchange.py:22

ClassRobustQueue

aio_pika/robust_queue.py:27

ClassSubscriberHandler

docs/source/examples/tornado-pubsub.py:13

tests/test_tools.py:16

tests/test_connection_params.py:57

tests/test_rpc.py:31

ClassTestCaseAMQPS

tests/test_amqps.py:63

ClassTestCaseAmqp

tests/test_amqp.py:56

ClassTestCaseAmqpBase

tests/test_amqp.py:38

ClassTestCaseAmqpNoConfirms

tests/test_amqp.py:2013

ClassTestCaseAmqpNoConfirmsRobust

tests/test_amqp_robust.py:210

ClassTestCaseAmqpWithConfirms

tests/test_amqp.py:2019

ClassTestCaseAmqpWithConfirmsRobust

tests/test_amqp_robust.py:214

ClassTestCaseItemReuse

tests/test_pool.py:134

ClassTestCaseNoMaxSize

tests/test_pool.py:113

ClassTestCaseNoRobust

tests/test_amqp_robust.py:28

ClassTestCaseRobust

tests/test_connection_params.py:103

ClassTestCompressedJsonMaster

tests/test_master.py:130

ClassTestEnsureAwaitable

tests/test_tools.py:157

ClassTestInstance

tests/test_pool.py:65

ClassTestInstanceBase

tests/test_pool.py:36

ClassTestJsonMaster

tests/test_master.py:126

ClassTestMaster

tests/test_master.py:14

ClassTransactionState

aio_pika/abc.py:82

ClassUnderlayChannel

aio_pika/abc.py:509

next →1–100 of 101, ranked by callers