soulfire.script_connect.ScriptServiceClient

class soulfire.script_connect.ScriptServiceClient(address: str, *, codec: connectrpc.codec.Codec | None = _PROTO_BINARY_CODEC, protocol: connectrpc.protocol.ProtocolType = ProtocolType.CONNECT, accept_compression: collections.abc.Iterable[connectrpc.compression.Compression] | None = None, send_compression: connectrpc.compression.Compression | None = _GZIP_COMPRESSION, timeout_ms: int | None = None, read_max_bytes: int | None = None, interceptors: collections.abc.Iterable[connectrpc.interceptor.Interceptor] = (), http_client: pyqwest.Client | None = None)

Bases: connectrpc.client.ConnectClient

An asynchronous client for the Connect protocol.

async create_script(request: soulfire.script_pb2.CreateScriptRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.script_pb2.CreateScriptResponse

async get_script(request: soulfire.script_pb2.GetScriptRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.script_pb2.GetScriptResponse

async update_script(request: soulfire.script_pb2.UpdateScriptRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.script_pb2.UpdateScriptResponse

async delete_script(request: soulfire.script_pb2.DeleteScriptRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.script_pb2.DeleteScriptResponse

async list_scripts(request: soulfire.script_pb2.ListScriptsRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.script_pb2.ListScriptsResponse

activate_script(request: soulfire.script_pb2.ActivateScriptRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → collections.abc.AsyncIterator[soulfire.script_pb2.ScriptEvent]

async deactivate_script(request: soulfire.script_pb2.DeactivateScriptRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.script_pb2.DeactivateScriptResponse

async get_script_status(request: soulfire.script_pb2.GetScriptStatusRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.script_pb2.GetScriptStatusResponse

subscribe_script_logs(request: soulfire.script_pb2.SubscribeScriptLogsRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → collections.abc.AsyncIterator[soulfire.script_pb2.ScriptLogEntry]

async get_node_types(request: soulfire.script_pb2.GetNodeTypesRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.script_pb2.GetNodeTypesResponse

async get_registry_data(request: soulfire.script_pb2.GetRegistryDataRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.script_pb2.GetRegistryDataResponse

async validate_script(request: soulfire.script_pb2.ValidateScriptRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.script_pb2.ValidateScriptResponse

dry_run_script(request: soulfire.script_pb2.DryRunScriptRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → collections.abc.AsyncIterator[soulfire.script_pb2.ScriptEvent]