DefaultActorEngineConfig 默认配置
()
| 55 | |
| 56 | // DefaultActorEngineConfig 默认配置 |
| 57 | func DefaultActorEngineConfig() *ActorEngineConfig { |
| 58 | return &ActorEngineConfig{ |
| 59 | SystemName: "workflow", |
| 60 | DefaultTimeout: 5 * time.Minute, |
| 61 | MaxConcurrentAgents: 10, |
| 62 | SupervisorStrategy: actor.NewOneForOneStrategy(3, time.Minute, actor.DefaultDecider), |
| 63 | EnableMetrics: true, |
| 64 | } |
| 65 | } |
| 66 | |
| 67 | // NewActorEngine 创建 Actor 化的工作流引擎 |
| 68 | func NewActorEngine(config *EngineConfig, actorConfig *ActorEngineConfig) (*ActorEngine, error) { |
no test coverage detected