Struct rebuilderd::models::Queued

pub struct Queued {
    pub id: i32,
    pub pkgbase_id: i32,
    pub version: String,
    pub required_backend: String,
    pub priority: i32,
    pub queued_at: NaiveDateTime,
    pub worker_id: Option<i32>,
    pub started_at: Option<NaiveDateTime>,
    pub last_ping: Option<NaiveDateTime>,
}

Fields

id: i32

pkgbase_id: i32

version: String

required_backend: String

priority: i32

queued_at: NaiveDateTime

worker_id: Option<i32>

started_at: Option<NaiveDateTime>

last_ping: Option<NaiveDateTime>

Implementations

impl Queued

pub fn get_id(my_id: i32, connection: &SqliteConnection) -> Result<Queued>

pub fn get( pkg: i32, my_version: &str, connection: &SqliteConnection ) -> Result<Option<Queued>>

pub fn pop_next( my_worker_id: i32, supported_backends: &[String], connection: &SqliteConnection ) -> Result<Option<QueueItem>>

pub fn ping_job(&mut self, connection: &SqliteConnection) -> Result<()>

pub fn delete(&self, connection: &SqliteConnection) -> Result<()>

pub fn list( limit: Option<i64>, connection: &SqliteConnection ) -> Result<Vec<Queued>>

pub fn update(&self, connection: &SqliteConnection) -> Result<()>

pub fn queue_batch( pkgbases: &[(i32, String)], required_backend: String, priority: i32, connection: &SqliteConnection ) -> Result<()>

pub fn insert_batch( queued: &[NewQueued], connection: &SqliteConnection ) -> Result<()>

pub fn drop_for_pkgbases( pkgbases: &[i32], connection: &SqliteConnection ) -> Result<()>

pub fn requeue(&self, connection: &SqliteConnection) -> Result<()>

pub fn free_stale_jobs(connection: &SqliteConnection) -> Result<()>

pub fn into_api_item(self, connection: &SqliteConnection) -> Result<QueueItem>

Trait Implementations

impl<'update> AsChangeset for &'update Queued

type Target = table

The table which Self::Changeset will be updating

type Changeset = <(Eq<pkgbase_id, <&'update i32 as AsExpression<<pkgbase_id as Expression>::SqlType>>::Expression>, Eq<version, <&'update String as AsExpression<<version as Expression>::SqlType>>::Expression>, Eq<required_backend, <&'update String as AsExpression<<required_backend as Expression>::SqlType>>::Expression>, Eq<priority, <&'update i32 as AsExpression<<priority as Expression>::SqlType>>::Expression>, Eq<queued_at, <&'update NaiveDateTime as AsExpression<<queued_at as Expression>::SqlType>>::Expression>, Option<Eq<worker_id, <&'update i32 as AsExpression<<worker_id as Expression>::SqlType>>::Expression>>, Option<Eq<started_at, <&'update NaiveDateTime as AsExpression<<started_at as Expression>::SqlType>>::Expression>>, Option<Eq<last_ping, <&'update NaiveDateTime as AsExpression<<last_ping as Expression>::SqlType>>::Expression>>) as AsChangeset>::Changeset

The update statement this type represents

fn as_changeset(self) -> Self::Changeset

Convert self into the actual update statement being executed

impl<'update> AsChangeset for Queued

type Target = table

The table which Self::Changeset will be updating

type Changeset = <(Eq<pkgbase_id, <i32 as AsExpression<<pkgbase_id as Expression>::SqlType>>::Expression>, Eq<version, <String as AsExpression<<version as Expression>::SqlType>>::Expression>, Eq<required_backend, <String as AsExpression<<required_backend as Expression>::SqlType>>::Expression>, Eq<priority, <i32 as AsExpression<<priority as Expression>::SqlType>>::Expression>, Eq<queued_at, <NaiveDateTime as AsExpression<<queued_at as Expression>::SqlType>>::Expression>, Option<Eq<worker_id, <i32 as AsExpression<<worker_id as Expression>::SqlType>>::Expression>>, Option<Eq<started_at, <NaiveDateTime as AsExpression<<started_at as Expression>::SqlType>>::Expression>>, Option<Eq<last_ping, <NaiveDateTime as AsExpression<<last_ping as Expression>::SqlType>>::Expression>>) as AsChangeset>::Changeset

The update statement this type represents

fn as_changeset(self) -> Self::Changeset

Convert self into the actual update statement being executed

impl Debug for Queued

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

Formats the value using the given formatter.

impl HasTable for Queued

type Table = table

The table this type is associated with.

fn table() -> Self::Table

Returns the table this type is associated with.

impl<'ident> Identifiable for &'ident Queued

type Id = &'ident i32

The type of this struct’s identifier.

fn id(self) -> Self::Id

Returns the identifier for this record.

impl PartialEq for Queued

fn eq(&self, other: &Queued) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<__DB: Backend, __ST> Queryable<__ST, __DB> for Queued

where (i32, i32, String, String, i32, NaiveDateTime, Option<i32>, Option<NaiveDateTime>, Option<NaiveDateTime>): Queryable<__ST, __DB>,

type Row = <(i32, i32, String, String, i32, NaiveDateTime, Option<i32>, Option<NaiveDateTime>, Option<NaiveDateTime>) as Queryable<__ST, __DB>>::Row

The Rust type you’d like to map from.

fn build(row: Self::Row) -> Self

Construct an instance of this type

impl Serialize for Queued

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for Queued

impl StructuralEq for Queued

impl StructuralPartialEq for Queued