VimPlug/typeshed
1
0
Fork 0
mirror of https://github.com/davidhalter/typeshed.git synced 2025-12-09 13:34:58 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Initial pika stubs (#9200)

Browse Source
This commit is contained in:
Sebastian Rittau
2022-11-21 19:31:21 +01:00
committed by GitHub
parent 4588dd6c74
commit ebb5bddbdc
33 changed files with 2374 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
pyrightconfig.stricter.json
View File

@@ -52,6 +52,7 @@
"stubs/google-cloud-ndb",
"stubs/passlib",
"stubs/peewee",
"stubs/pika",
"stubs/psutil",
"stubs/psycopg2",
"stubs/pyflakes",

28
stubs/pika/@tests/stubtest_allowlist.txt Normal file
View File

@@ -0,0 +1,28 @@
# Inherited from stdlib's io module.
pika.compat.StringIO.seek
pika.compat.StringIO.truncate
# Requires external libraries to be installed.
pika\.adapters\.gevent_connection.*
pika\.adapters\.tornado_connection.*
pika\.adapters\.twisted_connection.*
# Stubtest doesn't understand that a property alias is also read-only.
pika.BlockingConnection.basic_nack
pika.BlockingConnection.consumer_cancel_notify
pika.BlockingConnection.exchange_exchange_bindings
pika.BlockingConnection.publisher_confirms
pika.adapters.BlockingConnection.basic_nack
pika.adapters.BlockingConnection.consumer_cancel_notify
pika.adapters.BlockingConnection.exchange_exchange_bindings
pika.adapters.BlockingConnection.publisher_confirms
pika.adapters.blocking_connection.BlockingConnection.basic_nack
pika.adapters.blocking_connection.BlockingConnection.consumer_cancel_notify
pika.adapters.blocking_connection.BlockingConnection.exchange_exchange_bindings
pika.adapters.blocking_connection.BlockingConnection.publisher_confirms
# Flagged by stubtest for unknown reasons.
pika.data.PY2
pika.data.basestring
pika.spec.str_or_bytes
pika.validators.basestring

4
stubs/pika/METADATA.toml Normal file
View File

@@ -0,0 +1,4 @@
version = "1.3.*"
[tool.stubtest]
ignore_missing_stub = false

11
stubs/pika/pika/__init__.pyi Normal file
View File

@@ -0,0 +1,11 @@
from pika import adapters as adapters
from pika.adapters import (
BaseConnection as BaseConnection,
BlockingConnection as BlockingConnection,
SelectConnection as SelectConnection,
)
from pika.adapters.utils.connection_workflow import AMQPConnectionWorkflow as AMQPConnectionWorkflow
from pika.connection import ConnectionParameters as ConnectionParameters, SSLOptions as SSLOptions, URLParameters as URLParameters
from pika.credentials import PlainCredentials as PlainCredentials
from pika.delivery_mode import DeliveryMode as DeliveryMode
from pika.spec import BasicProperties as BasicProperties

3
stubs/pika/pika/adapters/__init__.pyi Normal file
View File

@@ -0,0 +1,3 @@
from pika.adapters.base_connection import BaseConnection as BaseConnection
from pika.adapters.blocking_connection import BlockingConnection as BlockingConnection
from pika.adapters.select_connection import IOLoop as IOLoop, SelectConnection as SelectConnection

48
stubs/pika/pika/adapters/asyncio_connection.pyi Normal file
View File

@@ -0,0 +1,48 @@
from _typeshed import Incomplete
from pika.adapters import base_connection
from pika.adapters.utils import io_services_utils, nbio_interface
LOGGER: Incomplete
class AsyncioConnection(base_connection.BaseConnection):
def __init__(
self,
parameters: Incomplete | None = ...,
on_open_callback: Incomplete | None = ...,
on_open_error_callback: Incomplete | None = ...,
on_close_callback: Incomplete | None = ...,
custom_ioloop: Incomplete | None = ...,
internal_connection_workflow: bool = ...,
) -> None: ...
@classmethod
def create_connection(
cls, connection_configs, on_done, custom_ioloop: Incomplete | None = ..., workflow: Incomplete | None = ...
): ...
class _AsyncioIOServicesAdapter(
io_services_utils.SocketConnectionMixin,
io_services_utils.StreamingConnectionMixin,
nbio_interface.AbstractIOServices,
nbio_interface.AbstractFileDescriptorServices,
):
def __init__(self, loop: Incomplete | None = ...) -> None: ...
def get_native_ioloop(self): ...
def close(self) -> None: ...
def run(self) -> None: ...
def stop(self) -> None: ...
def add_callback_threadsafe(self, callback) -> None: ...
def call_later(self, delay, callback): ...
def getaddrinfo(self, host, port, on_done, family: int = ..., socktype: int = ..., proto: int = ..., flags: int = ...): ...
def set_reader(self, fd, on_readable) -> None: ...
def remove_reader(self, fd): ...
def set_writer(self, fd, on_writable) -> None: ...
def remove_writer(self, fd): ...
class _TimerHandle(nbio_interface.AbstractTimerReference):
def __init__(self, handle) -> None: ...
def cancel(self) -> None: ...
class _AsyncioIOReference(nbio_interface.AbstractIOReference):
def __init__(self, future, on_done) -> None: ...
def cancel(self): ...

28
stubs/pika/pika/adapters/base_connection.pyi Normal file
View File

@@ -0,0 +1,28 @@
import abc
from _typeshed import Incomplete
from pika import connection
from pika.adapters.utils import nbio_interface
LOGGER: Incomplete
class BaseConnection(connection.Connection, metaclass=abc.ABCMeta):
def __init__(
self, parameters, on_open_callback, on_open_error_callback, on_close_callback, nbio, internal_connection_workflow
) -> None: ...
@classmethod
@abc.abstractmethod
def create_connection(
cls, connection_configs, on_done, custom_ioloop: Incomplete | None = ..., workflow: Incomplete | None = ...
): ...
@property
def ioloop(self): ...
class _StreamingProtocolShim(nbio_interface.AbstractStreamProtocol):
connection_made: Incomplete
connection_lost: Incomplete
eof_received: Incomplete
data_received: Incomplete
conn: Incomplete
def __init__(self, conn) -> None: ...
def __getattr__(self, attr): ...

236
stubs/pika/pika/adapters/blocking_connection.pyi Normal file
View File

