Struct Pool 

pub struct Pool(/* private fields */);

Implementations

impl Pool

pub async fn insert_tasks<I>( &self, tasks: I, params: &TaskParams, ) -> Result<u64>

where I: Iterator<Item = TaskPayload>,

Trait Implementations

impl AsRef<Pool<Sqlite>> for Pool

fn as_ref(&self) -> &SqlitePool

Converts this type into a shared reference of the (usually inferred) input type.

impl AuthenticationRepository for Pool

async fn find_by_credentials( &self, email: &str, password: &str, ) -> Result<Option<Profile>>

async fn create( &self, email: &str, password: &str, ) -> Result<Profile, SignupError>

impl Clone for Pool

fn clone(&self) -> Pool

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Pool

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl MediaRepository for Pool

async fn find_by_id(&self, media_id: u64) -> Result<Option<MediaFile>>

async fn upsert(&self, disk: &str, input: &[MediaFileInput]) -> Result<u64>

impl PodcastEpisodeRepository for Pool

async fn find_by_id(&self, episode_id: u64) -> Result<Option<PodcastEpisode>>

async fn list<'a>( &self, params: ListPodcastEpisodeParams<'a>, ) -> Result<Vec<PodcastEpisode>>

async fn delete_progressions( &self, user_id: u64, episode_ids: &[u64], ) -> Result<()>

async fn list_progressions( &self, user_id: u64, episode_ids: &[u64], ) -> Result<Vec<PodcastEpisodeProgress>>

async fn upsert_progressions( &self, inputs: &[PodcastEpisodeProgressInput], ) -> Result<Vec<PodcastEpisodeProgress>>

impl PodcastRepository for Pool

async fn find_by_id(&self, podcast_id: u64) -> Result<Option<Podcast>>

async fn find_by_feed_url(&self, feed_url: &str) -> Result<Option<Podcast>>

async fn list<'a>(&self, params: ListPodcastParams<'a>) -> Result<Vec<Podcast>>

async fn upsert(&self, entity: &PodcastInput) -> Result<Podcast>

impl PodcastSubscriptionRepository for Pool

async fn create(&self, user_id: u64, podcast_id: u64) -> Result<()>

async fn delete(&self, user_id: u64, podcast_id: u64) -> Result<()>

async fn list( &self, user_id: u64, podcast_ids: &[u64], ) -> Result<Vec<PodcastSubscription>>

async fn update( &self, user_id: u64, podcast_id: u64, body: PodcastSubscriptionUpdate, ) -> Result<()>

async fn find( &self, user_id: u64, podcast_id: u64, ) -> Result<Option<PodcastSubscription>>

impl PodcastTaskRepository for Pool

async fn last( &self, method: TaskMethod, podcast_ids: &[u64], ) -> Result<Vec<Task>>

impl TaskRepository for Pool

async fn start_task(&self) -> Result<Option<Task>>

async fn complete_task(&self, task_id: u64) -> Result<()>

async fn fail_task(&self, task_id: u64, error: String) -> Result<()>

async fn find_by_target_ids( &self, task_method: TaskMethod, target_ids: &[u64], ) -> Result<Vec<Task>>

impl TvShowEpisodeFileRepository for Pool

async fn list<'a>( &self, params: ListEpisodeFileParams<'a>, ) -> Result<Vec<TvShowEpisodeFile>>

impl TvShowEpisodeRepository for Pool

async fn find_by_id( &self, episode_id: u64, language: Language, ) -> Result<Option<TvShowEpisode>>

async fn list<'a>( &self, params: ListTvShowEpisodeParams<'a>, ) -> Result<Vec<TvShowEpisode>>

async fn upsert( &self, tvshow_id: u64, input: &[ExternalTvShowEpisode], ) -> Result<Vec<TvShowEpisode>>

async fn delete_progressions( &self, user_id: u64, episode_ids: &[u64], ) -> Result<()>

async fn list_progressions( &self, user_id: u64, episode_ids: &[u64], ) -> Result<Vec<TvShowEpisodeProgress>>

async fn upsert_progressions( &self, inputs: &[TvShowEpisodeProgressInput], ) -> Result<Vec<TvShowEpisodeProgress>>

impl TvShowRepository for Pool

async fn find_by_id( &self, tvshow_id: u64, language: Language, ) -> Result<Option<TvShow>>

async fn find_by_source( &self, source: TvShowSource, language: Language, ) -> Result<Option<TvShow>>

async fn list<'a>(&self, params: ListTvShowParams<'a>) -> Result<Vec<TvShow>>

async fn list_languages( &self, tvshow_ids: &[u64], ) -> Result<Vec<(u64, Language)>>

async fn upsert(&self, input: &ExternalTvShow) -> Result<TvShow>

impl TvShowSeasonRepository for Pool

async fn find_by_id( &self, season_id: u64, language: Language, ) -> Result<Option<TvShowSeason>>

async fn list<'a>( &self, params: ListTvShowSeasonParams<'a>, ) -> Result<Vec<TvShowSeason>>

async fn upsert( &self, tvshow_id: u64, input: &ExternalTvShowSeason, ) -> Result<TvShowSeason>

impl TvShowSubscriptionRepository for Pool

async fn list_by_ids( &self, user_id: u64, tvshow_ids: &[u64], ) -> Result<Vec<TvShowSubscription>>

async fn create(&self, user_id: u64, tvshow_id: u64) -> Result<()>

async fn delete(&self, user_id: u64, tvshow_id: u64) -> Result<()>

async fn list( &self, user_id: u64, language: Language, ) -> Result<Vec<TvShowWithSubscription>>