soulfire.script_connect.ScriptServiceClientSync

class soulfire.script_connect.ScriptServiceClientSync(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.InterceptorSync] = (), http_client: pyqwest.SyncClient | None = None)

Bases: connectrpc.client.ConnectClientSync

A synchronous client for the Connect protocol.

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

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

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

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

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.Iterator[soulfire.script_pb2.ScriptEvent]

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

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.Iterator[soulfire.script_pb2.ScriptLogEntry]

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

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

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.Iterator[soulfire.script_pb2.ScriptEvent]