@@ -0,0 +1,236 @@
from _typeshed import Incomplete
from collections.abc import Generator
from typing import NamedTuple
LOGGER: Incomplete
class _CallbackResult:
def __init__(self, value_class: Incomplete | None = ...) -> None: ...
def reset(self) -> None: ...
def __bool__(self) -> bool: ...
__nonzero__: Incomplete
def __enter__(self): ...
def __exit__(self, *args, **kwargs) -> None: ...
def is_ready(self): ...
@property
def ready(self): ...
def signal_once(self, *_args, **_kwargs) -> None: ...
def set_value_once(self, *args, **kwargs) -> None: ...
def append_element(self, *args, **kwargs) -> None: ...
@property
def value(self): ...
@property
def elements(self): ...
class _IoloopTimerContext:
def __init__(self, duration, connection) -> None: ...
def __enter__(self): ...
def __exit__(self, *_args, **_kwargs) -> None: ...
def is_ready(self): ...
class _TimerEvt:
timer_id: Incomplete
def __init__(self, callback) -> None: ...
def dispatch(self) -> None: ...
class _ConnectionBlockedUnblockedEvtBase:
def __init__(self, callback, method_frame) -> None: ...
def dispatch(self) -> None: ...
class _ConnectionBlockedEvt(_ConnectionBlockedUnblockedEvtBase): ...
class _ConnectionUnblockedEvt(_ConnectionBlockedUnblockedEvtBase): ...
class BlockingConnection:
class _OnClosedArgs(NamedTuple):
connection: Incomplete
error: Incomplete
class _OnChannelOpenedArgs(NamedTuple):
channel: Incomplete
def __init__(self, parameters: Incomplete | None = ..., _impl_class: Incomplete | None = ...) -> None: ...
def __enter__(self): ...
def __exit__(self, exc_type, value, traceback) -> None: ...
def add_on_connection_blocked_callback(self, callback) -> None: ...
def add_on_connection_unblocked_callback(self, callback) -> None: ...
def call_later(self, delay, callback): ...
def add_callback_threadsafe(self, callback) -> None: ...
def remove_timeout(self, timeout_id) -> None: ...
def update_secret(self, new_secret, reason) -> None: ...
def close(self, reply_code: int = ..., reply_text: str = ...) -> None: ...
def process_data_events(self, time_limit: int = ...): ...
def sleep(self, duration) -> None: ...
def channel(self, channel_number: Incomplete | None = ...): ...
@property
def is_closed(self): ...
@property
def is_open(self): ...
@property
def basic_nack_supported(self): ...
@property
def consumer_cancel_notify_supported(self): ...
@property
def exchange_exchange_bindings_supported(self): ...
@property
def publisher_confirms_supported(self): ...
basic_nack = basic_nack_supported
consumer_cancel_notify = consumer_cancel_notify_supported
exchange_exchange_bindings = exchange_exchange_bindings_supported
publisher_confirms = publisher_confirms_supported
class _ChannelPendingEvt: ...
class _ConsumerDeliveryEvt(_ChannelPendingEvt):
method: Incomplete
properties: Incomplete
body: Incomplete
def __init__(self, method, properties, body) -> None: ...
class _ConsumerCancellationEvt(_ChannelPendingEvt):
method_frame: Incomplete
def __init__(self, method_frame) -> None: ...
@property
def method(self): ...
class _ReturnedMessageEvt(_ChannelPendingEvt):
callback: Incomplete
channel: Incomplete
method: Incomplete
properties: Incomplete
body: Incomplete
def __init__(self, callback, channel, method, properties, body) -> None: ...
def dispatch(self) -> None: ...
class ReturnedMessage:
method: Incomplete
properties: Incomplete
body: Incomplete
def __init__(self, method, properties, body) -> None: ...
class _ConsumerInfo:
SETTING_UP: int
ACTIVE: int
TEARING_DOWN: int
CANCELLED_BY_BROKER: int
consumer_tag: Incomplete
auto_ack: Incomplete
on_message_callback: Incomplete
alternate_event_sink: Incomplete
state: Incomplete
def __init__(
self, consumer_tag, auto_ack, on_message_callback: Incomplete | None = ..., alternate_event_sink: Incomplete | None = ...
) -> None: ...
@property
def setting_up(self): ...
@property
def active(self): ...
@property
def tearing_down(self): ...
@property
def cancelled_by_broker(self): ...
class _QueueConsumerGeneratorInfo:
params: Incomplete
consumer_tag: Incomplete
pending_events: Incomplete
def __init__(self, params, consumer_tag) -> None: ...
class BlockingChannel:
class _RxMessageArgs(NamedTuple):
channel: Incomplete
method: Incomplete
properties: Incomplete
body: Incomplete
class _MethodFrameCallbackResultArgs(NamedTuple):
method_frame: Incomplete
class _OnMessageConfirmationReportArgs(NamedTuple):
method_frame: Incomplete
class _FlowOkCallbackResultArgs(NamedTuple):
active: Incomplete
def __init__(self, channel_impl, connection) -> None: ...
def __int__(self) -> int: ...
def __enter__(self): ...
def __exit__(self, exc_type, value, traceback) -> None: ...
@property
def channel_number(self): ...
@property
def connection(self): ...
@property
def is_closed(self): ...
@property
def is_open(self): ...
@property
def consumer_tags(self): ...
def close(self, reply_code: int = ..., reply_text: str = ...): ...
def flow(self, active): ...
def add_on_cancel_callback(self, callback) -> None: ...
def add_on_return_callback(self, callback): ...
def basic_consume(
self,
queue,
on_message_callback,
auto_ack: bool = ...,
exclusive: bool = ...,
consumer_tag: Incomplete | None = ...,
arguments: Incomplete | None = ...,
): ...
def basic_cancel(self, consumer_tag): ...
def start_consuming(self) -> None: ...
def stop_consuming(self, consumer_tag: Incomplete | None = ...) -> None: ...
def consume(
self,
queue,
auto_ack: bool = ...,
exclusive: bool = ...,
arguments: Incomplete | None = ...,
inactivity_timeout: Incomplete | None = ...,
) -> Generator[Incomplete, None, None]: ...
def get_waiting_message_count(self): ...
def cancel(self): ...
def basic_ack(self, delivery_tag: int = ..., multiple: bool = ...) -> None: ...
def basic_nack(self, delivery_tag: int = ..., multiple: bool = ..., requeue: bool = ...) -> None: ...
def basic_get(self, queue, auto_ack: bool = ...): ...
def basic_publish(self, exchange, routing_key, body, properties: Incomplete | None = ..., mandatory: bool = ...) -> None: ...
def basic_qos(self, prefetch_size: int = ..., prefetch_count: int = ..., global_qos: bool = ...) -> None: ...
def basic_recover(self, requeue: bool = ...) -> None: ...
def basic_reject(self, delivery_tag: int = ..., requeue: bool = ...) -> None: ...
def confirm_delivery(self) -> None: ...
def exchange_declare(
self,
exchange,
exchange_type=...,
passive: bool = ...,
durable: bool = ...,
auto_delete: bool = ...,
internal: bool = ...,
arguments: Incomplete | None = ...,
): ...
def exchange_delete(self, exchange: Incomplete | None = ..., if_unused: bool = ...): ...
def exchange_bind(self, destination, source, routing_key: str = ..., arguments: Incomplete | None = ...): ...
def exchange_unbind(
self,
destination: Incomplete | None = ...,
source: Incomplete | None = ...,
routing_key: str = ...,
arguments: Incomplete | None = ...,
): ...
def queue_declare(
self,
queue,
passive: bool = ...,
durable: bool = ...,
exclusive: bool = ...,
auto_delete: bool = ...,
arguments: Incomplete | None = ...,
): ...
def queue_delete(self, queue, if_unused: bool = ..., if_empty: bool = ...): ...
def queue_purge(self, queue): ...
def queue_bind(self, queue, exchange, routing_key: Incomplete | None = ..., arguments: Incomplete | None = ...): ...
def queue_unbind(
self, queue, exchange: Incomplete | None = ..., routing_key: Incomplete | None = ..., arguments: Incomplete | None = ...
): ...
def tx_select(self): ...
def tx_commit(self): ...
def tx_rollback(self): ...

56
stubs/pika/pika/adapters/gevent_connection.pyi Normal file
View File

@@ -0,0 +1,56 @@
from _typeshed import Incomplete
from pika.adapters.base_connection import BaseConnection
from pika.adapters.utils.nbio_interface import AbstractIOReference
from pika.adapters.utils.selector_ioloop_adapter import AbstractSelectorIOLoop, SelectorIOServicesAdapter
LOGGER: Incomplete
class GeventConnection(BaseConnection):
def __init__(
self,
parameters: Incomplete | None = ...,
on_open_callback: Incomplete | None = ...,
on_open_error_callback: Incomplete | None = ...,
on_close_callback: Incomplete | None = ...,
custom_ioloop: Incomplete | None = ...,
internal_connection_workflow: bool = ...,
) -> None: ...
@classmethod
def create_connection(
cls, connection_configs, on_done, custom_ioloop: Incomplete | None = ..., workflow: Incomplete | None = ...
): ...
class _TSafeCallbackQueue:
def __init__(self) -> None: ...
@property
def fd(self): ...
def add_callback_threadsafe(self, callback) -> None: ...
def run_next_callback(self) -> None: ...
class _GeventSelectorIOLoop(AbstractSelectorIOLoop):
READ: int
WRITE: int
ERROR: int
def __init__(self, gevent_hub: Incomplete | None = ...) -> None: ...
def close(self) -> None: ...
def start(self) -> None: ...
def stop(self) -> None: ...
def add_callback(self, callback) -> None: ...
def call_later(self, delay, callback): ...
def remove_timeout(self, timeout_handle) -> None: ...
def add_handler(self, fd, handler, events) -> None: ...
def update_handler(self, fd, events) -> None: ...
def remove_handler(self, fd) -> None: ...
class _GeventSelectorIOServicesAdapter(SelectorIOServicesAdapter):
def getaddrinfo(self, host, port, on_done, family: int = ..., socktype: int = ..., proto: int = ..., flags: int = ...): ...
class _GeventIOLoopIOHandle(AbstractIOReference):
def __init__(self, subject) -> None: ...
def cancel(self): ...
class _GeventAddressResolver:
def __init__(self, native_loop, host, port, family, socktype, proto, flags, on_done) -> None: ...
def start(self) -> None: ...
def cancel(self): ...

99
stubs/pika/pika/adapters/select_connection.pyi Normal file
View File

