Struct KomodoPlugin 

pub struct KomodoPlugin { /* private fields */ }

Implementations

impl KomodoPlugin

pub fn new() -> Self

Trait Implementations

impl Default for KomodoPlugin

fn default() -> Self

Returns the “default value” for a type.

impl Plugin for KomodoPlugin

fn metadata(&self) -> &PluginMetadata

fn provider_type(&self) -> &str

fn client_options(&self, config: &HashMap<String, String>) -> ClientOptions

fn initialize( &mut self, provider_id: i64, config: HashMap<String, String>, http_client: Option<Arc<Client>>, ) -> PluginResult<()>

fn validate_credentials<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = PluginResult<bool>> + Send + 'async_trait>>

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

fn fetch_available_pipelines<'life0, 'async_trait>( &'life0 self, params: Option<PaginationParams>, ) -> Pin<Box<dyn Future<Output = PluginResult<PaginatedResponse<AvailablePipeline>>> + Send + 'async_trait>>

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

fn fetch_organizations<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = PluginResult<Vec<Organization>>> + Send + 'async_trait>>

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

fn fetch_available_pipelines_filtered<'life0, 'async_trait>( &'life0 self, org: Option<String>, search: Option<String>, params: Option<PaginationParams>, ) -> Pin<Box<dyn Future<Output = PluginResult<PaginatedResponse<AvailablePipeline>>> + Send + 'async_trait>>

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

fn fetch_pipelines<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = PluginResult<Vec<Pipeline>>> + Send + 'async_trait>>

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

fn fetch_run_history<'life0, 'life1, 'async_trait>( &'life0 self, pipeline_id: &'life1 str, limit: usize, ) -> Pin<Box<dyn Future<Output = PluginResult<Vec<PipelineRun>>> + Send + 'async_trait>>

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

fn fetch_run_details<'life0, 'life1, 'async_trait>( &'life0 self, pipeline_id: &'life1 str, run_number: i64, ) -> Pin<Box<dyn Future<Output = PluginResult<PipelineRun>> + Send + 'async_trait>>

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

fn fetch_log_nodes<'life0, 'life1, 'async_trait>( &'life0 self, run: RunRef<'life1>, ) -> Pin<Box<dyn Future<Output = PluginResult<Vec<LogNode>>> + Send + 'async_trait>>

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

fn read_log<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, run: RunRef<'life1>, node_id: &'life2 str, from: Option<&'life3 LogCursor>, sink: &'life4 mut LogSink, ) -> Pin<Box<dyn Future<Output = PluginResult<LogRead>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

fn log_dialect(&self) -> &'static dyn LogDialect

fn trigger_pipeline<'life0, 'async_trait>( &'life0 self, params: TriggerParams, ) -> Pin<Box<dyn Future<Output = PluginResult<String>> + Send + 'async_trait>>

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

fn status_source(&self) -> Option<&StatusSource>

fn check_health<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<ComponentHealth>, PluginError>> + Send + 'async_trait>>

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

fn fetch_pipeline_catalog<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<PipelineCatalog, PluginError>> + Send + 'async_trait>>

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

fn ids_with_ci<'life0, 'async_trait>( &'life0 self, ids: Vec<String>, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, PluginError>> + Send + 'async_trait>>

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

fn fetch_pipelines_paginated<'life0, 'async_trait>( &'life0 self, page: usize, page_size: usize, ) -> Pin<Box<dyn Future<Output = Result<PaginatedResponse<Pipeline>, PluginError>> + Send + 'async_trait>>

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

fn fetch_recent_runs<'life0, 'life1, 'async_trait>( &'life0 self, _pipeline_ids: &'life1 [String], _limit: usize, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, Vec<PipelineRun>>, PluginError>> + Send + 'async_trait>>

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

fn cancel_run<'life0, 'life1, 'async_trait>( &'life0 self, _pipeline_id: &'life1 str, _run_number: i64, ) -> Pin<Box<dyn Future<Output = Result<(), PluginError>> + Send + 'async_trait>>

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

fn force_cancel_run<'life0, 'life1, 'async_trait>( &'life0 self, _pipeline_id: &'life1 str, _run_number: i64, ) -> Pin<Box<dyn Future<Output = Result<(), PluginError>> + Send + 'async_trait>>

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

fn review_run<'life0, 'life1, 'async_trait>( &'life0 self, _pipeline_id: &'life1 str, _run_number: i64, _decision: ReviewDecision, ) -> Pin<Box<dyn Future<Output = Result<(), PluginError>> + Send + 'async_trait>>

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

fn rerun_failed_jobs<'life0, 'life1, 'async_trait>( &'life0 self, _pipeline_id: &'life1 str, _run_number: i64, ) -> Pin<Box<dyn Future<Output = Result<(), PluginError>> + Send + 'async_trait>>

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

fn rerun_run<'life0, 'life1, 'async_trait>( &'life0 self, _pipeline_id: &'life1 str, _run_number: i64, ) -> Pin<Box<dyn Future<Output = Result<(), PluginError>> + Send + 'async_trait>>

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

fn enable_pipeline<'life0, 'life1, 'async_trait>( &'life0 self, _pipeline_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), PluginError>> + Send + 'async_trait>>

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

fn fetch_workflow_parameters<'life0, 'life1, 'async_trait>( &'life0 self, _workflow_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<WorkflowParameter>, PluginError>> + Send + 'async_trait>>

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

fn fetch_agents<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<BuildAgent>, PluginError>> + Send + 'async_trait>>

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

fn fetch_artifacts<'life0, 'life1, 'async_trait>( &'life0 self, _run_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Vec<BuildArtifact>, PluginError>> + Send + 'async_trait>>

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

fn fetch_queues<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<BuildQueue>, PluginError>> + Send + 'async_trait>>

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

fn fetch_rate_limit<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<RateLimit>, PluginError>> + Send + 'async_trait>>

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

fn get_migrations(&self) -> Vec<String>

fn get_field_options<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _field_key: &'life1 str, _config: &'life2 HashMap<String, String>, ) -> Pin<Box<dyn Future<Output = Result<Vec<String>, PluginError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

fn sign_in_client<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, _config: &'life1 HashMap<String, String>, _http_client: &'life2 Client, ) -> Pin<Box<dyn Future<Output = Result<SignInClient, PluginError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

fn sign_in_refresh_rejections(&self) -> &'static [SignInRefreshRejection]

fn check_permissions<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<PermissionStatus, PluginError>> + Send + 'async_trait>>

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

fn get_feature_availability( &self, status: &PermissionStatus, ) -> Vec<FeatureAvailability>