New creates a new controller server.
(c *controller.Controller)
| 47 | |
| 48 | // New creates a new controller server. |
| 49 | func New(c *controller.Controller) *Server { |
| 50 | return &Server{ |
| 51 | controller: c, |
| 52 | inFlight: make(map[string]struct{}), |
| 53 | } |
| 54 | } |
| 55 | |
| 56 | // Exec executes a new agentic task with streaming responses. |
| 57 | func (s *Server) Exec(req *proto.ExecRequest, stream grpc.ServerStreamingServer[proto.ExecResponse]) error { |
no outgoing calls