Struct PluginSession 

pub struct PluginSession { /* private fields */ }

Implementations

impl PluginSession

pub async fn start( command: PluginCommand, expected_provider_kind: &str, provider_instance: &str, startup_timeout: Duration, request_timeout: Duration, ) -> Result<Self, PluginError>

pub async fn linked( provider: Arc<dyn Provider>, expected_provider_kind: &str, provider_instance: &str, request_timeout: Duration, ) -> Result<Self, PluginError>

pub fn run_dir(&self) -> &Path

pub fn provider_version(&self) -> &str

pub fn capabilities(&self) -> &BTreeSet<String>

pub fn resource_kinds(&self) -> &[ResourceKindDescriptor]

Advertised provider-owned resource kind schemas from handshake.

pub async fn observe( &mut self, provider_config_json: Vec<u8>, selection_json: Vec<u8>, secrets: HashMap<String, Vec<u8>>, ) -> Result<Vec<u8>, PluginError>

pub async fn capture( &mut self, provider_config_json: Vec<u8>, resource_ids: Vec<String>, secrets: HashMap<String, Vec<u8>>, ) -> Result<Vec<CaptureArtifact>, PluginError>

pub async fn plan( &mut self, desired_json: Vec<u8>, observations_json: Vec<u8>, secrets: HashMap<String, Vec<u8>>, ) -> Result<Vec<PlannedAction>, PluginError>

pub async fn plan_with_context( &mut self, desired_json: Vec<u8>, observations_json: Vec<u8>, secrets: HashMap<String, Vec<u8>>, resource_contexts: HashMap<String, ResourcePlanContext>, enrollment_strategy: EnrollmentStrategy, planning_mode: PlanningMode, ) -> Result<Vec<PlannedAction>, PluginError>

pub async fn apply( &mut self, action: PlannedAction, secrets: HashMap<String, Vec<u8>>, run_id: &str, ) -> Result<Vec<ApplyResponse>, PluginError>

pub async fn apply_with_progress( &mut self, action: PlannedAction, secrets: HashMap<String, Vec<u8>>, run_id: &str, logger: Logger, ) -> Result<Vec<ApplyResponse>, PluginError>

pub async fn verify( &mut self, action: PlannedAction, secrets: HashMap<String, Vec<u8>>, ) -> Result<(), PluginError>

pub async fn verify_with_outputs( &mut self, action: PlannedAction, secrets: HashMap<String, Vec<u8>>, confidential_outputs: HashMap<String, Vec<u8>>, public_outputs: HashMap<String, Vec<u8>>, ) -> Result<(), PluginError>

pub async fn cancel(&mut self, run_id: &str) -> Result<(), PluginError>

Trait Implementations

impl Drop for PluginSession

fn drop(&mut self)

Executes the destructor for this type.