initializeA2A initializes A2A protocol support
()
| 177 | |
| 178 | // initializeA2A initializes A2A protocol support |
| 179 | func (s *Server) initializeA2A() { |
| 180 | // 创建 Actor System |
| 181 | systemConfig := actor.DefaultSystemConfig() |
| 182 | systemConfig.MailboxSize = 10000 |
| 183 | s.actorSystem = actor.NewSystemWithConfig("aster-server", systemConfig) |
| 184 | |
| 185 | // 创建任务存储 |
| 186 | taskStore := a2a.NewInMemoryTaskStore() |
| 187 | |
| 188 | // 创建 A2A Server |
| 189 | s.a2aServer = a2a.NewServer(s.actorSystem, taskStore) |
| 190 | |
| 191 | fmt.Println("✅ A2A protocol support initialized") |
| 192 | } |
| 193 | |
| 194 | // setupMiddleware configures all middleware |
| 195 | func (s *Server) setupMiddleware() { |
no test coverage detected