Struct BaseEventResponsePlugin 

pub struct BaseEventResponsePlugin { /* private fields */ }

Base implementation of EventResponsePlugin

Implementations

impl BaseEventResponsePlugin

pub fn new( id: &str, name: &str, handled_event_types: Vec<EventType>, workflow_steps: Vec<String>, ) -> BaseEventResponsePlugin

Create a new base event response plugin

pub fn with_priority(self, priority: PluginPriority) -> BaseEventResponsePlugin

Set the plugin priority

pub fn with_max_impact_scope(self, _scope: &str) -> BaseEventResponsePlugin

Set the max impact scope

Trait Implementations

impl AgentPlugin for BaseEventResponsePlugin

fn metadata(&self) -> &PluginMetadata

获取插件元数据

fn state(&self) -> PluginState

获取插件状态

fn load<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 PluginContext, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, BaseEventResponsePlugin: 'async_trait,

插件加载（分配资源）

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

where 'life0: 'async_trait, BaseEventResponsePlugin: 'async_trait,

插件初始化（配置初始化）

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

where 'life0: 'async_trait, BaseEventResponsePlugin: 'async_trait,

插件启动

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

where 'life0: 'async_trait, BaseEventResponsePlugin: 'async_trait,

插件停止

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

where 'life0: 'async_trait, BaseEventResponsePlugin: 'async_trait,

插件卸载（释放资源）

fn execute<'life0, 'async_trait>( &'life0 mut self, input: String, ) -> Pin<Box<dyn Future<Output = Result<String, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, BaseEventResponsePlugin: 'async_trait,

执行插件功能

fn stats(&self) -> HashMap<String, Value>

获取插件统计信息

fn as_any(&self) -> &(dyn Any + 'static)

转换为 Any（用于向下转型）

fn as_any_mut(&mut self) -> &mut (dyn Any + 'static)

转换为可变 Any

fn into_any(self: Box<BaseEventResponsePlugin>) -> Box<dyn Any>

消费并转换为 Any（用于提取具体的插件类型）

fn plugin_id(&self) -> &str

获取插件 ID（便捷方法）

fn plugin_type(&self) -> PluginType

获取插件类型

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

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

插件暂停

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

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

插件恢复

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

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

健康检查

impl EventResponsePlugin for BaseEventResponsePlugin

fn config(&self) -> &EventResponseConfig

Get the plugin configuration

fn update_config<'life0, 'async_trait>( &'life0 mut self, config: EventResponseConfig, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, BaseEventResponsePlugin: 'async_trait,

Update the plugin configuration at runtime

fn can_handle(&self, event: &Event) -> bool

Check if this plugin can handle the given event

fn handle_event<'life0, 'async_trait>( &'life0 mut self, event: Event, ) -> Pin<Box<dyn Future<Output = Result<Event, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, BaseEventResponsePlugin: 'async_trait,

Handle the event

fn execute_workflow<'life0, 'life1, 'async_trait>( &'life0 self, event: &'life1 Event, ) -> Pin<Box<dyn Future<Output = Result<HashMap<String, String>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, BaseEventResponsePlugin: 'async_trait,

Execute the response workflow for the event