plugin

type AppFrameworkPlugin struct {
	hashiPlugin.Plugin
	Impl Module
}

type DefaultModule struct {
	// 模块名称
	Name string

	// 模块版本
	Version string

	// 模块描述
	Description string

	// 支持的操作列表
	SupportedActions []string

	// 配置
	Config map[string]interface{}
}

type GRPCClient struct {
	// contains filtered or unexported fields
}

type GRPCServer struct {
	pb.UnimplementedModuleServer
	Impl Module
}

type IsolationLevel int

type LoadedPlugin struct {
	Metadata  PluginMetadata
	Instance  interface{}
	Client    *hashiPlugin.Client
	RawPlugin *plugin.Plugin
}

type ManagedPlugin struct {
	ID        string
	Name      string
	Version   string
	Path      string
	Client    *plugin.Client
	Interface interface{}
	Sandbox   *PluginSandbox
	Config    *PluginConfig
	State     PluginState
	LastError error
	StartTime time.Time
	StopTime  time.Time
}

type ManagerConfigV2 struct {
	// 插件目录
	PluginsDir string

	// 自动发现
	AutoDiscover bool

	// 扫描间隔
	ScanInterval time.Duration

	// 健康检查间隔
	HealthCheckInterval time.Duration

	// 自动启动
	AutoStart bool
}

type ManagerConfigV3 struct {
	// 插件目录
	PluginsDir string

	// 自动发现
	AutoDiscover bool

	// 扫描间隔
	ScanInterval time.Duration

	// 健康检查间隔
	HealthCheckInterval time.Duration

	// 自动启动
	AutoStart bool

	// 隔离级别
	IsolationLevel isolation.IsolationLevel

	// 资源限制
	ResourceLimits map[string]int64

	// 操作超时
	OperationTimeout time.Duration
}

type Message struct {
	ID          string                 // 消息ID
	Type        MessageType            // 消息类型
	Source      string                 // 消息源
	Destination string                 // 消息目标
	Topic       string                 // 消息主题
	Payload     map[string]interface{} // 消息负载
	Timestamp   time.Time              // 时间戳
}

type MessageHandler func(ctx context.Context, msg Message) (Message, error)

type MessageType string

type Module interface {
	// Init 初始化模块
	Init(config map[string]interface{}) error

	// Execute 执行模块操作
	Execute(action string, params map[string]interface{}) (map[string]interface{}, error)

	// Shutdown 关闭模块
	Shutdown() error

	// GetInfo 获取模块信息
	GetInfo() ModuleInfo

	// HandleMessage 处理消息
	HandleMessage(messageType string, messageID string, timestamp int64, payload map[string]interface{}) (map[string]interface{}, error)
}

type ModuleInfo struct {
	Name             string   `json:"name"`
	Version          string   `json:"version"`
	Description      string   `json:"description"`
	SupportedActions []string `json:"supported_actions"`
}

type ModulePlugin struct {
	plugin.Plugin
	Impl Module
}

type PluginCommunicationClient struct {
	// contains filtered or unexported fields
}

type PluginCommunicationInterface interface {
	// SendMessage 发送消息
	SendMessage(ctx context.Context, msg Message) (Message, error)

	// PublishEvent 发布事件
	PublishEvent(ctx context.Context, topic string, payload map[string]interface{}) error

	// Subscribe 订阅主题
	Subscribe(topic string) error

	// Unsubscribe 取消订阅主题
	Unsubscribe(topic string) error

	// GetSubscriptions 获取订阅
	GetSubscriptions() []string
}

type PluginCommunicator struct {
	// contains filtered or unexported fields
}

type PluginConfig struct {
	ID             string
	Name           string
	Version        string
	Path           string
	IsolationLevel IsolationLevel
	AutoStart      bool
	AutoRestart    bool
	Enabled        bool
	Dependencies   []string
	ResourceLimits map[string]int
	Environment    map[string]string
	Args           []string
	Timeout        time.Duration
}

type PluginDependency struct {
	ID       string // 依赖的插件ID
	Version  string // 依赖的插件版本
	Optional bool   // 是否可选
}

type PluginDependencyManager struct {
	// contains filtered or unexported fields
}

type PluginExecutor struct {
	// contains filtered or unexported fields
}

type PluginExecutorOption func(*PluginExecutor)

type PluginIsolationConfig struct {
	Level           IsolationLevel         // 隔离级别
	ResourceLimits  map[string]int         // 资源限制
	TimeoutDuration time.Duration          // 超时时间
	MemoryLimit     int64                  // 内存限制（字节）
	CPULimit        int                    // CPU限制（百分比）
	IOLimit         int                    // IO限制（操作/秒）
	NetworkLimit    int                    // 网络限制（字节/秒）
	AllowedAPIs     map[string]bool        // 允许的API
	BlockedAPIs     map[string]bool        // 阻止的API
	Environment     map[string]string      // 环境变量
	WorkingDir      string                 // 工作目录
	LogLevel        string                 // 日志级别
	ErrorHandler    errors.ErrorHandler    // 错误处理器
	RecoveryHandler errors.RecoveryHandler // 恢复处理器
}

type PluginIsolationStats struct {
	TotalCalls         int64
	SuccessfulCalls    int64
	FailedCalls        int64
	Timeouts           int64
	ResourceViolations int64
	Panics             int64
	TotalExecutionTime time.Duration
	AvgExecutionTime   time.Duration
	MaxExecutionTime   time.Duration
	MinExecutionTime   time.Duration
}

type PluginIsolator struct {
	// contains filtered or unexported fields
}

type PluginIsolatorOption func(*PluginIsolator)

type PluginLoader struct {
	// contains filtered or unexported fields
}

type PluginManager struct {
	// contains filtered or unexported fields
}

type PluginManagerOption func(*PluginManager)

type PluginManagerV2 struct {
	// contains filtered or unexported fields
}

type PluginManagerV3 struct {
	// contains filtered or unexported fields
}

type PluginMetadata struct {
	ID             string    // 插件ID
	Name           string    // 插件名称
	Version        string    // 插件版本
	Author         string    // 插件作者
	Description    string    // 插件描述
	Website        string    // 插件网站
	License        string    // 插件许可证
	Dependencies   []string  // 插件依赖
	Tags           []string  // 插件标签
	CreatedAt      time.Time // 创建时间
	UpdatedAt      time.Time // 更新时间
	Enabled        bool      // 是否启用
	Optional       bool      // 是否可选
	Path           string    // 插件路径
	EntryPoint     string    // 插件入口点
	IsolationLevel string    // 隔离级别
}

type PluginSandbox struct {
	// contains filtered or unexported fields
}

type PluginSandboxOption func(*PluginSandbox)

type PluginState int