@@ -0,0 +1,99 @@
import abc
from _typeshed import Incomplete
import pika.compat
from pika.adapters.base_connection import BaseConnection
from pika.adapters.utils.selector_ioloop_adapter import AbstractSelectorIOLoop
LOGGER: Incomplete
SELECT_TYPE: Incomplete
class SelectConnection(BaseConnection):
def __init__(
self,
parameters: Incomplete | None = ...,
on_open_callback: Incomplete | None = ...,
on_open_error_callback: Incomplete | None = ...,
on_close_callback: Incomplete | None = ...,
custom_ioloop: Incomplete | None = ...,
internal_connection_workflow: bool = ...,
) -> None: ...
@classmethod
def create_connection(
cls, connection_configs, on_done, custom_ioloop: Incomplete | None = ..., workflow: Incomplete | None = ...
): ...
class _Timeout:
deadline: Incomplete
callback: Incomplete
def __init__(self, deadline, callback) -> None: ...
def __eq__(self, other): ...
def __ne__(self, other): ...
def __lt__(self, other): ...
def __gt__(self, other): ...
def __le__(self, other): ...
def __ge__(self, other): ...
class _Timer:
def __init__(self) -> None: ...
def close(self) -> None: ...
def call_later(self, delay, callback): ...
def remove_timeout(self, timeout) -> None: ...
def get_remaining_interval(self): ...
def process_timeouts(self) -> None: ...
class PollEvents:
READ: Incomplete
WRITE: Incomplete
ERROR: Incomplete
class IOLoop(AbstractSelectorIOLoop):
READ: Incomplete
WRITE: Incomplete
ERROR: Incomplete
def __init__(self) -> None: ...
def close(self) -> None: ...
def call_later(self, delay, callback): ...
def remove_timeout(self, timeout_handle) -> None: ...
def add_callback_threadsafe(self, callback) -> None: ...
add_callback: Incomplete
def process_timeouts(self) -> None: ...
def add_handler(self, fd, handler, events) -> None: ...
def update_handler(self, fd, events) -> None: ...
def remove_handler(self, fd) -> None: ...
def start(self) -> None: ...
def stop(self) -> None: ...
def activate_poller(self) -> None: ...
def deactivate_poller(self) -> None: ...
def poll(self) -> None: ...
class _PollerBase(pika.compat.AbstractBase, metaclass=abc.ABCMeta):
POLL_TIMEOUT_MULT: int
def __init__(self, get_wait_seconds, process_timeouts) -> None: ...
def close(self) -> None: ...
def wake_threadsafe(self) -> None: ...
def add_handler(self, fileno, handler, events) -> None: ...
def update_handler(self, fileno, events) -> None: ...
def remove_handler(self, fileno) -> None: ...
def activate_poller(self) -> None: ...
def deactivate_poller(self) -> None: ...
def start(self) -> None: ...
def stop(self) -> None: ...
@abc.abstractmethod
def poll(self): ...
class SelectPoller(_PollerBase):
POLL_TIMEOUT_MULT: int
def poll(self) -> None: ...
class KQueuePoller(_PollerBase):
def __init__(self, get_wait_seconds, process_timeouts) -> None: ...
def poll(self) -> None: ...
class PollPoller(_PollerBase):
POLL_TIMEOUT_MULT: int
def __init__(self, get_wait_seconds, process_timeouts) -> None: ...
def poll(self) -> None: ...
class EPollPoller(PollPoller):
POLL_TIMEOUT_MULT: int

20
stubs/pika/pika/adapters/tornado_connection.pyi Normal file
View File

@@ -0,0 +1,20 @@
from _typeshed import Incomplete
from pika.adapters import base_connection
LOGGER: Incomplete
class TornadoConnection(base_connection.BaseConnection):
def __init__(
self,
parameters: Incomplete | None = ...,
on_open_callback: Incomplete | None = ...,
on_open_error_callback: Incomplete | None = ...,
on_close_callback: Incomplete | None = ...,
custom_ioloop: Incomplete | None = ...,
internal_connection_workflow: bool = ...,
) -> None: ...
@classmethod
def create_connection(
cls, connection_configs, on_done, custom_ioloop: Incomplete | None = ..., workflow: Incomplete | None = ...
): ...

127
stubs/pika/pika/adapters/twisted_connection.pyi Normal file
View File

@@ -0,0 +1,127 @@
from _typeshed import Incomplete
from typing import Any, NamedTuple
from typing_extensions import TypeAlias
import pika.connection
from pika.adapters.utils import nbio_interface
DeferredQueue: TypeAlias = Any # TODO: twisted.internet.defer.DeferredQueue
Protocol: TypeAlias = Any # TODO: twisted.internet.protocol.Protocol
LOGGER: Incomplete
class ClosableDeferredQueue(DeferredQueue):
closed: Incomplete
def __init__(self, size: Incomplete | None = ..., backlog: Incomplete | None = ...) -> None: ...
def put(self, obj): ...
def get(self): ...
pending: Incomplete
def close(self, reason) -> None: ...
class ReceivedMessage(NamedTuple):
channel: Incomplete
method: Incomplete
properties: Incomplete
body: Incomplete
class TwistedChannel:
on_closed: Incomplete
def __init__(self, channel) -> None: ...
@property
def channel_number(self): ...
@property
def connection(self): ...
@property
def is_closed(self): ...
@property
def is_closing(self): ...
@property
def is_open(self): ...
@property
def flow_active(self): ...
@property
def consumer_tags(self): ...
def callback_deferred(self, deferred, replies) -> None: ...
def add_on_return_callback(self, callback): ...
def basic_ack(self, delivery_tag: int = ..., multiple: bool = ...): ...
def basic_cancel(self, consumer_tag: str = ...): ...
def basic_consume(
self,
queue,
auto_ack: bool = ...,
exclusive: bool = ...,
consumer_tag: Incomplete | None = ...,
arguments: Incomplete | None = ...,
): ...
def basic_get(self, queue, auto_ack: bool = ...): ...
def basic_nack(self, delivery_tag: Incomplete | None = ..., multiple: bool = ..., requeue: bool = ...): ...
def basic_publish(self, exchange, routing_key, body, properties: Incomplete | None = ..., mandatory: bool = ...): ...
def basic_qos(self, prefetch_size: int = ..., prefetch_count: int = ..., global_qos: bool = ...): ...
def basic_reject(self, delivery_tag, requeue: bool = ...): ...
def basic_recover(self, requeue: bool = ...): ...
def close(self, reply_code: int = ..., reply_text: str = ...): ...
def confirm_delivery(self): ...
def exchange_bind(self, destination, source, routing_key: str = ..., arguments: Incomplete | None = ...): ...
def exchange_declare(
self,
exchange,
exchange_type=...,
passive: bool = ...,
durable: bool = ...,
auto_delete: bool = ...,
internal: bool = ...,
arguments: Incomplete | None = ...,
): ...
def exchange_delete(self, exchange: Incomplete | None = ..., if_unused: bool = ...): ...
def exchange_unbind(
self,
destination: Incomplete | None = ...,
source: Incomplete | None = ...,
routing_key: str = ...,
arguments: Incomplete | None = ...,
): ...
def flow(self, active): ...
def open(self): ...
def queue_bind(self, queue, exchange, routing_key: Incomplete | None = ..., arguments: Incomplete | None = ...): ...
def queue_declare(
self,
queue,
passive: bool = ...,
durable: bool = ...,
exclusive: bool = ...,
auto_delete: bool = ...,
arguments: Incomplete | None = ...,
): ...
def queue_delete(self, queue, if_unused: bool = ..., if_empty: bool = ...): ...
def queue_purge(self, queue): ...
def queue_unbind(
self, queue, exchange: Incomplete | None = ..., routing_key: Incomplete | None = ..., arguments: Incomplete | None = ...
): ...
def tx_commit(self): ...
def tx_rollback(self): ...
def tx_select(self): ...
class _TwistedConnectionAdapter(pika.connection.Connection):
def __init__(self, parameters, on_open_callback, on_open_error_callback, on_close_callback, custom_reactor) -> None: ...
def connection_made(self, transport) -> None: ...
def connection_lost(self, error) -> None: ...
def data_received(self, data) -> None: ...
class TwistedProtocolConnection(Protocol):
ready: Incomplete
closed: Incomplete
def __init__(self, parameters: Incomplete | None = ..., custom_reactor: Incomplete | None = ...) -> None: ...
def channel(self, channel_number: Incomplete | None = ...): ...
@property
def is_open(self): ...
@property
def is_closed(self): ...
def close(self, reply_code: int = ..., reply_text: str = ...): ...
def dataReceived(self, data) -> None: ...
def connectionLost(self, reason=...) -> None: ...
def makeConnection(self, transport) -> None: ...
def connectionReady(self): ...
class _TimerHandle(nbio_interface.AbstractTimerReference):
def __init__(self, handle) -> None: ...
def cancel(self) -> None: ...

0
stubs/pika/pika/adapters/utils/__init__.pyi Normal file
View File

37
stubs/pika/pika/adapters/utils/connection_workflow.pyi Normal file
View File

