Class DstackClient

sdk/python/src/dstack_sdk/dstack_client.py:537–634

class DstackClient(BaseClient):
    PATH_PREFIX = "/"

    def __init__(self, endpoint: str | None = None, *, timeout: float = 3):
        """Initialize client with HTTP or Unix-socket transport.

        If a non-HTTP(S) endpoint is provided, it is treated as a Unix socket
        path and validated for existence.
        """
        self.async_client = AsyncDstackClient(
            endpoint, use_sync_http=True, timeout=timeout
        )

    @call_async
    def get_key(
        self,
        path: str | None = None,
        purpose: str | None = None,
        algorithm: str = "secp256k1",
    ) -> GetKeyResponse:
        """Derive a key from the given path, purpose, and algorithm."""
        raise NotImplementedError

    @call_async
    def get_quote(
        self,
        report_data: str | bytes,
    ) -> GetQuoteResponse:
        """Request an attestation quote for the provided report data."""
        raise NotImplementedError

    @call_async
    def attest(
        self,
        report_data: str | bytes,
    ) -> AttestResponse:
        """Request a versioned attestation for the provided report data."""
        raise NotImplementedError

    @call_async
    def info(self) -> InfoResponse[TcbInfo]:
        """Fetch service information including parsed TCB info."""
        raise NotImplementedError

    @call_async
    def emit_event(
        self,
        event: str,
        payload: str | bytes,
    ) -> None:
        """Emit an event that extends RTMR3 on TDX platforms."""
        raise NotImplementedError

    @call_async
    def get_tls_key(
        self,
        subject: str | None = None,
        alt_names: List[str] | None = None,