Struct astro_run_server::AstroRunServer

pub struct AstroRunServer { /* private fields */ }

Implementations

impl AstroRunServer

pub fn new() -> Self

Examples found in repository

examples/server.rs (line 6)

async fn main() -> Result<()> {
  let server = AstroRunServer::new();

  // Start server in background
  let handle = tokio::spawn({
    let server = server.clone();

    async move {
      server.serve("127.0.0.1:5338").await.unwrap();
    }
  });

  let astro_run = AstroRun::builder().runner(server).build();

  let workflow = r#"
    jobs:
      test:
        name: Test Job
        steps:
          - timeout: 60m
            continue-on-error: false
            run: Hello World
      "#;

  let workflow = Workflow::builder()
    .config(workflow)
    .build(&astro_run)
    .unwrap();

  let ctx = astro_run.execution_context().build();

  // Run workflow
  let _res = workflow.run(ctx).await;

  // Wait for server to stop
  handle.await.unwrap();

  Ok(())
}

pub fn with_scheduler<T>(scheduler: T) -> Self

where T: Scheduler + 'static,

pub async fn serve(self, url: impl Into<&str>) -> Result<()>

Examples found in repository

examples/server.rs (line 13)

async fn main() -> Result<()> {
  let server = AstroRunServer::new();

  // Start server in background
  let handle = tokio::spawn({
    let server = server.clone();

    async move {
      server.serve("127.0.0.1:5338").await.unwrap();
    }
  });

  let astro_run = AstroRun::builder().runner(server).build();

  let workflow = r#"
    jobs:
      test:
        name: Test Job
        steps:
          - timeout: 60m
            continue-on-error: false
            run: Hello World
      "#;

  let workflow = Workflow::builder()
    .config(workflow)
    .build(&astro_run)
    .unwrap();

  let ctx = astro_run.execution_context().build();

  // Run workflow
  let _res = workflow.run(ctx).await;

  // Wait for server to stop
  handle.await.unwrap();

  Ok(())
}

Trait Implementations

impl AstroRunService for AstroRunServer

type SubscribeEventsStream = ReceiverStream<Result<Event, Status>>

Server streaming response type for the SubscribeEvents method.

fn subscribe_events<'life0, 'async_trait>( &'life0 self, request: Request<RunnerMetadata> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::SubscribeEventsStream>, Status>> + Send + 'async_trait>>

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

fn report_log<'life0, 'async_trait>( &'life0 self, request: Request<WorkflowLog> ) -> Pin<Box<dyn Future<Output = Result<Response<ReportLogResponse>, Status>> + Send + 'async_trait>>

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

fn report_run_completed<'life0, 'async_trait>( &'life0 self, request: Request<ReportRunCompletedRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<ReportRunCompletedResponse>, Status>> + Send + 'async_trait>>

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

impl Clone for AstroRunServer

fn clone(&self) -> AstroRunServer

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Runner for AstroRunServer

fn run<'life0, 'async_trait>( &'life0 self, ctx: Context ) -> Pin<Box<dyn Future<Output = RunResponse> + Send + 'async_trait>>

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

fn on_step_completed(&self, result: StepRunResult)

fn on_job_completed(&self, result: JobRunResult)

fn on_workflow_completed(&self, result: WorkflowRunResult)

fn on_run_step(&self, event: RunStepEvent)

fn on_run_job(&self, event: RunJobEvent)

fn on_run_workflow(&self, event: RunWorkflowEvent)

fn on_log(&self, log: WorkflowLog)

fn on_state_change(&self, event: WorkflowStateEvent)