@@ -0,0 +1,37 @@
from _typeshed import Incomplete
import pika.compat
class AMQPConnectorException(Exception): ...
class AMQPConnectorStackTimeout(AMQPConnectorException): ...
class AMQPConnectorAborted(AMQPConnectorException): ...
class AMQPConnectorWrongState(AMQPConnectorException): ...
class AMQPConnectorPhaseErrorBase(AMQPConnectorException):
exception: Incomplete
def __init__(self, exception, *args) -> None: ...
class AMQPConnectorSocketConnectError(AMQPConnectorPhaseErrorBase): ...
class AMQPConnectorTransportSetupError(AMQPConnectorPhaseErrorBase): ...
class AMQPConnectorAMQPHandshakeError(AMQPConnectorPhaseErrorBase): ...
class AMQPConnectionWorkflowAborted(AMQPConnectorException): ...
class AMQPConnectionWorkflowWrongState(AMQPConnectorException): ...
class AMQPConnectionWorkflowFailed(AMQPConnectorException):
exceptions: Incomplete
def __init__(self, exceptions, *args) -> None: ...
class AMQPConnector:
def __init__(self, conn_factory, nbio) -> None: ...
def start(self, addr_record, conn_params, on_done) -> None: ...
def abort(self) -> None: ...
class AbstractAMQPConnectionWorkflow(pika.compat.AbstractBase):
def start(self, connection_configs, connector_factory, native_loop, on_done) -> None: ...
def abort(self) -> None: ...
class AMQPConnectionWorkflow(AbstractAMQPConnectionWorkflow):
def __init__(self, _until_first_amqp_attempt: bool = ...) -> None: ...
def set_io_services(self, nbio) -> None: ...
def start(self, connection_configs, connector_factory, native_loop, on_done) -> None: ...
def abort(self) -> None: ...

46
stubs/pika/pika/adapters/utils/io_services_utils.pyi Normal file
View File

@@ -0,0 +1,46 @@
import abc
from _typeshed import Incomplete
from pika.adapters.utils.nbio_interface import AbstractIOReference, AbstractStreamTransport
def check_callback_arg(callback, name) -> None: ...
def check_fd_arg(fd) -> None: ...
class SocketConnectionMixin:
def connect_socket(self, sock, resolved_addr, on_done): ...
class StreamingConnectionMixin:
def create_streaming_connection(
self, protocol_factory, sock, on_done, ssl_context: Incomplete | None = ..., server_hostname: Incomplete | None = ...
): ...
class _AsyncServiceAsyncHandle(AbstractIOReference):
def __init__(self, subject) -> None: ...
def cancel(self): ...
class _AsyncSocketConnector:
def __init__(self, nbio, sock, resolved_addr, on_done) -> None: ...
def start(self): ...
def cancel(self): ...
class _AsyncStreamConnector:
def __init__(self, nbio, protocol_factory, sock, ssl_context, server_hostname, on_done) -> None: ...
def start(self): ...
def cancel(self): ...
class _AsyncTransportBase(AbstractStreamTransport, metaclass=abc.ABCMeta):
class RxEndOfFile(OSError):
def __init__(self) -> None: ...
def __init__(self, sock, protocol, nbio) -> None: ...
def abort(self) -> None: ...
def get_protocol(self): ...
def get_write_buffer_size(self): ...
class _AsyncPlaintextTransport(_AsyncTransportBase):
def __init__(self, sock, protocol, nbio) -> None: ...
def write(self, data) -> None: ...
class _AsyncSSLTransport(_AsyncTransportBase):
def __init__(self, sock, protocol, nbio) -> None: ...
def write(self, data) -> None: ...

64
stubs/pika/pika/adapters/utils/nbio_interface.pyi Normal file
View File

@@ -0,0 +1,64 @@
import abc
from _typeshed import Incomplete
import pika.compat
class AbstractIOServices(pika.compat.AbstractBase, metaclass=abc.ABCMeta):
@abc.abstractmethod
def get_native_ioloop(self): ...
@abc.abstractmethod
def close(self): ...
@abc.abstractmethod
def run(self): ...
@abc.abstractmethod
def stop(self): ...
@abc.abstractmethod
def add_callback_threadsafe(self, callback): ...
@abc.abstractmethod
def call_later(self, delay, callback): ...
@abc.abstractmethod
def getaddrinfo(self, host, port, on_done, family: int = ..., socktype: int = ..., proto: int = ..., flags: int = ...): ...
@abc.abstractmethod
def connect_socket(self, sock, resolved_addr, on_done): ...
@abc.abstractmethod
def create_streaming_connection(
self, protocol_factory, sock, on_done, ssl_context: Incomplete | None = ..., server_hostname: Incomplete | None = ...
): ...
class AbstractFileDescriptorServices(pika.compat.AbstractBase, metaclass=abc.ABCMeta):
@abc.abstractmethod
def set_reader(self, fd, on_readable): ...
@abc.abstractmethod
def remove_reader(self, fd): ...
@abc.abstractmethod
def set_writer(self, fd, on_writable): ...
@abc.abstractmethod
def remove_writer(self, fd): ...
class AbstractTimerReference(pika.compat.AbstractBase, metaclass=abc.ABCMeta):
@abc.abstractmethod
def cancel(self): ...
class AbstractIOReference(pika.compat.AbstractBase, metaclass=abc.ABCMeta):
@abc.abstractmethod
def cancel(self): ...
class AbstractStreamProtocol(pika.compat.AbstractBase, metaclass=abc.ABCMeta):
@abc.abstractmethod
def connection_made(self, transport): ...
@abc.abstractmethod
def connection_lost(self, error): ...
@abc.abstractmethod
def eof_received(self): ...
@abc.abstractmethod
def data_received(self, data): ...
class AbstractStreamTransport(pika.compat.AbstractBase, metaclass=abc.ABCMeta):
@abc.abstractmethod
def abort(self): ...
@abc.abstractmethod
def get_protocol(self): ...
@abc.abstractmethod
def write(self, data): ...
@abc.abstractmethod
def get_write_buffer_size(self): ...

76
stubs/pika/pika/adapters/utils/selector_ioloop_adapter.pyi Normal file
View File

@@ -0,0 +1,76 @@
import abc
from _typeshed import Incomplete
from pika.adapters.utils import io_services_utils, nbio_interface
LOGGER: Incomplete
class AbstractSelectorIOLoop(metaclass=abc.ABCMeta):
@property
@abc.abstractmethod
def READ(self): ...
@property
@abc.abstractmethod
def WRITE(self): ...
@property
@abc.abstractmethod
def ERROR(self): ...
@abc.abstractmethod
def close(self): ...
@abc.abstractmethod
def start(self): ...
@abc.abstractmethod
def stop(self): ...
@abc.abstractmethod
def call_later(self, delay, callback): ...
@abc.abstractmethod
def remove_timeout(self, timeout_handle): ...
@abc.abstractmethod
def add_callback(self, callback): ...
@abc.abstractmethod
def add_handler(self, fd, handler, events): ...
@abc.abstractmethod
def update_handler(self, fd, events): ...
@abc.abstractmethod
def remove_handler(self, fd): ...
class SelectorIOServicesAdapter(
io_services_utils.SocketConnectionMixin,
io_services_utils.StreamingConnectionMixin,
nbio_interface.AbstractIOServices,
nbio_interface.AbstractFileDescriptorServices,
):
def __init__(self, native_loop) -> None: ...
def get_native_ioloop(self): ...
def close(self) -> None: ...
def run(self) -> None: ...
def stop(self) -> None: ...
def add_callback_threadsafe(self, callback) -> None: ...
def call_later(self, delay, callback): ...
def getaddrinfo(self, host, port, on_done, family: int = ..., socktype: int = ..., proto: int = ..., flags: int = ...): ...
def set_reader(self, fd, on_readable) -> None: ...
def remove_reader(self, fd): ...
def set_writer(self, fd, on_writable) -> None: ...
def remove_writer(self, fd): ...
class _FileDescriptorCallbacks:
reader: Incomplete
writer: Incomplete
def __init__(self, reader: Incomplete | None = ..., writer: Incomplete | None = ...) -> None: ...
class _TimerHandle(nbio_interface.AbstractTimerReference):
def __init__(self, handle, loop) -> None: ...
def cancel(self) -> None: ...
class _SelectorIOLoopIOHandle(nbio_interface.AbstractIOReference):
def __init__(self, subject) -> None: ...
def cancel(self): ...
class _AddressResolver:
NOT_STARTED: int
ACTIVE: int
CANCELED: int
COMPLETED: int
def __init__(self, native_loop, host, port, family, socktype, proto, flags, on_done) -> None: ...
def start(self): ...
def cancel(self): ...

15
stubs/pika/pika/amqp_object.pyi Normal file
View File

@@ -0,0 +1,15 @@
from typing import ClassVar
class AMQPObject:
NAME: ClassVar[str]
INDEX: ClassVar[int | None]
def __eq__(self, other: AMQPObject | None) -> bool: ... # type: ignore[override]
class Class(AMQPObject): ...
class Method(AMQPObject):
synchronous: ClassVar[bool]
def get_properties(self) -> Properties: ...
def get_body(self) -> str: ...
class Properties(AMQPObject): ...

31
stubs/pika/pika/callback.pyi Normal file
View File

