Struct rebuilderd::models::Queued

pub struct Queued {
    pub id: i32,
    pub package_id: i32,
    pub version: 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

package_id: i32

version: 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,
    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(
    pkgs: &[(i32, String)],
    priority: i32,
    connection: &SqliteConnection
) -> Result<()>

pub fn drop_for_pkgs(pkgs: &[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<package_id, &'update i32>, Eq<version, &'update String>, Eq<priority, &'update i32>, Eq<queued_at, &'update NaiveDateTime>, Option<Eq<worker_id, &'update i32>>, Option<Eq<started_at, &'update NaiveDateTime>>, Option<Eq<last_ping, &'update NaiveDateTime>>) 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<package_id, i32>, Eq<version, String>, Eq<priority, i32>, Eq<queued_at, NaiveDateTime>, Option<Eq<worker_id, i32>>, Option<Eq<started_at, NaiveDateTime>>, Option<Eq<last_ping, NaiveDateTime>>) 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<Queued> 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: &Queued) -> bool

This method tests for !=.

impl<__DB: Backend, __ST> Queryable<__ST, __DB> for Queued where
    (i32, i32, String, i32, NaiveDateTime, Option<i32>, Option<NaiveDateTime>, Option<NaiveDateTime>): Queryable<__ST, __DB>, 

type Row = <(i32, i32, 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 StructuralPartialEq for Queued