RuntimeService

fleetforge_contracts::runtime::runtime_service_server

Trait RuntimeService 

Source 
pub trait RuntimeService:
    Send
    + Sync
    + 'static {
    type TapRunStream: Stream<Item = Result<RunEvent, Status>> + Send + 'static;


Show 15 methods    // Required methods
    fn submit_run<'life0, 'async_trait>(
        &'life0 self,
        request: Request<SubmitRunRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<SubmitRunResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_run<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetRunRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetRunResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn tap_run<'life0, 'async_trait>(
        &'life0 self,
        request: Request<TapRunRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<Self::TapRunStream>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn replay_run<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ReplayRunRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ReplayRunResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn update_breakpoints<'life0, 'async_trait>(
        &'life0 self,
        request: Request<UpdateBreakpointsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateBreakpointsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn resume_run<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ResumeRunRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ResumeRunResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn patch_step<'life0, 'async_trait>(
        &'life0 self,
        request: Request<PatchStepRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<PatchStepResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn create_branch_run<'life0, 'async_trait>(
        &'life0 self,
        request: Request<CreateBranchRunRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<CreateBranchRunResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn sync_eval_pack<'life0, 'async_trait>(
        &'life0 self,
        request: Request<SyncEvalPackRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<SyncEvalPackResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_eval_scenarios<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListEvalScenariosRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListEvalScenariosResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn record_eval_result<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RecordEvalResultRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RecordEvalResultResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn check_change_gate<'life0, 'async_trait>(
        &'life0 self,
        request: Request<CheckChangeGateRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<CheckChangeGateResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn record_gate_followup<'life0, 'async_trait>(
        &'life0 self,
        request: Request<RecordGateFollowupRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<RecordGateFollowupResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn list_change_gates<'life0, 'async_trait>(
        &'life0 self,
        request: Request<ListChangeGatesRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<ListChangeGatesResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_attestations<'life0, 'async_trait>(
        &'life0 self,
        request: Request<GetAttestationsRequest>,
    ) -> Pin<Box<dyn Future<Output = Result<Response<GetAttestationsResponse>, Status>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;

}
Expand description

Generated trait containing gRPC methods that should be implemented for use with RuntimeServiceServer.

Required Associated Types§

Source

type TapRunStream: Stream<Item = Result<RunEvent, Status>> + Send + 'static

Server streaming response type for the TapRun method.

Required Methods§

Source

fn submit_run<'life0, 'async_trait>( &'life0 self, request: Request<SubmitRunRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SubmitRunResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn get_run<'life0, 'async_trait>( &'life0 self, request: Request<GetRunRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetRunResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn tap_run<'life0, 'async_trait>( &'life0 self, request: Request<TapRunRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::TapRunStream>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn replay_run<'life0, 'async_trait>( &'life0 self, request: Request<ReplayRunRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ReplayRunResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn update_breakpoints<'life0, 'async_trait>( &'life0 self, request: Request<UpdateBreakpointsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<UpdateBreakpointsResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn resume_run<'life0, 'async_trait>( &'life0 self, request: Request<ResumeRunRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ResumeRunResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn patch_step<'life0, 'async_trait>( &'life0 self, request: Request<PatchStepRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<PatchStepResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn create_branch_run<'life0, 'async_trait>( &'life0 self, request: Request<CreateBranchRunRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CreateBranchRunResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn sync_eval_pack<'life0, 'async_trait>( &'life0 self, request: Request<SyncEvalPackRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<SyncEvalPackResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn list_eval_scenarios<'life0, 'async_trait>( &'life0 self, request: Request<ListEvalScenariosRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListEvalScenariosResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn record_eval_result<'life0, 'async_trait>( &'life0 self, request: Request<RecordEvalResultRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RecordEvalResultResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn check_change_gate<'life0, 'async_trait>( &'life0 self, request: Request<CheckChangeGateRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<CheckChangeGateResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn record_gate_followup<'life0, 'async_trait>( &'life0 self, request: Request<RecordGateFollowupRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<RecordGateFollowupResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn list_change_gates<'life0, 'async_trait>( &'life0 self, request: Request<ListChangeGatesRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<ListChangeGatesResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Source

fn get_attestations<'life0, 'async_trait>( &'life0 self, request: Request<GetAttestationsRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<GetAttestationsResponse>, Status>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Implementors§