pub struct RemoteExecutor { /* private fields */ }
Expand description
远程执行器
Implementations§
Source§impl RemoteExecutor
impl RemoteExecutor
Sourcepub fn from_yaml_file<P: AsRef<Path>>(
path: P,
variables: Option<HashMap<String, String>>,
) -> Result<Self>
pub fn from_yaml_file<P: AsRef<Path>>( path: P, variables: Option<HashMap<String, String>>, ) -> Result<Self>
从YAML文件创建执行器
Sourcepub fn from_yaml_str(
yaml_content: &str,
variables: Option<HashMap<String, String>>,
) -> Result<Self>
pub fn from_yaml_str( yaml_content: &str, variables: Option<HashMap<String, String>>, ) -> Result<Self>
从YAML字符串创建执行器
Sourcepub async fn execute_pipeline_with_realtime_output(
&mut self,
pipeline_name: &str,
output_callback: Option<OutputCallback>,
log_callback: Option<OutputCallback>,
) -> Result<PipelineExecutionResult>
pub async fn execute_pipeline_with_realtime_output( &mut self, pipeline_name: &str, output_callback: Option<OutputCallback>, log_callback: Option<OutputCallback>, ) -> Result<PipelineExecutionResult>
执行指定的流水线(支持实时输出)
Sourcepub async fn execute_all_pipelines_with_realtime_output(
&mut self,
output_callback: Option<OutputCallback>,
log_callback: Option<OutputCallback>,
) -> Result<Vec<PipelineExecutionResult>>
pub async fn execute_all_pipelines_with_realtime_output( &mut self, output_callback: Option<OutputCallback>, log_callback: Option<OutputCallback>, ) -> Result<Vec<PipelineExecutionResult>>
执行所有流水线(支持实时输出)
Sourcepub async fn execute_pipeline(
&mut self,
pipeline_name: &str,
) -> Result<PipelineExecutionResult>
pub async fn execute_pipeline( &mut self, pipeline_name: &str, ) -> Result<PipelineExecutionResult>
执行指定的流水线(原有方法,保持兼容性)
Sourcepub async fn execute_script_with_realtime_output(
&self,
client_name: &str,
step: Step,
pipeline_name: &str,
output_callback: Option<OutputCallback>,
) -> Result<ExecutionResult>
pub async fn execute_script_with_realtime_output( &self, client_name: &str, step: Step, pipeline_name: &str, output_callback: Option<OutputCallback>, ) -> Result<ExecutionResult>
在指定客户端执行shell脚本(支持实时输出)
Sourcepub fn get_available_clients(&self) -> Vec<String>
pub fn get_available_clients(&self) -> Vec<String>
获取所有可用的客户端名称
Sourcepub fn client_exists(&self, client_name: &str) -> bool
pub fn client_exists(&self, client_name: &str) -> bool
检查客户端是否存在
Sourcepub fn get_available_pipelines(&self) -> Vec<String>
pub fn get_available_pipelines(&self) -> Vec<String>
获取所有可用的流水线名称
Sourcepub fn pipeline_exists(&self, pipeline_name: &str) -> bool
pub fn pipeline_exists(&self, pipeline_name: &str) -> bool
检查流水线是否存在
Auto Trait Implementations§
impl Freeze for RemoteExecutor
impl RefUnwindSafe for RemoteExecutor
impl Send for RemoteExecutor
impl Sync for RemoteExecutor
impl Unpin for RemoteExecutor
impl UnwindSafe for RemoteExecutor
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more