soulfire.user_connect.UserServiceClient¶

class soulfire.user_connect.UserServiceClient(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)[source]¶

Bases: connectrpc.client.ConnectClient

An asynchronous client for the Connect protocol.

async create_user(request: soulfire.user_pb2.UserCreateRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.user_pb2.UserCreateResponse[source]¶

async delete_user(request: soulfire.user_pb2.UserDeleteRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.user_pb2.UserDeleteResponse[source]¶

async list_users(request: soulfire.user_pb2.UserListRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.user_pb2.UserListResponse[source]¶

async get_user_info(request: soulfire.user_pb2.UserInfoRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.user_pb2.UserInfoResponse[source]¶

async invalidate_sessions(request: soulfire.user_pb2.InvalidateSessionsRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.user_pb2.InvalidateSessionsResponse[source]¶

async update_user(request: soulfire.user_pb2.UpdateUserRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.user_pb2.UpdateUserResponse[source]¶

async generate_user_api_token(request: soulfire.user_pb2.GenerateUserAPITokenRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.user_pb2.GenerateUserAPITokenResponse[source]¶

async list_user_plugin_permission_grants(request: soulfire.user_pb2.ListUserPluginPermissionGrantsRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.user_pb2.ListUserPluginPermissionGrantsResponse[source]¶

async set_user_plugin_permission_grant(request: soulfire.user_pb2.SetUserPluginPermissionGrantRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.user_pb2.UserPluginPermissionGrant[source]¶

async delete_user_plugin_permission_grant(request: soulfire.user_pb2.DeleteUserPluginPermissionGrantRequest, *, headers: connectrpc.request.Headers | collections.abc.Mapping[str, str] | None = None, timeout_ms: int | None = None) → soulfire.user_pb2.DeleteUserPluginPermissionGrantResponse[source]¶