Struct PostgresDatabase 

pub struct PostgresDatabase { /* private fields */ }

Implements a planetary database using a PostgreSQL server.

Implementations

impl PostgresDatabase

pub fn new(url: SecretString) -> Result<Self>

Constructs a new PostgreSQL database with the given database URL.

pub async fn run_pending_migrations(&self) -> Result<()>

Runs any pending migrations for the database.

Trait Implementations

impl Database for PostgresDatabase

fn insert_task<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, username: &'life1 str, task: &'life2 RequestTask, ) -> Pin<Box<dyn Future<Output = DatabaseResult<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Inserts a task into the database for the specified user.

fn get_task<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, username: &'life1 str, tes_id: &'life2 str, params: GetTaskParams, ) -> Pin<Box<dyn Future<Output = DatabaseResult<TaskResponse>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Gets a task from the database for the specified user.

fn get_task_template_data<'life0, 'life1, 'async_trait>( &'life0 self, tes_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = DatabaseResult<TaskTemplateData>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Gets a task’s template data for use in rendering Kubernetes resource templates.

fn get_tasks<'life0, 'life1, 'async_trait>( &'life0 self, username: &'life1 str, params: ListTasksParams, ) -> Pin<Box<dyn Future<Output = DatabaseResult<(Vec<TaskResponse>, Option<String>)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Gets tasks from the database for the specified user.

fn get_in_progress_tasks<'life0, 'async_trait>( &'life0 self, before: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = DatabaseResult<Vec<String>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gets the TES identifiers of in-progress tasks.

fn update_task_state<'a, 'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, tes_id: &'life1 str, state: State, messages: &'life2 [&'life3 str], containers: Option<BoxFuture<'a, Result<Vec<TerminatedContainer<'a>>>>>, outputs: Option<&'life4 [OutputFile]>, ) -> Pin<Box<dyn Future<Output = DatabaseResult<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'a: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

Updates the state of a task.

fn append_system_log<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, tes_id: &'life1 str, messages: &'life2 [&'life3 str], ) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Appends the given messages to the task’s system log.

fn add_task_resource_usage_samples<'life0, 'life1, 'async_trait>( &'life0 self, samples: &'life1 [ContainerUsageSample], ) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Records per-container resource usage observations.

fn insert_error<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, source: &'life1 str, tes_id: Option<&'life2 str>, message: &'life3 str, ) -> Pin<Box<dyn Future<Output = DatabaseResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

Inserts an internal system error with the database.