perf: optimize async HTTP/2 transport performance

Author: cnzakii

.license-ignore

@@ -13,6 +13,7 @@ NOTICE
 .pre-commit-config.yaml
 .python-version
 uv.lock
+py.typed
 
 
 # directories

docs/CONTRIBUTING.md

@@ -220,12 +220,12 @@ For more details, refer to https://hatch.pypa.io/latest/publish/
 
 > Reference: [Publishing package distribution releases using GitHub Actions CI/CD workflows](https://packaging.python.org/en/latest/guides/publishing-package-distribution-releases-using-github-actions-ci-cd-workflows/)
 
-##### Prerequisites: Configuring Trusted Publishing
+**Prerequisites: Configuring Trusted Publishing**
 
 Follow the **[Configuring Trusted Publishing](https://packaging.python.org/en/latest/guides/publishing-package-distribution-releases-using-github-actions-ci-cd-workflows/#configuring-trusted-publishing)** section of the official guide to ensure that only manually approved workflow runs are permitted to publish to PyPI.
 
 **NOTE**: For security reasons, you must require [manual approval](https://docs.github.com/en/actions/deployment/targeting-different-environments/using-environments-for-deployment#deployment-protection-rules) on each run for the `pypi` environment.
 
-##### Trigger Conditions
+**Trigger Conditions**
 
-The `publish` workflow is triggered whenever a new Release is created in the GitHub repository. It will build the source code corresponding to that Release, upload the resulting artifacts, and then publish the package to PyPI.
+The `publish` workflow is triggered whenever a new Release is published in the GitHub repository. It will build the source code corresponding to that Release, upload the resulting artifacts, and then publish the package to PyPI.

pyproject.toml

@@ -59,6 +59,7 @@ dependencies = [
     "anyio>=4.9.0",
     "h2>=4.1.0",
     "psutil>=6.0.0",
+    "sniffio>=1.3.1",
     "typing-extensions>=4.13.2; python_version < '3.10'",
 ]
 

src/dubbo/bootstrap.py

@@ -334,6 +334,28 @@ def get_method_param_bool(self, method: str, key: str, default: bool = False) ->
         value = self.get_method_param(method, key)
         return value.lower() in _BOOL_TRUE if value else default
 
+    def get_group(self, default: str = "") -> str:
+        """Get the group parameter value.
+
+        Args:
+            default: Default value if 'group' parameter not found
+
+        Returns:
+            Group value if present, else default
+        """
+        return self.get_param(constants.GROUP_KEY, default)
+
+    def get_interface(self, default: str = "") -> str:
+        """Get the service parameter value.
+
+        Args:
+            default: Default value if 'service' parameter not found
+
+        Returns:
+            Service value if present, else default
+        """
+        return self.get_param(constants.INTERFACE_KEY, default)
+
     # ---------------------- Attribute Methods ----------------------
 
     def add_attribute(self, key: str, value: Any) -> None:

src/dubbo/common/_url.py

@@ -21,9 +21,17 @@
 PORT_KEY = "port"
 PATH_KEY = "path"
 
-TIMEOUT_KEY = "timeout"
+INTERFACE_KEY = "interface"
 METHODS_KEY = "methods"
 METHOD_KEY = "method"
+GROUP_KEY = "group"
+VERSION_KEY = "version"
+CATEGORY_KEY = "category"
+
+DYNAMIC_KEY = "dynamic"
+TIMEOUT_KEY = "timeout"
 WEIGHT_KEY = "weight"
 TIMESTAMP_KEY = "timestamp"
 WARMUP_KEY = "warmup"
+
+TOKEN_KEY = "token"

src/dubbo/common/constants/_key.py

@@ -28,9 +28,10 @@
     PRODUCTION_ENVIRONMENT,
 }
 
+DEFAULT_TRI_PORT = 50051
 
-DEFAULT_TIMEOUT_VALUE = 10.0  # units: seconds
-
+DEFAULT_CATEGORY = "providers"
 
+DEFAULT_TIMEOUT_VALUE = 10.0  # units: seconds
 DEFAULT_WEIGHT_VALUE = 100
 DEFAULT_WARMUP_VALUE = 0

src/dubbo/common/constants/_value.py

@@ -36,14 +36,14 @@ def to_bytes(data: StrOrBytes, encoding=constants.UTF_8) -> bytes:
         result = to_bytes("hello")
         result = to_bytes(bytearray(b"data"))
     """
-    if isinstance(data, str):
-        return data.encode(encoding)
     if isinstance(data, bytes):
         return data
     if isinstance(data, bytearray):
         return bytes(data)
     if isinstance(data, memoryview):
         return data.tobytes()
+    if isinstance(data, str):
+        return data.encode(encoding)
 
     raise TypeError(f"Expected str, bytes, bytearray, or memoryview, got {type(data).__name__}")