@@ -0,0 +1,31 @@
from _typeshed import Incomplete
LOGGER: Incomplete
def name_or_value(value): ...
def sanitize_prefix(function): ...
def check_for_prefix_and_key(function): ...
class CallbackManager:
CALLS: str
ARGUMENTS: str
DUPLICATE_WARNING: str
CALLBACK: str
ONE_SHOT: str
ONLY_CALLER: str
def __init__(self) -> None: ...
def add(
self,
prefix,
key,
callback,
one_shot: bool = ...,
only_caller: Incomplete | None = ...,
arguments: Incomplete | None = ...,
): ...
def clear(self) -> None: ...
def cleanup(self, prefix): ...
def pending(self, prefix, key): ...
def process(self, prefix, key, caller, *args, **keywords): ...
def remove(self, prefix, key, callback_value: Incomplete | None = ..., arguments: Incomplete | None = ...): ...
def remove_all(self, prefix, key) -> None: ...

113
stubs/pika/pika/channel.pyi Normal file
View File

@@ -0,0 +1,113 @@
from _typeshed import Incomplete
LOGGER: Incomplete
MAX_CHANNELS: int
class Channel:
CLOSED: int
OPENING: int
OPEN: int
CLOSING: int
channel_number: Incomplete
callbacks: Incomplete
connection: Incomplete
flow_active: bool
def __init__(self, connection, channel_number, on_open_callback) -> None: ...
def __int__(self) -> int: ...
def add_callback(self, callback, replies, one_shot: bool = ...) -> None: ...
def add_on_cancel_callback(self, callback) -> None: ...
def add_on_close_callback(self, callback) -> None: ...
def add_on_flow_callback(self, callback) -> None: ...
def add_on_return_callback(self, callback) -> None: ...
def basic_ack(self, delivery_tag: int = ..., multiple: bool = ...): ...
def basic_cancel(self, consumer_tag: str = ..., callback: Incomplete | None = ...) -> None: ...
def basic_consume(
self,
queue,
on_message_callback,
auto_ack: bool = ...,
exclusive: bool = ...,
consumer_tag: Incomplete | None = ...,
arguments: Incomplete | None = ...,
callback: Incomplete | None = ...,
): ...
def basic_get(self, queue, callback, auto_ack: bool = ...) -> None: ...
def basic_nack(self, delivery_tag: int = ..., multiple: bool = ..., requeue: bool = ...): ...
def basic_publish(self, exchange, routing_key, body, properties: Incomplete | None = ..., mandatory: bool = ...) -> None: ...
def basic_qos(
self, prefetch_size: int = ..., prefetch_count: int = ..., global_qos: bool = ..., callback: Incomplete | None = ...
): ...
def basic_reject(self, delivery_tag: int = ..., requeue: bool = ...): ...
def basic_recover(self, requeue: bool = ..., callback: Incomplete | None = ...): ...
def close(self, reply_code: int = ..., reply_text: str = ...) -> None: ...
def confirm_delivery(self, ack_nack_callback, callback: Incomplete | None = ...) -> None: ...
@property
def consumer_tags(self): ...
def exchange_bind(
self, destination, source, routing_key: str = ..., arguments: Incomplete | None = ..., callback: Incomplete | None = ...
): ...
def exchange_declare(
self,
exchange,
exchange_type=...,
passive: bool = ...,
durable: bool = ...,
auto_delete: bool = ...,
internal: bool = ...,
arguments: Incomplete | None = ...,
callback: Incomplete | None = ...,
): ...
def exchange_delete(self, exchange: Incomplete | None = ..., if_unused: bool = ..., callback: Incomplete | None = ...): ...
def exchange_unbind(
self,
destination: Incomplete | None = ...,
source: Incomplete | None = ...,
routing_key: str = ...,
arguments: Incomplete | None = ...,
callback: Incomplete | None = ...,
): ...
def flow(self, active, callback: Incomplete | None = ...) -> None: ...
@property
def is_closed(self): ...
@property
def is_closing(self): ...
@property
def is_open(self): ...
@property
def is_opening(self): ...
def open(self) -> None: ...
def queue_bind(
self,
queue,
exchange,
routing_key: Incomplete | None = ...,
arguments: Incomplete | None = ...,
callback: Incomplete | None = ...,
): ...
def queue_declare(
self,
queue,
passive: bool = ...,
durable: bool = ...,
exclusive: bool = ...,
auto_delete: bool = ...,
arguments: Incomplete | None = ...,
callback: Incomplete | None = ...,
): ...
def queue_delete(self, queue, if_unused: bool = ..., if_empty: bool = ..., callback: Incomplete | None = ...): ...
def queue_purge(self, queue, callback: Incomplete | None = ...): ...
def queue_unbind(
self,
queue,
exchange: Incomplete | None = ...,
routing_key: Incomplete | None = ...,
arguments: Incomplete | None = ...,
callback: Incomplete | None = ...,
): ...
def tx_commit(self, callback: Incomplete | None = ...): ...
def tx_rollback(self, callback: Incomplete | None = ...): ...
def tx_select(self, callback: Incomplete | None = ...): ...
class ContentFrameAssembler:
def __init__(self) -> None: ...
def process(self, frame_value): ...

44
stubs/pika/pika/compat.pyi Normal file
View File

@@ -0,0 +1,44 @@
from abc import ABCMeta
from io import StringIO as StringIO
from re import Pattern
from typing_extensions import Final, Literal
from urllib.parse import parse_qs, quote, unquote, urlencode as urlencode, urlparse as urlparse
url_quote = quote
url_unquote = unquote
url_parse_qs = parse_qs
PY2: Final[Literal[False]]
PY3: Final[Literal[True]]
RE_NUM: Final[Pattern[str]]
ON_LINUX: Final[bool]
ON_OSX: Final[bool]
ON_WINDOWS: Final[bool]
class AbstractBase(metaclass=ABCMeta): ...
SOCKET_ERROR = OSError
SOL_TCP: Final[int]
basestring: Final[tuple[type[str]]]
str_or_bytes: Final[tuple[type[str], type[bytes]]]
xrange = range
unicode_type = str
def time_now(): ...
def dictkeys(dct): ...
def dictvalues(dct): ...
def dict_iteritems(dct): ...
def dict_itervalues(dct): ...
def byte(*args): ...
class long(int): ...
def canonical_str(value): ...
def is_integer(value): ...
def as_bytes(value): ...
def to_digit(value): ...
def get_linux_version(release_str: str) -> tuple[int, int, int]: ...
HAVE_SIGNAL: Final[bool]
EINTR_IS_EXPOSED: Final[Literal[False]]
LINUX_VERSION: tuple[int, int, int] | None

196
stubs/pika/pika/connection.pyi Normal file
View File

