feat: migrate python sdk from grpc to fibp binary protocol

.github/workflows/dev-publish.yml

@@ -20,9 +20,10 @@ jobs:
         run: |
           COMMIT_COUNT=$(git rev-list --count HEAD)
           SHORT_SHA=$(git rev-parse --short HEAD)
-          DEV_VERSION="0.1.dev${COMMIT_COUNT}+g${SHORT_SHA}"
+          DEV_VERSION="0.1.dev${COMMIT_COUNT}"
           sed -i "s/^version = .*/version = \"${DEV_VERSION}\"/" pyproject.toml
-          echo "Publishing version: ${DEV_VERSION}"
+          sed -i "s/^description = .*/description = \"Python client SDK for the Fila message broker (dev build from ${SHORT_SHA})\"/" pyproject.toml
+          echo "Publishing version: ${DEV_VERSION} (${SHORT_SHA})"
       - run: pip install build
       - run: python -m build
       - uses: pypa/gh-action-pypi-publish@release/v1

README.md

@@ -2,6 +2,8 @@
 
 Python client SDK for the [Fila](https://github.com/faiscadev/fila) message broker.
 
+Communicates with the Fila server over the FIBP (Fila Binary Protocol) on port 5555.
+
 ## Installation
 
 ```bash
@@ -102,7 +104,7 @@ client = Client(
 )
 ```
 
-The API key is sent as `authorization: Bearer <key>` metadata on every RPC.
+The API key is sent during the FIBP handshake.
 
 ## API
 
@@ -114,6 +116,10 @@ Connect to a Fila broker. Both support context manager protocol.
 
 Enqueue a message. Returns the broker-assigned message ID.
 
+### `client.enqueue_many(messages) -> list[EnqueueResult]`
+
+Enqueue multiple messages in a single request. Returns per-message results.
+
 ### `client.consume(queue) -> Iterator[ConsumeMessage]`
 
 Open a streaming consumer. Returns an iterator (sync) or async iterator (async) that yields messages as they become available.
@@ -126,12 +132,31 @@ Acknowledge a successfully processed message. The message is permanently removed
 
 Negatively acknowledge a failed message. The message is requeued or routed to the dead-letter queue based on the queue's configuration.
 
+### Admin Methods
+
+- `client.create_queue(name, config=None)` -- Create a queue
+- `client.delete_queue(name)` -- Delete a queue
+- `client.get_stats(queue) -> StatsResult` -- Get queue statistics
+- `client.list_queues() -> list[str]` -- List all queues
+- `client.set_config(queue, config)` -- Set queue configuration
+- `client.get_config(queue) -> dict` -- Get queue configuration
+- `client.list_config(queue) -> dict` -- List queue configuration
+- `client.redrive(source, dest, count)` -- Redrive messages between queues
+
+### Auth Methods
+
+- `client.create_api_key(name) -> CreateApiKeyResult` -- Create an API key
+- `client.revoke_api_key(key_id)` -- Revoke an API key
+- `client.list_api_keys() -> list[ApiKeyInfo]` -- List API keys
+- `client.set_acl(key_id, patterns, superadmin=False)` -- Set ACL
+- `client.get_acl(key_id) -> AclEntry` -- Get ACL
+
 ## Error Handling
 
 Per-operation exception classes:
 
 ```python
-from fila import QueueNotFoundError, MessageNotFoundError
+from fila import QueueNotFoundError, MessageNotFoundError, UnauthorizedError
 
 try:
     client.enqueue("missing-queue", None, b"test")

fila/__init__.py

@@ -1,21 +1,73 @@
-"""Fila — Python client SDK for the Fila message broker."""
+"""Fila -- Python client SDK for the Fila message broker."""
 
 from fila.async_client import AsyncClient
 from fila.client import Client
 from fila.errors import (
+    AclNotFoundError,
+    ApiKeyNotFoundError,
+    ChannelFullError,
+    EnqueueError,
     FilaError,
+    ForbiddenError,
+    InvalidArgumentError,
+    LuaError,
     MessageNotFoundError,
+    NotLeaderError,
+    PermissionDeniedError,
+    ProtocolError,
+    QueueAlreadyExistsError,
     QueueNotFoundError,
+    ResourceExhaustedError,
     RPCError,
+    UnauthorizedError,
+    UnavailableError,
+)
+from fila.types import (
+    AccumulatorMode,
+    AclEntry,
+    AclPermission,
+    ApiKeyInfo,
+    ConsumeMessage,
+    CreateApiKeyResult,
+    EnqueueResult,
+    FairnessKeyStat,
+    Linger,
+    QueueInfo,
+    StatsResult,
+    ThrottleKeyStat,
 )
-from fila.types import ConsumeMessage
 
 __all__ = [
+    "AccumulatorMode",
+    "AclEntry",
+    "AclNotFoundError",
+    "AclPermission",
+    "ApiKeyInfo",
+    "ApiKeyNotFoundError",
     "AsyncClient",
+    "ChannelFullError",
     "Client",
     "ConsumeMessage",
+    "CreateApiKeyResult",
+    "EnqueueError",
+    "EnqueueResult",
+    "FairnessKeyStat",
     "FilaError",
+    "ForbiddenError",
+    "InvalidArgumentError",
+    "Linger",
+    "LuaError",
     "MessageNotFoundError",
+    "NotLeaderError",
+    "PermissionDeniedError",
+    "ProtocolError",
+    "QueueAlreadyExistsError",
+    "QueueInfo",
     "QueueNotFoundError",
     "RPCError",
+    "ResourceExhaustedError",
+    "StatsResult",
+    "ThrottleKeyStat",
+    "UnauthorizedError",
+    "UnavailableError",
 ]