Struct ParadeDbRepository 

pub struct ParadeDbRepository { /* private fields */ }

Implementations

impl ParadeDbRepository

pub const fn new(pool: PgPool) -> Self

pub fn arc_new(pool: PgPool) -> Arc<Self>

impl ParadeDbRepository

pub async fn create( &self, task: &Task, user_id: i32, ) -> Result<Task, RepositoryError>

pub async fn get(&self, id: Uuid) -> Result<Task, RepositoryError>

pub async fn list(&self, user_id: i32) -> Result<Vec<Task>, RepositoryError>

pub async fn update(&self, task: &Task) -> Result<Task, RepositoryError>

pub async fn delete(&self, id: Uuid) -> Result<(), RepositoryError>

pub async fn search_bm25( &self, user_id: i32, query: &str, limit: i64, ) -> Result<Vec<Task>, RepositoryError>

pub async fn search_vector( &self, user_id: i32, embedding: &[f32], limit: i64, ) -> Result<Vec<(Task, f64)>, RepositoryError>

pub async fn update_embedding( &self, task_id: Uuid, embedding: &[f32], ) -> Result<(), RepositoryError>

pub async fn upsert_user(&self, email: &str) -> Result<i32, RepositoryError>

pub async fn create_session( &self, token: &str, user_id: i32, ) -> Result<(), RepositoryError>

pub async fn validate_session( &self, token: &str, ) -> Result<Option<i32>, RepositoryError>