@@ -0,0 +1,196 @@
import abc
from _typeshed import Incomplete
from pika.compat import AbstractBase
PRODUCT: str
LOGGER: Incomplete
class Parameters:
DEFAULT_USERNAME: str
DEFAULT_PASSWORD: str
DEFAULT_BLOCKED_CONNECTION_TIMEOUT: Incomplete
DEFAULT_CHANNEL_MAX: Incomplete
DEFAULT_CLIENT_PROPERTIES: Incomplete
DEFAULT_CREDENTIALS: Incomplete
DEFAULT_CONNECTION_ATTEMPTS: int
DEFAULT_FRAME_MAX: Incomplete
DEFAULT_HEARTBEAT_TIMEOUT: Incomplete
DEFAULT_HOST: str
DEFAULT_LOCALE: str
DEFAULT_PORT: int
DEFAULT_RETRY_DELAY: float
DEFAULT_SOCKET_TIMEOUT: float
DEFAULT_STACK_TIMEOUT: float
DEFAULT_SSL: bool
DEFAULT_SSL_OPTIONS: Incomplete
DEFAULT_SSL_PORT: int
DEFAULT_VIRTUAL_HOST: str
DEFAULT_TCP_OPTIONS: Incomplete
def __init__(self) -> None: ...
def __eq__(self, other): ...
def __ne__(self, other): ...
@property
def blocked_connection_timeout(self): ...
@blocked_connection_timeout.setter
def blocked_connection_timeout(self, value) -> None: ...
@property
def channel_max(self): ...
@channel_max.setter
def channel_max(self, value) -> None: ...
@property
def client_properties(self): ...
@client_properties.setter
def client_properties(self, value) -> None: ...
@property
def connection_attempts(self): ...
@connection_attempts.setter
def connection_attempts(self, value) -> None: ...
@property
def credentials(self): ...
@credentials.setter
def credentials(self, value) -> None: ...
@property
def frame_max(self): ...
@frame_max.setter
def frame_max(self, value) -> None: ...
@property
def heartbeat(self): ...
@heartbeat.setter
def heartbeat(self, value) -> None: ...
@property
def host(self): ...
@host.setter
def host(self, value) -> None: ...
@property
def locale(self): ...
@locale.setter
def locale(self, value) -> None: ...
@property
def port(self): ...
@port.setter
def port(self, value) -> None: ...
@property
def retry_delay(self): ...
@retry_delay.setter
def retry_delay(self, value) -> None: ...
@property
def socket_timeout(self): ...
@socket_timeout.setter
def socket_timeout(self, value) -> None: ...
@property
def stack_timeout(self): ...
@stack_timeout.setter
def stack_timeout(self, value) -> None: ...
@property
def ssl_options(self): ...
@ssl_options.setter
def ssl_options(self, value) -> None: ...
@property
def virtual_host(self): ...
@virtual_host.setter
def virtual_host(self, value) -> None: ...
@property
def tcp_options(self): ...
@tcp_options.setter
def tcp_options(self, value) -> None: ...
class ConnectionParameters(Parameters):
class _DEFAULT: ...
blocked_connection_timeout: Incomplete
channel_max: Incomplete
client_properties: Incomplete
connection_attempts: Incomplete
credentials: Incomplete
frame_max: Incomplete
heartbeat: Incomplete
host: Incomplete
locale: Incomplete
retry_delay: Incomplete
socket_timeout: Incomplete
stack_timeout: Incomplete
ssl_options: Incomplete
port: Incomplete
virtual_host: Incomplete
tcp_options: Incomplete
def __init__(
self,
host=...,
port=...,
virtual_host=...,
credentials=...,
channel_max=...,
frame_max=...,
heartbeat=...,
ssl_options=...,
connection_attempts=...,
retry_delay=...,
socket_timeout=...,
stack_timeout=...,
locale=...,
blocked_connection_timeout=...,
client_properties=...,
tcp_options=...,
**kwargs,
) -> None: ...
class URLParameters(Parameters):
ssl_options: Incomplete
host: Incomplete
port: Incomplete
credentials: Incomplete
virtual_host: Incomplete
def __init__(self, url) -> None: ...
class SSLOptions:
context: Incomplete
server_hostname: Incomplete
def __init__(self, context, server_hostname: Incomplete | None = ...) -> None: ...
class Connection(AbstractBase, metaclass=abc.ABCMeta):
ON_CONNECTION_CLOSED: str
ON_CONNECTION_ERROR: str
ON_CONNECTION_OPEN_OK: str
CONNECTION_CLOSED: int
CONNECTION_INIT: int
CONNECTION_PROTOCOL: int
CONNECTION_START: int
CONNECTION_TUNE: int
CONNECTION_OPEN: int
CONNECTION_CLOSING: int
connection_state: Incomplete
params: Incomplete
callbacks: Incomplete
server_capabilities: Incomplete
server_properties: Incomplete
known_hosts: Incomplete
def __init__(
self,
parameters: Incomplete | None = ...,
on_open_callback: Incomplete | None = ...,
on_open_error_callback: Incomplete | None = ...,
on_close_callback: Incomplete | None = ...,
internal_connection_workflow: bool = ...,
) -> None: ...
def add_on_close_callback(self, callback) -> None: ...
def add_on_connection_blocked_callback(self, callback) -> None: ...
def add_on_connection_unblocked_callback(self, callback) -> None: ...
def add_on_open_callback(self, callback) -> None: ...
def add_on_open_error_callback(self, callback, remove_default: bool = ...) -> None: ...
def channel(self, channel_number: Incomplete | None = ..., on_open_callback: Incomplete | None = ...): ...
def update_secret(self, new_secret, reason, callback: Incomplete | None = ...) -> None: ...
def close(self, reply_code: int = ..., reply_text: str = ...) -> None: ...
@property
def is_closed(self): ...
@property
def is_closing(self): ...
@property
def is_open(self): ...
@property
def basic_nack(self): ...
@property
def consumer_cancel_notify(self): ...
@property
def exchange_exchange_bindings(self): ...
@property
def publisher_confirms(self): ...

25
stubs/pika/pika/credentials.pyi Normal file
View File

@@ -0,0 +1,25 @@
from _typeshed import Incomplete
LOGGER: Incomplete
class PlainCredentials:
TYPE: str
username: Incomplete
password: Incomplete
erase_on_connect: Incomplete
def __init__(self, username, password, erase_on_connect: bool = ...) -> None: ...
def __eq__(self, other): ...
def __ne__(self, other): ...
def response_for(self, start): ...
def erase_credentials(self) -> None: ...
class ExternalCredentials:
TYPE: str
erase_on_connect: bool
def __init__(self) -> None: ...
def __eq__(self, other): ...
def __ne__(self, other): ...
def response_for(self, start): ...
def erase_credentials(self) -> None: ...
VALID_TYPES: Incomplete

6
stubs/pika/pika/data.pyi Normal file
View File

@@ -0,0 +1,6 @@
def encode_short_string(pieces, value): ...
def decode_short_string(encoded, offset): ...
def encode_table(pieces, table): ...
def encode_value(pieces, value): ...
def decode_table(encoded, offset): ...
def decode_value(encoded, offset): ...

5
stubs/pika/pika/delivery_mode.pyi Normal file
View File

@@ -0,0 +1,5 @@
from enum import Enum
class DeliveryMode(Enum):
Transient: int
Persistent: int

1
stubs/pika/pika/diagnostic_utils.pyi Normal file
View File

@@ -0,0 +1 @@
def create_log_exception_decorator(logger): ...

60
stubs/pika/pika/exceptions.pyi Normal file
View File

@@ -0,0 +1,60 @@
from _typeshed import Incomplete
class AMQPError(Exception): ...
class AMQPConnectionError(AMQPError): ...
class ConnectionOpenAborted(AMQPConnectionError): ...
class StreamLostError(AMQPConnectionError): ...
class IncompatibleProtocolError(AMQPConnectionError): ...
class AuthenticationError(AMQPConnectionError): ...
class ProbableAuthenticationError(AMQPConnectionError): ...
class ProbableAccessDeniedError(AMQPConnectionError): ...
class NoFreeChannels(AMQPConnectionError): ...
class ConnectionWrongStateError(AMQPConnectionError): ...
class ConnectionClosed(AMQPConnectionError):
def __init__(self, reply_code, reply_text) -> None: ...
@property
def reply_code(self): ...
@property
def reply_text(self): ...
class ConnectionClosedByBroker(ConnectionClosed): ...
class ConnectionClosedByClient(ConnectionClosed): ...
class ConnectionBlockedTimeout(AMQPConnectionError): ...
class AMQPHeartbeatTimeout(AMQPConnectionError): ...
class AMQPChannelError(AMQPError): ...
class ChannelWrongStateError(AMQPChannelError): ...
class ChannelClosed(AMQPChannelError):
def __init__(self, reply_code, reply_text) -> None: ...
@property
def reply_code(self): ...
@property
def reply_text(self): ...
class ChannelClosedByBroker(ChannelClosed): ...
class ChannelClosedByClient(ChannelClosed): ...
class DuplicateConsumerTag(AMQPChannelError): ...
class ConsumerCancelled(AMQPChannelError): ...
class UnroutableError(AMQPChannelError):
messages: Incomplete
def __init__(self, messages) -> None: ...
class NackError(AMQPChannelError):
messages: Incomplete
def __init__(self, messages) -> None: ...
class InvalidChannelNumber(AMQPError): ...
class ProtocolSyntaxError(AMQPError): ...
class UnexpectedFrameError(ProtocolSyntaxError): ...
class ProtocolVersionMismatch(ProtocolSyntaxError): ...
class BodyTooLongError(ProtocolSyntaxError): ...
class InvalidFrameError(ProtocolSyntaxError): ...
class InvalidFieldTypeException(ProtocolSyntaxError): ...
class UnsupportedAMQPFieldException(ProtocolSyntaxError): ...
class MethodNotImplemented(AMQPError): ...
class ChannelError(Exception): ...
class ReentrancyError(Exception): ...
class ShortStringTooLong(AMQPError): ...
class DuplicateGetOkCallback(ChannelError): ...

7
stubs/pika/pika/exchange_type.pyi Normal file
View File

@@ -0,0 +1,7 @@
from enum import Enum
class ExchangeType(Enum):
direct: str
fanout: str
headers: str
topic: str

43
stubs/pika/pika/frame.pyi Normal file
View File

@@ -0,0 +1,43 @@
from _typeshed import Incomplete
from pika.amqp_object import AMQPObject
LOGGER: Incomplete
class Frame(AMQPObject):
frame_type: Incomplete
channel_number: Incomplete
def __init__(self, frame_type, channel_number) -> None: ...
def marshal(self) -> None: ...
class Method(Frame):
method: Incomplete
def __init__(self, channel_number, method) -> None: ...
def marshal(self): ...
class Header(Frame):
body_size: Incomplete
properties: Incomplete
def __init__(self, channel_number, body_size, props) -> None: ...
def marshal(self): ...
class Body(Frame):
fragment: Incomplete
def __init__(self, channel_number, fragment) -> None: ...
def marshal(self): ...
class Heartbeat(Frame):
def __init__(self) -> None: ...
def marshal(self): ...
class ProtocolHeader(AMQPObject):
frame_type: int
major: Incomplete
minor: Incomplete
revision: Incomplete
def __init__(
self, major: Incomplete | None = ..., minor: Incomplete | None = ..., revision: Incomplete | None = ...
) -> None: ...
def marshal(self): ...
def decode_frame(data_in): ...

12
stubs/pika/pika/heartbeat.pyi Normal file
View File

@@ -0,0 +1,12 @@
from _typeshed import Incomplete
LOGGER: Incomplete
class HeartbeatChecker:
def __init__(self, connection, timeout) -> None: ...
@property
def bytes_received_on_connection(self): ...
@property
def connection_is_idle(self): ...
def received(self) -> None: ...
def stop(self) -> None: ...

922
stubs/pika/pika/spec.pyi Normal file
View File

