Trait Deployment 

pub trait Deployment:
    Clone
    + Send
    + Sync
    + 'static {
    // Required methods
    fn new<'async_trait>(    ) -> Pin<Box<dyn Future<Output = Result<Self, DeploymentError>> + Send + 'async_trait>>
       where Self: 'async_trait;
    fn user_id(&self) -> &str;
    fn shared_types() -> Vec<String>;
    fn config(&self) -> &Arc<RwLock<Config>>;
    fn db(&self) -> &DBService;
    fn analytics(&self) -> &Option<AnalyticsService>;
    fn container(&self) -> &impl ContainerService;
    fn auth(&self) -> &AuthService;
    fn git(&self) -> &GitService;
    fn image(&self) -> &ImageService;
    fn filesystem(&self) -> &FilesystemService;
    fn msg_stores(&self) -> &Arc<RwLock<HashMap<Uuid, Arc<MsgStore>>>>;
    fn events(&self) -> &EventService;
    fn file_search_cache(&self) -> &Arc<FileSearchCache>;
    fn approvals(&self) -> &Approvals;
    fn drafts(&self) -> &DraftsService;
    fn forge_config(&self) -> &ForgeConfigService;
    fn omni(&self) -> &Arc<RwLock<OmniService>>;
    fn profile_cache(&self) -> &ProfileCacheManager;

    // Provided methods
    fn update_sentry_scope<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<(), DeploymentError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn spawn_pr_monitor_service<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = JoinHandle<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn track_if_analytics_allowed<'life0, 'life1, 'async_trait>(
        &'life0 self,
        event_name: &'life1 str,
        properties: Value,
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait { ... }
    fn cleanup_orphan_executions<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<(), DeploymentError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn backfill_before_head_commits<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<(), DeploymentError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn trigger_auto_project_setup<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn stream_events<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = BoxStream<'static, Result<Event, Error>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
}

Required Methods

fn new<'async_trait>() -> Pin<Box<dyn Future<Output = Result<Self, DeploymentError>> + Send + 'async_trait>>

where Self: 'async_trait,

fn user_id(&self) -> &str

fn shared_types() -> Vec<String>

fn config(&self) -> &Arc<RwLock<Config>>

fn db(&self) -> &DBService

fn analytics(&self) -> &Option<AnalyticsService>

fn container(&self) -> &impl ContainerService

fn auth(&self) -> &AuthService

fn git(&self) -> &GitService

fn image(&self) -> &ImageService

fn filesystem(&self) -> &FilesystemService

fn msg_stores(&self) -> &Arc<RwLock<HashMap<Uuid, Arc<MsgStore>>>>

fn events(&self) -> &EventService

fn file_search_cache(&self) -> &Arc<FileSearchCache>

fn approvals(&self) -> &Approvals

fn drafts(&self) -> &DraftsService

fn forge_config(&self) -> &ForgeConfigService

fn omni(&self) -> &Arc<RwLock<OmniService>>

fn profile_cache(&self) -> &ProfileCacheManager

Provided Methods

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

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

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

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

fn track_if_analytics_allowed<'life0, 'life1, 'async_trait>( &'life0 self, event_name: &'life1 str, properties: Value, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

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

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

Cleanup executions marked as running in the db, call at startup

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

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

Backfill before_head_commit for legacy execution processes. Rules:

• If a process has after_head_commit and missing before_head_commit, then set before_head_commit to the previous process’s after_head_commit.
• If there is no previous process, set before_head_commit to the base branch commit.

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

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

Trigger background auto-setup of default projects for new users

fn stream_events<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = BoxStream<'static, Result<Event, Error>>> + Send + 'async_trait>>

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

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors