mirror of
https://github.com/davidhalter/typeshed.git
synced 2025-12-07 20:54:28 +08:00
Remove paho-mqtt stubs (#12552)
This commit is contained in:
sobolevn
@@ -1,3 +0,0 @@
|
||||
version = "1.6.*"
|
||||
upstream_repository = "https://github.com/eclipse/paho.mqtt.python"
|
||||
obsolete_since = "2.0.0" # Released on 2024-02-10
|
||||
@@ -1 +0,0 @@
|
||||
class MQTTException(Exception): ...
|
||||
@@ -1,331 +0,0 @@
|
||||
import logging
|
||||
import socket as _socket
|
||||
import ssl as _ssl
|
||||
import time
|
||||
import types
|
||||
from _typeshed import Incomplete, Unused
|
||||
from collections.abc import Callable
|
||||
from typing import Any, TypeVar
|
||||
from typing_extensions import TypeAlias
|
||||
|
||||
from .matcher import MQTTMatcher as MQTTMatcher
|
||||
from .properties import Properties as Properties
|
||||
from .reasoncodes import ReasonCodes as ReasonCodes
|
||||
from .subscribeoptions import SubscribeOptions as SubscribeOptions
|
||||
|
||||
ssl: types.ModuleType | None
|
||||
socks: types.ModuleType | None
|
||||
time_func = time.monotonic
|
||||
HAVE_DNS: bool
|
||||
EAGAIN: int | Incomplete
|
||||
MQTTv31: int
|
||||
MQTTv311: int
|
||||
MQTTv5: int
|
||||
unicode = str
|
||||
basestring = str
|
||||
CONNECT: int
|
||||
CONNACK: int
|
||||
PUBLISH: int
|
||||
PUBACK: int
|
||||
PUBREC: int
|
||||
PUBREL: int
|
||||
PUBCOMP: int
|
||||
SUBSCRIBE: int
|
||||
SUBACK: int
|
||||
UNSUBSCRIBE: int
|
||||
UNSUBACK: int
|
||||
PINGREQ: int
|
||||
PINGRESP: int
|
||||
DISCONNECT: int
|
||||
AUTH: int
|
||||
MQTT_LOG_INFO: int
|
||||
MQTT_LOG_NOTICE: int
|
||||
MQTT_LOG_WARNING: int
|
||||
MQTT_LOG_ERR: int
|
||||
MQTT_LOG_DEBUG: int
|
||||
LOGGING_LEVEL: dict[int, int]
|
||||
CONNACK_ACCEPTED: int
|
||||
CONNACK_REFUSED_PROTOCOL_VERSION: int
|
||||
CONNACK_REFUSED_IDENTIFIER_REJECTED: int
|
||||
CONNACK_REFUSED_SERVER_UNAVAILABLE: int
|
||||
CONNACK_REFUSED_BAD_USERNAME_PASSWORD: int
|
||||
CONNACK_REFUSED_NOT_AUTHORIZED: int
|
||||
mqtt_cs_new: int
|
||||
mqtt_cs_connected: int
|
||||
mqtt_cs_disconnecting: int
|
||||
mqtt_cs_connect_async: int
|
||||
mqtt_ms_invalid: int
|
||||
mqtt_ms_publish: int
|
||||
mqtt_ms_wait_for_puback: int
|
||||
mqtt_ms_wait_for_pubrec: int
|
||||
mqtt_ms_resend_pubrel: int
|
||||
mqtt_ms_wait_for_pubrel: int
|
||||
mqtt_ms_resend_pubcomp: int
|
||||
mqtt_ms_wait_for_pubcomp: int
|
||||
mqtt_ms_send_pubrec: int
|
||||
mqtt_ms_queued: int
|
||||
MQTT_ERR_AGAIN: int
|
||||
MQTT_ERR_SUCCESS: int
|
||||
MQTT_ERR_NOMEM: int
|
||||
MQTT_ERR_PROTOCOL: int
|
||||
MQTT_ERR_INVAL: int
|
||||
MQTT_ERR_NO_CONN: int
|
||||
MQTT_ERR_CONN_REFUSED: int
|
||||
MQTT_ERR_NOT_FOUND: int
|
||||
MQTT_ERR_CONN_LOST: int
|
||||
MQTT_ERR_TLS: int
|
||||
MQTT_ERR_PAYLOAD_SIZE: int
|
||||
MQTT_ERR_NOT_SUPPORTED: int
|
||||
MQTT_ERR_AUTH: int
|
||||
MQTT_ERR_ACL_DENIED: int
|
||||
MQTT_ERR_UNKNOWN: int
|
||||
MQTT_ERR_ERRNO: int
|
||||
MQTT_ERR_QUEUE_SIZE: int
|
||||
MQTT_ERR_KEEPALIVE: int
|
||||
MQTT_CLIENT: int
|
||||
MQTT_BRIDGE: int
|
||||
MQTT_CLEAN_START_FIRST_ONLY: int
|
||||
sockpair_data: bytes
|
||||
_UserData: TypeAlias = Any
|
||||
_Socket: TypeAlias = _socket.socket | _ssl.SSLSocket | Incomplete
|
||||
_Payload: TypeAlias = str | bytes | bytearray | float
|
||||
_ExtraHeader: TypeAlias = dict[str, str] | Callable[[dict[str, str]], dict[str, str]]
|
||||
_OnLog: TypeAlias = Callable[[Client, _UserData, int, str], object]
|
||||
_OnConnect: TypeAlias = Callable[[Client, _UserData, dict[str, int], int], object]
|
||||
_OnConnectV5: TypeAlias = Callable[[Client, _UserData, dict[str, int], ReasonCodes, Properties | None], object]
|
||||
_TOnConnect = TypeVar("_TOnConnect", _OnConnect, _OnConnectV5)
|
||||
_OnConnectFail: TypeAlias = Callable[[Client, _UserData], object]
|
||||
_OnSubscribe: TypeAlias = Callable[[Client, _UserData, int, tuple[int]], object]
|
||||
_OnSubscribeV5: TypeAlias = Callable[[Client, _UserData, int, list[ReasonCodes], Properties], object]
|
||||
_TOnSubscribe = TypeVar("_TOnSubscribe", _OnSubscribe, _OnSubscribeV5)
|
||||
_OnMessage: TypeAlias = Callable[[Client, _UserData, MQTTMessage], object]
|
||||
_OnPublish: TypeAlias = Callable[[Client, _UserData, int], object]
|
||||
_OnUnsubscribe: TypeAlias = Callable[[Client, _UserData, int], object]
|
||||
_OnUnsubscribeV5: TypeAlias = Callable[[Client, _UserData, int, Properties, list[ReasonCodes] | ReasonCodes], object]
|
||||
_TOnUnsubscribe = TypeVar("_TOnUnsubscribe", _OnUnsubscribe, _OnUnsubscribeV5)
|
||||
_OnDisconnect: TypeAlias = Callable[[Client, _UserData, int], object]
|
||||
_OnDisconnectV5: TypeAlias = Callable[[Client, _UserData, ReasonCodes | None, Properties | None], object]
|
||||
_TOnDisconnect = TypeVar("_TOnDisconnect", _OnDisconnect, _OnDisconnectV5)
|
||||
_OnSocket: TypeAlias = Callable[[Client, _UserData, _Socket | WebsocketWrapper | None], object]
|
||||
|
||||
class WebsocketConnectionError(ValueError): ...
|
||||
|
||||
def error_string(mqtt_errno: int) -> str: ...
|
||||
def connack_string(connack_code: int) -> str: ...
|
||||
def base62(num: int, base: str = ..., padding: int = 1) -> str: ...
|
||||
def topic_matches_sub(sub: str, topic: str) -> bool: ...
|
||||
|
||||
class MQTTMessageInfo:
|
||||
mid: int
|
||||
rc: int
|
||||
def __init__(self, mid: int) -> None: ...
|
||||
def __iter__(self) -> MQTTMessageInfo: ...
|
||||
def __next__(self) -> int: ...
|
||||
def next(self) -> int: ...
|
||||
def __getitem__(self, index: int) -> int: ...
|
||||
def wait_for_publish(self, timeout: float | None = None) -> None: ...
|
||||
def is_published(self) -> bool: ...
|
||||
|
||||
class MQTTMessage:
|
||||
timestamp: int
|
||||
state: int
|
||||
dup: bool
|
||||
mid: int
|
||||
payload: bytes | bytearray
|
||||
qos: int
|
||||
retain: bool
|
||||
info: MQTTMessageInfo
|
||||
properties: Properties | None
|
||||
def __init__(self, mid: int = 0, topic: bytes | bytearray = b"") -> None: ...
|
||||
def __eq__(self, other: object) -> bool: ...
|
||||
def __ne__(self, other: object) -> bool: ...
|
||||
@property
|
||||
def topic(self) -> str: ...
|
||||
@topic.setter
|
||||
def topic(self, value: bytes | bytearray) -> None: ...
|
||||
|
||||
class Client:
|
||||
suppress_exceptions: bool
|
||||
def __init__(
|
||||
self,
|
||||
client_id: str | None = "",
|
||||
clean_session: bool | None = None,
|
||||
userdata: _UserData | None = None,
|
||||
protocol: int = 4,
|
||||
transport: str = "tcp",
|
||||
reconnect_on_failure: bool = True,
|
||||
) -> None: ...
|
||||
def __del__(self) -> None: ...
|
||||
def reinitialise(self, client_id: str = "", clean_session: bool = True, userdata: _UserData | None = None) -> None: ...
|
||||
def ws_set_options(self, path: str = "/mqtt", headers: _ExtraHeader | None = None) -> None: ...
|
||||
def tls_set_context(self, context: _ssl.SSLContext | None = None) -> None: ...
|
||||
def tls_set(
|
||||
self,
|
||||
ca_certs: str | None = None,
|
||||
certfile: str | None = None,
|
||||
keyfile: str | None = None,
|
||||
cert_reqs: _ssl.VerifyMode | None = None,
|
||||
tls_version: _ssl._SSLMethod | None = None,
|
||||
ciphers: str | None = None,
|
||||
keyfile_password: _ssl._PasswordType | None = None,
|
||||
) -> None: ...
|
||||
def tls_insecure_set(self, value: bool) -> None: ...
|
||||
def proxy_set(self, **proxy_args: Any) -> None: ...
|
||||
def enable_logger(self, logger: logging.Logger | None = None) -> None: ...
|
||||
def disable_logger(self) -> None: ...
|
||||
def connect(
|
||||
self,
|
||||
host: str,
|
||||
port: int = 1883,
|
||||
keepalive: int = 60,
|
||||
bind_address: str = "",
|
||||
bind_port: int = 0,
|
||||
clean_start: int = 3,
|
||||
properties: Properties | None = None,
|
||||
) -> int: ...
|
||||
def connect_srv(
|
||||
self,
|
||||
domain: str | None = None,
|
||||
keepalive: int = 60,
|
||||
bind_address: str = "",
|
||||
clean_start: int = 3,
|
||||
properties: Properties | None = None,
|
||||
) -> int: ...
|
||||
def connect_async(
|
||||
self,
|
||||
host: str,
|
||||
port: int = 1883,
|
||||
keepalive: int = 60,
|
||||
bind_address: str = "",
|
||||
bind_port: int = 0,
|
||||
clean_start: int = 3,
|
||||
properties: Properties | None = None,
|
||||
) -> None: ...
|
||||
def reconnect_delay_set(self, min_delay: int = 1, max_delay: int = 120) -> None: ...
|
||||
def reconnect(self) -> int: ...
|
||||
def loop(self, timeout: float = 1.0, max_packets: int = 1) -> int: ...
|
||||
def publish(
|
||||
self,
|
||||
topic: str,
|
||||
payload: _Payload | None = None,
|
||||
qos: int = 0,
|
||||
retain: bool = False,
|
||||
properties: Properties | None = None,
|
||||
) -> MQTTMessageInfo: ...
|
||||
def username_pw_set(self, username: str, password: str | bytes | bytearray | None = None) -> None: ...
|
||||
def enable_bridge_mode(self) -> None: ...
|
||||
def is_connected(self) -> bool: ...
|
||||
def disconnect(self, reasoncode: ReasonCodes | None = None, properties: Properties | None = None) -> int: ...
|
||||
def subscribe(
|
||||
self,
|
||||
topic: str | tuple[str, SubscribeOptions] | list[tuple[str, SubscribeOptions]] | list[tuple[str, int]],
|
||||
qos: int = 0,
|
||||
options: SubscribeOptions | None = None,
|
||||
properties: Properties | None = None,
|
||||
) -> tuple[int, int]: ...
|
||||
def unsubscribe(self, topic: str | list[str], properties: Properties | None = None) -> tuple[int, int]: ...
|
||||
def loop_read(self, max_packets: int = 1) -> int: ...
|
||||
def loop_write(self, max_packets: int = 1) -> int: ...
|
||||
def want_write(self) -> bool: ...
|
||||
def loop_misc(self) -> int: ...
|
||||
def max_inflight_messages_set(self, inflight: int) -> None: ...
|
||||
def max_queued_messages_set(self, queue_size: int) -> Client: ...
|
||||
def message_retry_set(self, retry: Unused) -> None: ...
|
||||
def user_data_set(self, userdata: _UserData) -> None: ...
|
||||
def will_set(
|
||||
self,
|
||||
topic: str,
|
||||
payload: _Payload | None = None,
|
||||
qos: int = 0,
|
||||
retain: bool = False,
|
||||
properties: Properties | None = None,
|
||||
) -> None: ...
|
||||
def will_clear(self) -> None: ...
|
||||
def socket(self) -> _Socket | WebsocketWrapper: ...
|
||||
def loop_forever(self, timeout: float = 1.0, max_packets: int = 1, retry_first_connection: bool = False) -> int: ...
|
||||
def loop_start(self) -> int | None: ...
|
||||
def loop_stop(self, force: bool = False) -> int | None: ...
|
||||
@property
|
||||
def on_log(self) -> _OnLog | None: ...
|
||||
@on_log.setter
|
||||
def on_log(self, func: _OnLog | None) -> None: ...
|
||||
def log_callback(self) -> Callable[[_OnLog], _OnLog]: ...
|
||||
@property
|
||||
def on_connect(self) -> _OnConnect | _OnConnectV5 | None: ...
|
||||
@on_connect.setter
|
||||
def on_connect(self, func: _OnConnect | _OnConnectV5 | None) -> None: ...
|
||||
def connect_callback(self) -> Callable[[_TOnConnect], _TOnConnect]: ...
|
||||
@property
|
||||
def on_connect_fail(self) -> _OnConnectFail | None: ...
|
||||
@on_connect_fail.setter
|
||||
def on_connect_fail(self, func: _OnConnectFail | None) -> None: ...
|
||||
def connect_fail_callback(self) -> Callable[[_OnConnectFail], _OnConnectFail]: ...
|
||||
@property
|
||||
def on_subscribe(self) -> _OnSubscribe | _OnSubscribeV5 | None: ...
|
||||
@on_subscribe.setter
|
||||
def on_subscribe(self, func: _OnSubscribe | _OnSubscribeV5 | None) -> None: ...
|
||||
def subscribe_callback(self) -> Callable[[_TOnSubscribe], _TOnSubscribe]: ...
|
||||
@property
|
||||
def on_message(self) -> _OnMessage | None: ...
|
||||
@on_message.setter
|
||||
def on_message(self, func: _OnMessage | None) -> None: ...
|
||||
def message_callback(self) -> Callable[[_OnMessage], _OnMessage]: ...
|
||||
@property
|
||||
def on_publish(self) -> _OnPublish | None: ...
|
||||
@on_publish.setter
|
||||
def on_publish(self, func: _OnPublish | None) -> None: ...
|
||||
def publish_callback(self) -> Callable[[_OnPublish], _OnPublish]: ...
|
||||
@property
|
||||
def on_unsubscribe(self) -> _OnUnsubscribe | _OnUnsubscribeV5 | None: ...
|
||||
@on_unsubscribe.setter
|
||||
def on_unsubscribe(self, func: _OnUnsubscribe | _OnUnsubscribeV5 | None) -> None: ...
|
||||
def unsubscribe_callback(self) -> Callable[[_TOnUnsubscribe], _TOnUnsubscribe]: ...
|
||||
@property
|
||||
def on_disconnect(self) -> _OnDisconnect | _OnDisconnectV5 | None: ...
|
||||
@on_disconnect.setter
|
||||
def on_disconnect(self, func: _OnDisconnect | _OnDisconnectV5 | None) -> None: ...
|
||||
def disconnect_callback(self) -> Callable[[_TOnDisconnect], _TOnDisconnect]: ...
|
||||
@property
|
||||
def on_socket_open(self) -> _OnSocket | None: ...
|
||||
@on_socket_open.setter
|
||||
def on_socket_open(self, func: _OnSocket | None) -> None: ...
|
||||
def socket_open_callback(self) -> Callable[[_OnSocket], _OnSocket]: ...
|
||||
@property
|
||||
def on_socket_close(self) -> _OnSocket | None: ...
|
||||
@on_socket_close.setter
|
||||
def on_socket_close(self, func: _OnSocket | None) -> None: ...
|
||||
def socket_close_callback(self) -> Callable[[_OnSocket], _OnSocket]: ...
|
||||
@property
|
||||
def on_socket_register_write(self) -> _OnSocket | None: ...
|
||||
@on_socket_register_write.setter
|
||||
def on_socket_register_write(self, func: _OnSocket | None) -> None: ...
|
||||
def socket_register_write_callback(self) -> Callable[[_OnSocket], _OnSocket]: ...
|
||||
@property
|
||||
def on_socket_unregister_write(self) -> _OnSocket | None: ...
|
||||
@on_socket_unregister_write.setter
|
||||
def on_socket_unregister_write(self, func: _OnSocket | None) -> None: ...
|
||||
def socket_unregister_write_callback(self) -> Callable[[_OnSocket], _OnSocket]: ...
|
||||
def message_callback_add(self, sub: str, callback: _OnMessage) -> None: ...
|
||||
def topic_callback(self, sub: str) -> Callable[[_OnMessage], _OnMessage]: ...
|
||||
def message_callback_remove(self, sub: str) -> None: ...
|
||||
|
||||
class WebsocketWrapper:
|
||||
OPCODE_CONTINUATION: int
|
||||
OPCODE_TEXT: int
|
||||
OPCODE_BINARY: int
|
||||
OPCODE_CONNCLOSE: int
|
||||
OPCODE_PING: int
|
||||
OPCODE_PONG: int
|
||||
connected: bool
|
||||
def __init__(
|
||||
self, socket: _Socket, host: str, port: int, is_ssl: bool, path: str, extra_headers: _ExtraHeader | None
|
||||
) -> None: ...
|
||||
def __del__(self) -> None: ...
|
||||
def recv(self, length: int) -> bytes | bytearray | None: ...
|
||||
def read(self, length: int) -> bytes | bytearray | None: ...
|
||||
def send(self, data: bytes | bytearray) -> int: ...
|
||||
def write(self, data: bytes | bytearray) -> int: ...
|
||||
def close(self) -> None: ...
|
||||
def fileno(self) -> int: ...
|
||||
def pending(self) -> int: ...
|
||||
def setblocking(self, flag: bool) -> None: ...
|
||||
@@ -1,11 +0,0 @@
|
||||
from collections.abc import Generator
|
||||
from typing import Any
|
||||
|
||||
class MQTTMatcher:
|
||||
class Node: ...
|
||||
|
||||
def __init__(self) -> None: ...
|
||||
def __setitem__(self, key: str, value: Any) -> None: ...
|
||||
def __getitem__(self, key: str) -> Any: ...
|
||||
def __delitem__(self, key: str) -> None: ...
|
||||
def iter_match(self, topic: str) -> Generator[Any, None, None]: ...
|
||||
@@ -1,19 +0,0 @@
|
||||
class PacketTypes:
|
||||
indexes: range
|
||||
CONNECT: int
|
||||
CONNACK: int
|
||||
PUBLISH: int
|
||||
PUBACK: int
|
||||
PUBREC: int
|
||||
PUBREL: int
|
||||
PUBCOMP: int
|
||||
SUBSCRIBE: int
|
||||
SUBACK: int
|
||||
UNSUBSCRIBE: int
|
||||
UNSUBACK: int
|
||||
PINGREQ: int
|
||||
PINGRESP: int
|
||||
DISCONNECT: int
|
||||
AUTH: int
|
||||
WILLMESSAGE: int
|
||||
Names: list[str]
|
||||
@@ -1,38 +0,0 @@
|
||||
from typing import Any
|
||||
|
||||
from . import MQTTException as MQTTException
|
||||
|
||||
class MalformedPacket(MQTTException): ...
|
||||
|
||||
def writeInt16(length: int) -> bytearray: ...
|
||||
def readInt16(buf: bytes) -> int: ...
|
||||
def writeInt32(length: int) -> bytearray: ...
|
||||
def readInt32(buf: bytes) -> int: ...
|
||||
def writeUTF(data: str | bytes) -> bytearray: ...
|
||||
def readUTF(buffer: bytes, maxlen: int) -> tuple[str, int]: ...
|
||||
def writeBytes(buffer: bytes) -> bytearray: ...
|
||||
def readBytes(buffer: bytes) -> tuple[bytes, int]: ...
|
||||
|
||||
class VariableByteIntegers:
|
||||
@staticmethod
|
||||
def encode(x: int) -> bytes: ...
|
||||
@staticmethod
|
||||
def decode(buffer: bytes) -> tuple[int, int]: ...
|
||||
|
||||
class Properties:
|
||||
packetType: int
|
||||
types: list[str]
|
||||
names: dict[str, int]
|
||||
properties: dict[int, tuple[int, list[int]]]
|
||||
def __init__(self, packetType: int) -> None: ...
|
||||
def allowsMultiple(self, compressedName: str) -> bool: ...
|
||||
def getIdentFromName(self, compressedName: str) -> int: ...
|
||||
def __setattr__(self, name: str, value: Any) -> None: ...
|
||||
def json(self) -> dict[str, Any]: ...
|
||||
def isEmpty(self) -> bool: ...
|
||||
def clear(self) -> None: ...
|
||||
def writeProperty(self, identifier: int, type: int, value: Any) -> bytes: ...
|
||||
def pack(self) -> bytes: ...
|
||||
def readProperty(self, buffer: bytes, type: int, propslen: int) -> Any: ...
|
||||
def getNameFromIdent(self, identifier: int) -> str | None: ...
|
||||
def unpack(self, buffer: bytes) -> tuple[Properties, int]: ...
|
||||
@@ -1,63 +0,0 @@
|
||||
import ssl
|
||||
from collections.abc import Iterable
|
||||
from typing import TypedDict
|
||||
from typing_extensions import NotRequired, TypeAlias
|
||||
|
||||
_Payload: TypeAlias = str | bytes | bytearray | float
|
||||
|
||||
class _Msg(TypedDict):
|
||||
topic: str
|
||||
payload: NotRequired[_Payload | None]
|
||||
qos: NotRequired[int]
|
||||
retain: NotRequired[int]
|
||||
|
||||
class _Auth(TypedDict):
|
||||
username: str
|
||||
password: NotRequired[str]
|
||||
|
||||
class _TLS(TypedDict):
|
||||
ca_certs: str
|
||||
certfile: NotRequired[str]
|
||||
keyfile: NotRequired[str]
|
||||
tls_version: NotRequired[ssl._SSLMethod]
|
||||
ciphers: NotRequired[str]
|
||||
insecure: NotRequired[str]
|
||||
cert_reqs: NotRequired[ssl.VerifyMode]
|
||||
keyfile_password: NotRequired[ssl._PasswordType]
|
||||
|
||||
class _Proxy(TypedDict):
|
||||
proxy_type: int
|
||||
proxy_addr: str
|
||||
proxy_rdns: NotRequired[bool]
|
||||
proxy_username: NotRequired[str]
|
||||
proxy_passwor: NotRequired[str]
|
||||
|
||||
def multiple(
|
||||
msgs: Iterable[_Msg],
|
||||
hostname: str = "localhost",
|
||||
port: int = 1883,
|
||||
client_id: str = "",
|
||||
keepalive: int = 60,
|
||||
will: _Msg | None = None,
|
||||
auth: _Auth | None = None,
|
||||
tls: _TLS | None = None,
|
||||
protocol: int = 4,
|
||||
transport: str = "tcp",
|
||||
proxy_args: _Proxy | None = None,
|
||||
) -> None: ...
|
||||
def single(
|
||||
topic: str,
|
||||
payload: _Payload | None = None,
|
||||
qos: int | None = 0,
|
||||
retain: bool | None = False,
|
||||
hostname: str = "localhost",
|
||||
port: int = 1883,
|
||||
client_id: str = "",
|
||||
keepalive: int = 60,
|
||||
will: _Msg | None = None,
|
||||
auth: _Auth | None = None,
|
||||
tls: _TLS | None = None,
|
||||
protocol: int = 4,
|
||||
transport: str = "tcp",
|
||||
proxy_args: _Proxy | None = None,
|
||||
) -> None: ...
|
||||
@@ -1,13 +0,0 @@
|
||||
class ReasonCodes:
|
||||
packetType: int
|
||||
names: dict[int, dict[str, list[int]]]
|
||||
value: int
|
||||
def __init__(self, packetType: int, aName: str = "Success", identifier: int = -1) -> None: ...
|
||||
def __getName__(self, packetType: int, identifier: int) -> str: ...
|
||||
def getId(self, name: str) -> int: ...
|
||||
def set(self, name: str) -> None: ...
|
||||
def unpack(self, buffer: bytearray) -> int: ...
|
||||
def getName(self) -> str: ...
|
||||
def __eq__(self, other: object) -> bool: ...
|
||||
def json(self) -> str: ...
|
||||
def pack(self) -> bytearray: ...
|
||||
@@ -1,39 +0,0 @@
|
||||
from collections.abc import Callable
|
||||
|
||||
from .client import Client, MQTTMessage, _UserData
|
||||
from .publish import _TLS, _Auth, _Msg, _Proxy
|
||||
|
||||
def callback(
|
||||
callback: Callable[[Client, _UserData, MQTTMessage], None],
|
||||
topics: list[str],
|
||||
qos: int = 0,
|
||||
userdata: _UserData | None = None,
|
||||
hostname: str = "localhost",
|
||||
port: int = 1883,
|
||||
client_id: str = "",
|
||||
keepalive: int = 60,
|
||||
will: _Msg | None = None,
|
||||
auth: _Auth | None = None,
|
||||
tls: _TLS | None = None,
|
||||
protocol: int = 4,
|
||||
transport: str = "tcp",
|
||||
clean_session: bool = True,
|
||||
proxy_args: _Proxy | None = None,
|
||||
) -> None: ...
|
||||
def simple(
|
||||
topics: str | list[str],
|
||||
qos: int = 0,
|
||||
msg_count: int = 1,
|
||||
retained: bool = True,
|
||||
hostname: str = "localhost",
|
||||
port: int = 1883,
|
||||
client_id: str = "",
|
||||
keepalive: int = 60,
|
||||
will: _Msg | None = None,
|
||||
auth: _Auth | None = None,
|
||||
tls: _TLS | None = None,
|
||||
protocol: int = 4,
|
||||
transport: str = "tcp",
|
||||
clean_session: bool = True,
|
||||
proxy_args: _Proxy | None = None,
|
||||
) -> list[MQTTMessage] | MQTTMessage: ...
|
||||
@@ -1,24 +0,0 @@
|
||||
from typing import Any, TypedDict
|
||||
|
||||
from . import MQTTException as MQTTException
|
||||
|
||||
class _SubscribeOptionsJson(TypedDict):
|
||||
QoS: int
|
||||
noLocal: bool
|
||||
retainAsPublished: bool
|
||||
retainHandling: int
|
||||
|
||||
class SubscribeOptions:
|
||||
RETAIN_SEND_ON_SUBSCRIBE: int
|
||||
RETAIN_SEND_IF_NEW_SUB: int
|
||||
RETAIN_DO_NOT_SEND: int
|
||||
names: list[str]
|
||||
Qos: int
|
||||
noLocal: bool
|
||||
retainAsPublished: bool
|
||||
retainHandling: int
|
||||
def __init__(self, qos: int = 0, noLocal: bool = False, retainAsPublished: bool = False, retainHandling: int = 0) -> None: ...
|
||||
def __setattr__(self, name: str, value: Any) -> None: ...
|
||||
def pack(self) -> bytes: ...
|
||||
def unpack(self, buffer: bytes | bytearray) -> int: ...
|
||||
def json(self) -> _SubscribeOptionsJson: ...
|
||||
Reference in New Issue
Block a user