Struct ProviderService 

pub struct ProviderService { /* private fields */ }

Implementations

impl ProviderService

pub fn new( repository: Arc<Repository>, http_client_manager: Arc<HttpClientManager>, event_bus: Arc<dyn EventBus>, scheduler: Arc<FetchScheduler>, health: HealthHandle, dispatcher: RefreshDispatcher, config_state: Arc<ConfigState>, log_store: Arc<LogStore>, ) -> Self

pub fn repository(&self) -> &Arc<Repository>

pub fn list_available_plugins(&self) -> Vec<PluginMetadata>

pub fn retains_run_history(&self, provider_type: &str) -> bool

pub async fn init_plugin( &self, provider_type: &str, config: HashMap<String, String>, provider_id: i64, ) -> DomainResult<Box<dyn PluginTrait>>

pub async fn field_options( &self, provider_type: &str, field_key: &str, config: HashMap<String, String>, ) -> DomainResult<Vec<String>>

pub async fn provider_for_editing( &self, id: i64, ) -> DomainResult<ProviderConfig>

pub async fn stored_plugin(&self, id: i64) -> DomainResult<Box<dyn PluginTrait>>

pub async fn start_sign_in( &self, provider_type: &str, config: HashMap<String, String>, ) -> DomainResult<SignInStart>

pub async fn sign_in_status( &self, reference: &str, ) -> DomainResult<SignInStatus>

pub async fn complete_sign_in( &self, flow: &str, redirect_url: &str, ) -> DomainResult<SignInStatus>

pub async fn cancel_sign_in(&self, flow: &str)

pub async fn wait_for_sign_in(&self, flow: &str) -> SignInStatus

pub async fn acquire(&self, id: i64) -> DomainResult<ProviderLease>

pub async fn commit<F, Fut, T>(&self, lease: &ProviderLease, f: F) -> Option<T>

where F: FnOnce() -> Fut, Fut: Future<Output = T>,

pub async fn publish_summary(&self, id: i64, generation: Generation)

pub async fn add_provider(&self, config: ProviderConfig) -> DomainResult<i64>

pub async fn export_providers_toml(&self) -> DomainResult<String>

pub async fn import_providers_toml( &self, content: &str, ) -> DomainResult<ProviderImportResult>

pub async fn apply_config_file( &self, config_state: &ConfigState, ) -> DomainResult<SyncResult>

pub async fn update_general_settings( &self, config_state: &ConfigState, update: GeneralSettingsUpdate, ) -> DomainResult<()>

pub async fn get_provider_config(&self, id: i64) -> DomainResult<ProviderConfig>

pub async fn list_providers(&self) -> DomainResult<Vec<ProviderSummary>>

pub async fn update_provider( &self, id: i64, config: ProviderConfig, ) -> DomainResult<()>

pub async fn update_provider_refresh_interval( &self, id: i64, refresh_interval: i64, ) -> DomainResult<()>

pub async fn remove_provider(&self, id: i64) -> DomainResult<()>

pub async fn get_provider(&self, id: i64) -> DomainResult<Arc<dyn Provider>>

pub async fn check_quota(&self, lease: &ProviderLease) -> Option<DateTime<Utc>>

pub async fn get_provider_instance( &self, id: i64, ) -> DomainResult<Arc<dyn Provider>>

pub async fn load_missing_providers(&self)

pub async fn load_all_providers(&self) -> DomainResult<()>

pub async fn get_workflow_parameters( &self, provider_id: i64, workflow_id: &str, ) -> DomainResult<Vec<WorkflowParameter>>

pub async fn get_provider_permissions( &self, provider_id: i64, ) -> DomainResult<Option<PermissionStatus>>

pub async fn recheck_provider_permissions( &self, provider_id: i64, ) -> DomainResult<PermissionStatus>