Add v2.5.0

Author: jstabenow

core_client/base/api/v3_cluster_node_fs_put.py

@@ -0,0 +1,62 @@
+import httpx
+from pydantic import TypeAdapter, validate_call
+
+from ...models import Client
+from ..models import Error
+from ..models.v3 import FilesystemOperationOrder
+
+
+@validate_call()
+def _build_request(
+    client: Client,
+    id: str,
+    source: str,
+    target: str,
+    operation: FilesystemOperationOrder,
+    bandwidth_limit_kbit: int = None,
+    retries: int = None,
+    timeout: float = None,
+):
+    data = {
+        "source": source,
+        "operation": operation,
+        "target": target,
+        "bandwidth_limit_kbit": bandwidth_limit_kbit,
+    }
+    if not retries:
+        retries = client.retries
+    if not timeout:
+        timeout = client.timeout
+    return {
+        "method": "put",
+        "url": f"{client.base_url}/api/v3/cluster/node/{id}/fs",
+        "headers": client.headers,
+        "timeout": timeout,
+        "content": None,
+        "json": data,
+    }, retries
+
+
+def _build_response(response: httpx.Response):
+    if response.status_code == 200:
+        response_200 = response.json()
+        return response_200
+    else:
+        response_error = TypeAdapter(Error).validate_python(response.json())
+        return response_error
+
+
+def sync(client: Client, **kwargs):
+    request, retries = _build_request(client, **kwargs)
+    transport = httpx.HTTPTransport(retries=retries)
+    httpx_client = httpx.Client(transport=transport, http2=True)
+    response = httpx_client.request(**request)
+    return _build_response(response=response)
+
+
+async def asyncio(client: Client, **kwargs):
+    request, retries = _build_request(client, **kwargs)
+    transport = httpx.AsyncHTTPTransport(retries=retries)
+    async with httpx.AsyncClient(transport=transport) as httpx_client:
+        response = await httpx_client.request(**request)
+    return _build_response(response=response)

core_client/base/api/v3_iam_put_user_policy.py

@@ -11,7 +11,7 @@
 def _build_request(
     client: Client,
     name: str,
-    config: List[IamUserPolicy],
+    config: list[IamUserPolicy],
     domain: str = "",
     retries: int = None,
     timeout: float = None,
@@ -42,7 +42,7 @@ def _build_request(
 
 def _build_response(response: httpx.Response):
     if response.status_code == 200:
-        response_200 = TypeAdapter(List[IamUserPolicy]).validate_python(response.json())
+        response_200 = TypeAdapter(list[IamUserPolicy]).validate_python(response.json())
         return response_200
     else:
         response_error = TypeAdapter(Error).validate_python(response.json())

core_client/base/api/v3_process_get_report_list.py

@@ -11,8 +11,8 @@
 def _build_request(
     client: Client,
     id: str,
-    created_at: Union[str, int] = "",
-    exited_at: Union[str, int] = "",
+    created_at: str | int = "",
+    exited_at: str | int = "",
     domain: str = "",
     retries: int = None,
     timeout: float = None,

core_client/base/models/about.py

@@ -5,18 +5,18 @@
 
 class AboutVersion(BaseModel):
     number: str
-    repository_commit: Optional[str] = None
-    repository_branch: Optional[str] = None
-    build_date: Optional[Union[datetime, str]] = None
-    arch: Optional[str] = None
-    compiler: Optional[str] = None
+    repository_commit: str | None = None
+    repository_branch: str | None = None
+    build_date: datetime | str | None = None
+    arch: str | None = None
+    compiler: str | None = None
 
 
 class About(BaseModel):
     app: str
-    auths: Optional[List[str]] = None
-    created_at: Optional[datetime] = None
-    id: Optional[str] = None
-    name: Optional[str] = None
-    uptime_seconds: Optional[int] = None
+    auths: list[str] | None = None
+    created_at: datetime | None = None
+    id: str | None = None
+    name: str | None = None
+    uptime_seconds: int | None = None
     version: AboutVersion

core_client/base/models/error.py

@@ -5,4 +5,4 @@
 class Error(BaseModel):
     code: int
     message: str
-    details: List[Any]
+    details: list[Any]

core_client/base/models/login.py

@@ -3,9 +3,9 @@
 
 
 class Token(BaseModel):
-    access_token: Optional[str] = None
-    refresh_token: Optional[str] = None
-    expires_at: Optional[int] = None
+    access_token: str | None = None
+    refresh_token: str | None = None
+    expires_at: int | None = None
 
 
 class AccessToken(BaseModel):

core_client/base/models/v3/cluster.py

@@ -25,14 +25,14 @@ class Cluster(BaseModel):
     """
 
     id: str
-    name: Optional[str] = None
-    leader: Union[bool, ClusterLeader]
-    public_domains: Optional[List[str]] = None
-    address: Optional[str] = None
+    name: str | None = None
+    leader: bool | ClusterLeader
+    public_domains: list[str] | None = None
+    address: str | None = None
     raft: ClusterRaft
     nodes: list[ClusterNode]
     version: str
     degraded: bool
     degraded_error: str
     status: str
-    
+

core_client/base/models/v3/cluster_node_files.py

@@ -20,5 +20,5 @@ class ClusterNodeFiles(BaseModel):
     }
     """
 
-    files: Dict[str, List[str]]
+    files: dict[str, list[str]]
     last_update: int

core_client/base/models/v3/cluster_reallocation_node.py

@@ -17,5 +17,5 @@ class ClusterReallocationNode(BaseModel):
     ]
     """
 
-    target_node_id: Optional[str] = ""
+    target_node_id: str | None = ""
     process_ids: list[ClusterReallocationNodeProcess]

core_client/base/models/v3/config.py

@@ -57,25 +57,25 @@ class Config(BaseModel):
     }
     """
 
-    created_at: Optional[str] = None
-    version: Optional[int] = None
-    id: Optional[str] = None
-    name: Optional[str] = None
-    address: Optional[str] = None
-    log: Optional[ConfigLog] = None
-    db: Optional[ConfigDb] = None
-    host: Optional[ConfigHost] = None
-    api: Optional[ConfigApi] = None
-    tls: Optional[ConfigTls] = None
-    rtmp: Optional[ConfigRtmp] = None
-    srt: Optional[ConfigSrt] = None
-    storage: Optional[ConfigStorage] = None
-    ffmpeg: Optional[ConfigFfmpeg] = None
-    playout: Optional[ConfigPlayout] = None
-    resources: Optional[ConfigResources] = None
-    debug: Optional[ConfigDebug] = None
-    metrics: Optional[ConfigMetrics] = None
-    sessions: Optional[ConfigSessions] = None
-    service: Optional[ConfigService] = None
-    router: Optional[ConfigRouter] = None
-    cluster: Optional[ConfigCluster] = None
+    created_at: str | None = None
+    version: int | None = None
+    id: str | None = None
+    name: str | None = None
+    address: str | None = None
+    log: ConfigLog | None = None
+    db: ConfigDb | None = None
+    host: ConfigHost | None = None
+    api: ConfigApi | None = None
+    tls: ConfigTls | None = None
+    rtmp: ConfigRtmp | None = None
+    srt: ConfigSrt | None = None
+    storage: ConfigStorage | None = None
+    ffmpeg: ConfigFfmpeg | None = None
+    playout: ConfigPlayout | None = None
+    resources: ConfigResources | None = None
+    debug: ConfigDebug | None = None
+    metrics: ConfigMetrics | None = None
+    sessions: ConfigSessions | None = None
+    service: ConfigService | None = None
+    router: ConfigRouter | None = None
+    cluster: ConfigCluster | None = None