@@ -0,0 +1,922 @@
from _typeshed import Incomplete
from typing import ClassVar
from typing_extensions import TypeAlias
from .amqp_object import Class, Method, Properties
# Ouch. Since str = bytes at runtime, we need a type alias for "str".
_str: TypeAlias = str # noqa: Y042
str = bytes
PROTOCOL_VERSION: Incomplete
PORT: int
ACCESS_REFUSED: int
CHANNEL_ERROR: int
COMMAND_INVALID: int
CONNECTION_FORCED: int
CONTENT_TOO_LARGE: int
FRAME_BODY: int
FRAME_END: int
FRAME_END_SIZE: int
FRAME_ERROR: int
FRAME_HEADER: int
FRAME_HEADER_SIZE: int
FRAME_HEARTBEAT: int
FRAME_MAX_SIZE: int
FRAME_METHOD: int
FRAME_MIN_SIZE: int
INTERNAL_ERROR: int
INVALID_PATH: int
NOT_ALLOWED: int
NOT_FOUND: int
NOT_IMPLEMENTED: int
NO_CONSUMERS: int
NO_ROUTE: int
PERSISTENT_DELIVERY_MODE: int
PRECONDITION_FAILED: int
REPLY_SUCCESS: int
RESOURCE_ERROR: int
RESOURCE_LOCKED: int
SYNTAX_ERROR: int
TRANSIENT_DELIVERY_MODE: int
UNEXPECTED_FRAME: int
class Connection(Class):
INDEX: ClassVar[int]
class Start(Method):
INDEX: ClassVar[int]
version_major: Incomplete
version_minor: Incomplete
server_properties: Incomplete
mechanisms: Incomplete
locales: Incomplete
def __init__(
self,
version_major: int = ...,
version_minor: int = ...,
server_properties: Incomplete | None = ...,
mechanisms: _str = ...,
locales: _str = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class StartOk(Method):
INDEX: ClassVar[int]
client_properties: Incomplete
mechanism: Incomplete
response: Incomplete
locale: Incomplete
def __init__(
self,
client_properties: Incomplete | None = ...,
mechanism: _str = ...,
response: Incomplete | None = ...,
locale: _str = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Secure(Method):
INDEX: ClassVar[int]
challenge: Incomplete
def __init__(self, challenge: Incomplete | None = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class SecureOk(Method):
INDEX: ClassVar[int]
response: Incomplete
def __init__(self, response: Incomplete | None = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Tune(Method):
INDEX: ClassVar[int]
channel_max: Incomplete
frame_max: Incomplete
heartbeat: Incomplete
def __init__(self, channel_max: int = ..., frame_max: int = ..., heartbeat: int = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class TuneOk(Method):
INDEX: ClassVar[int]
channel_max: Incomplete
frame_max: Incomplete
heartbeat: Incomplete
def __init__(self, channel_max: int = ..., frame_max: int = ..., heartbeat: int = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Open(Method):
INDEX: ClassVar[int]
virtual_host: Incomplete
capabilities: Incomplete
insist: Incomplete
def __init__(self, virtual_host: _str = ..., capabilities: _str = ..., insist: bool = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class OpenOk(Method):
INDEX: ClassVar[int]
known_hosts: Incomplete
def __init__(self, known_hosts: _str = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Close(Method):
INDEX: ClassVar[int]
reply_code: Incomplete
reply_text: Incomplete
class_id: Incomplete
method_id: Incomplete
def __init__(
self,
reply_code: Incomplete | None = ...,
reply_text: _str = ...,
class_id: Incomplete | None = ...,
method_id: Incomplete | None = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class CloseOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Blocked(Method):
INDEX: ClassVar[int]
reason: Incomplete
def __init__(self, reason: _str = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Unblocked(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class UpdateSecret(Method):
INDEX: ClassVar[int]
new_secret: Incomplete
reason: Incomplete
def __init__(self, new_secret, reason) -> None: ...
@property
def synchronous(self): ...
mechanisms: Incomplete
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class UpdateSecretOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Channel(Class):
INDEX: ClassVar[int]
class Open(Method):
INDEX: ClassVar[int]
out_of_band: Incomplete
def __init__(self, out_of_band: _str = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class OpenOk(Method):
INDEX: ClassVar[int]
channel_id: Incomplete
def __init__(self, channel_id: _str = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Flow(Method):
INDEX: ClassVar[int]
active: Incomplete
def __init__(self, active: Incomplete | None = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class FlowOk(Method):
INDEX: ClassVar[int]
active: Incomplete
def __init__(self, active: Incomplete | None = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Close(Method):
INDEX: ClassVar[int]
reply_code: Incomplete
reply_text: Incomplete
class_id: Incomplete
method_id: Incomplete
def __init__(
self,
reply_code: Incomplete | None = ...,
reply_text: _str = ...,
class_id: Incomplete | None = ...,
method_id: Incomplete | None = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class CloseOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Access(Class):
INDEX: ClassVar[int]
class Request(Method):
INDEX: ClassVar[int]
realm: Incomplete
exclusive: Incomplete
passive: Incomplete
active: Incomplete
write: Incomplete
read: Incomplete
def __init__(
self,
realm: _str = ...,
exclusive: bool = ...,
passive: bool = ...,
active: bool = ...,
write: bool = ...,
read: bool = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class RequestOk(Method):
INDEX: ClassVar[int]
ticket: Incomplete
def __init__(self, ticket: int = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Exchange(Class):
INDEX: ClassVar[int]
class Declare(Method):
INDEX: ClassVar[int]
ticket: Incomplete
exchange: Incomplete
type: Incomplete
passive: Incomplete
durable: Incomplete
auto_delete: Incomplete
internal: Incomplete
nowait: Incomplete
arguments: Incomplete
def __init__(
self,
ticket: int = ...,
exchange: Incomplete | None = ...,
type=...,
passive: bool = ...,
durable: bool = ...,
auto_delete: bool = ...,
internal: bool = ...,
nowait: bool = ...,
arguments: Incomplete | None = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class DeclareOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Delete(Method):
INDEX: ClassVar[int]
ticket: Incomplete
exchange: Incomplete
if_unused: Incomplete
nowait: Incomplete
def __init__(
self, ticket: int = ..., exchange: Incomplete | None = ..., if_unused: bool = ..., nowait: bool = ...
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class DeleteOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Bind(Method):
INDEX: ClassVar[int]
ticket: int
destination: Incomplete | None
source: Incomplete | None
routing_key: _str
nowait: bool
arguments: Incomplete | None
def __init__(
self,
ticket: int = ...,
destination: Incomplete | None = ...,
source: Incomplete | None = ...,
routing_key: _str = ...,
nowait: bool = ...,
arguments: Incomplete | None = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class BindOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Unbind(Method):
INDEX: ClassVar[int]
ticket: Incomplete
destination: Incomplete
source: Incomplete
routing_key: Incomplete
nowait: Incomplete
arguments: Incomplete
def __init__(
self,
ticket: int = ...,
destination: Incomplete | None = ...,
source: Incomplete | None = ...,
routing_key: _str = ...,
nowait: bool = ...,
arguments: Incomplete | None = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class UnbindOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Queue(Class):
INDEX: ClassVar[int]
class Declare(Method):
INDEX: ClassVar[int]
ticket: Incomplete
queue: Incomplete
passive: Incomplete
durable: Incomplete
exclusive: Incomplete
auto_delete: Incomplete
nowait: Incomplete
arguments: Incomplete
def __init__(
self,
ticket: int = ...,
queue: _str = ...,
passive: bool = ...,
durable: bool = ...,
exclusive: bool = ...,
auto_delete: bool = ...,
nowait: bool = ...,
arguments: Incomplete | None = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class DeclareOk(Method):
INDEX: ClassVar[int]
queue: Incomplete
message_count: Incomplete
consumer_count: Incomplete
def __init__(
self, queue: Incomplete | None = ..., message_count: Incomplete | None = ..., consumer_count: Incomplete | None = ...
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Bind(Method):
INDEX: ClassVar[int]
ticket: Incomplete
queue: Incomplete
exchange: Incomplete
routing_key: Incomplete
nowait: Incomplete
arguments: Incomplete
def __init__(
self,
ticket: int = ...,
queue: _str = ...,
exchange: Incomplete | None = ...,
routing_key: _str = ...,
nowait: bool = ...,
arguments: Incomplete | None = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class BindOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Purge(Method):
INDEX: ClassVar[int]
ticket: Incomplete
queue: Incomplete
nowait: Incomplete
def __init__(self, ticket: int = ..., queue: _str = ..., nowait: bool = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class PurgeOk(Method):
INDEX: ClassVar[int]
message_count: Incomplete
def __init__(self, message_count: Incomplete | None = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Delete(Method):
INDEX: ClassVar[int]
ticket: Incomplete
queue: Incomplete
if_unused: Incomplete
if_empty: Incomplete
nowait: Incomplete
def __init__(
self, ticket: int = ..., queue: _str = ..., if_unused: bool = ..., if_empty: bool = ..., nowait: bool = ...
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class DeleteOk(Method):
INDEX: ClassVar[int]
message_count: Incomplete
def __init__(self, message_count: Incomplete | None = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Unbind(Method):
INDEX: ClassVar[int]
ticket: Incomplete
queue: Incomplete
exchange: Incomplete
routing_key: Incomplete
arguments: Incomplete
def __init__(
self,
ticket: int = ...,
queue: _str = ...,
exchange: Incomplete | None = ...,
routing_key: _str = ...,
arguments: Incomplete | None = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class UnbindOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Basic(Class):
INDEX: ClassVar[int]
class Qos(Method):
INDEX: ClassVar[int]
prefetch_size: Incomplete
prefetch_count: Incomplete
global_qos: Incomplete
def __init__(self, prefetch_size: int = ..., prefetch_count: int = ..., global_qos: bool = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class QosOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Consume(Method):
INDEX: ClassVar[int]
ticket: Incomplete
queue: Incomplete
consumer_tag: Incomplete
no_local: Incomplete
no_ack: Incomplete
exclusive: Incomplete
nowait: Incomplete
arguments: Incomplete
def __init__(
self,
ticket: int = ...,
queue: _str = ...,
consumer_tag: _str = ...,
no_local: bool = ...,
no_ack: bool = ...,
exclusive: bool = ...,
nowait: bool = ...,
arguments: Incomplete | None = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class ConsumeOk(Method):
INDEX: ClassVar[int]
consumer_tag: Incomplete
def __init__(self, consumer_tag: Incomplete | None = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Cancel(Method):
INDEX: ClassVar[int]
consumer_tag: Incomplete
nowait: Incomplete
def __init__(self, consumer_tag: Incomplete | None = ..., nowait: bool = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class CancelOk(Method):
INDEX: ClassVar[int]
consumer_tag: Incomplete
def __init__(self, consumer_tag: Incomplete | None = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Publish(Method):
INDEX: ClassVar[int]
ticket: Incomplete
exchange: Incomplete
routing_key: Incomplete
mandatory: Incomplete
immediate: Incomplete
def __init__(
self, ticket: int = ..., exchange: _str = ..., routing_key: _str = ..., mandatory: bool = ..., immediate: bool = ...
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Return(Method):
INDEX: ClassVar[int]
reply_code: Incomplete
reply_text: Incomplete
exchange: Incomplete
routing_key: Incomplete
def __init__(
self,
reply_code: Incomplete | None = ...,
reply_text: _str = ...,
exchange: Incomplete | None = ...,
routing_key: Incomplete | None = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Deliver(Method):
INDEX: ClassVar[int]
consumer_tag: Incomplete
delivery_tag: Incomplete
redelivered: Incomplete
exchange: Incomplete
routing_key: Incomplete
def __init__(
self,
consumer_tag: Incomplete | None = ...,
delivery_tag: Incomplete | None = ...,
redelivered: bool = ...,
exchange: Incomplete | None = ...,
routing_key: Incomplete | None = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Get(Method):
INDEX: ClassVar[int]
ticket: Incomplete
queue: Incomplete
no_ack: Incomplete
def __init__(self, ticket: int = ..., queue: _str = ..., no_ack: bool = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class GetOk(Method):
INDEX: ClassVar[int]
delivery_tag: Incomplete
redelivered: Incomplete
exchange: Incomplete
routing_key: Incomplete
message_count: Incomplete
def __init__(
self,
delivery_tag: Incomplete | None = ...,
redelivered: bool = ...,
exchange: Incomplete | None = ...,
routing_key: Incomplete | None = ...,
message_count: Incomplete | None = ...,
) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class GetEmpty(Method):
INDEX: ClassVar[int]
cluster_id: Incomplete
def __init__(self, cluster_id: _str = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Ack(Method):
INDEX: ClassVar[int]
delivery_tag: Incomplete
multiple: Incomplete
def __init__(self, delivery_tag: int = ..., multiple: bool = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Reject(Method):
INDEX: ClassVar[int]
delivery_tag: Incomplete
requeue: Incomplete
def __init__(self, delivery_tag: Incomplete | None = ..., requeue: bool = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class RecoverAsync(Method):
INDEX: ClassVar[int]
requeue: Incomplete
def __init__(self, requeue: bool = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Recover(Method):
INDEX: ClassVar[int]
requeue: Incomplete
def __init__(self, requeue: bool = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class RecoverOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Nack(Method):
INDEX: ClassVar[int]
delivery_tag: Incomplete
multiple: Incomplete
requeue: Incomplete
def __init__(self, delivery_tag: int = ..., multiple: bool = ..., requeue: bool = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Tx(Class):
INDEX: ClassVar[int]
class Select(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class SelectOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Commit(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class CommitOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Rollback(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class RollbackOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class Confirm(Class):
INDEX: ClassVar[int]
class Select(Method):
INDEX: ClassVar[int]
nowait: Incomplete
def __init__(self, nowait: bool = ...) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class SelectOk(Method):
INDEX: ClassVar[int]
def __init__(self) -> None: ...
@property
def synchronous(self): ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
class BasicProperties(Properties):
CLASS: Incomplete
INDEX: ClassVar[int]
FLAG_CONTENT_TYPE: Incomplete
FLAG_CONTENT_ENCODING: Incomplete
FLAG_HEADERS: Incomplete
FLAG_DELIVERY_MODE: Incomplete
FLAG_PRIORITY: Incomplete
FLAG_CORRELATION_ID: Incomplete
FLAG_REPLY_TO: Incomplete
FLAG_EXPIRATION: Incomplete
FLAG_MESSAGE_ID: Incomplete
FLAG_TIMESTAMP: Incomplete
FLAG_TYPE: Incomplete
FLAG_USER_ID: Incomplete
FLAG_APP_ID: Incomplete
FLAG_CLUSTER_ID: Incomplete
content_type: Incomplete
content_encoding: Incomplete
headers: Incomplete
delivery_mode: Incomplete
priority: Incomplete
correlation_id: Incomplete
reply_to: Incomplete
expiration: Incomplete
message_id: Incomplete
timestamp: Incomplete
type: Incomplete
user_id: Incomplete
app_id: Incomplete
cluster_id: Incomplete
def __init__(
self,
content_type: Incomplete | None = ...,
content_encoding: Incomplete | None = ...,
headers: Incomplete | None = ...,
delivery_mode: Incomplete | None = ...,
priority: Incomplete | None = ...,
correlation_id: Incomplete | None = ...,
reply_to: Incomplete | None = ...,
expiration: Incomplete | None = ...,
message_id: Incomplete | None = ...,
timestamp: Incomplete | None = ...,
type: Incomplete | None = ...,
user_id: Incomplete | None = ...,
app_id: Incomplete | None = ...,
cluster_id: Incomplete | None = ...,
) -> None: ...
def decode(self, encoded, offset: int = ...): ...
def encode(self): ...
methods: Incomplete
props: Incomplete
def has_content(methodNumber): ...

6
stubs/pika/pika/tcp_socket_opts.pyi Normal file
View File

@@ -0,0 +1,6 @@
from _typeshed import Incomplete
LOGGER: Incomplete
def socket_requires_keepalive(tcp_options): ...
def set_sock_opts(tcp_options, sock) -> None: ...

4
stubs/pika/pika/validators.pyi Normal file
View File

@@ -0,0 +1,4 @@
def require_string(value, value_name) -> None: ...
def require_callback(callback, callback_name: str = ...) -> None: ...
def rpc_completion_callback(callback): ...
def zero_or_greater(name, value) -> None: ...