Struct gitlab_runner::Runner

pub struct Runner { /* fields omitted */ }

Implementations

impl Runner

pub fn new(server: Url, token: String) -> Self

pub fn running(&self) -> usize

pub async fn request_job<F, J, Ret>(
    &mut self,
    process: F
) -> Result<bool, Error> where
    F: Fn(Job) -> Ret + Sync + Send + 'static,
    J: JobHandler + Send + 'static,
    Ret: Future<Output = Result<J, ()>> + Send + 'static, 

Request a new job from gitlab

pub async fn wait_job(&mut self)

Wait for at least one of the current jobs to finish

pub async fn sleep(&mut self, timeout: Duration)

Sleep for the given duration while keeping track of outstanding jobs

pub async fn run<F, J, Ret>(
    &mut self,
    process: F,
    maximum: usize
) -> Result<(), Error> where
    F: Fn(Job) -> Ret + Sync + Send + 'static + Clone,
    J: JobHandler + Send + 'static,
    Ret: Future<Output = Result<J, ()>> + Send + 'static, 

Trait Implementations

impl Debug for Runner

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

Formats the value using the given formatter.