Versions in this module Expand all Collapse all v0 v0.0.1 Feb 11, 2026 Changes in this version + type Handler struct + func NewHandler(processor agent.TaskProcessor, logger zerolog.Logger) *Handler + func (h *Handler) HandleHealth(w http.ResponseWriter, r *http.Request) + func (h *Handler) HandleTask(w http.ResponseWriter, r *http.Request) + func (h *Handler) HandleTaskStream(w http.ResponseWriter, r *http.Request) + type RunHandler struct + func NewRunHandler(runner *runner.TaskRunner, store *store.MongoStore, logger zerolog.Logger) *RunHandler + func (h *RunHandler) CancelRun(w http.ResponseWriter, r *http.Request) + func (h *RunHandler) CreateOnThread(w http.ResponseWriter, r *http.Request) + func (h *RunHandler) CreateOnThreadAndStream(w http.ResponseWriter, r *http.Request) + func (h *RunHandler) CreateOnThreadAndWait(w http.ResponseWriter, r *http.Request) + func (h *RunHandler) CreateStateless(w http.ResponseWriter, r *http.Request) + func (h *RunHandler) CreateStatelessStream(w http.ResponseWriter, r *http.Request) + func (h *RunHandler) CreateStatelessWait(w http.ResponseWriter, r *http.Request) + func (h *RunHandler) GetRun(w http.ResponseWriter, r *http.Request) + func (h *RunHandler) ListByThread(w http.ResponseWriter, r *http.Request) + func (h *RunHandler) StreamRun(w http.ResponseWriter, r *http.Request) + func (h *RunHandler) WaitRun(w http.ResponseWriter, r *http.Request) + type Server struct + func NewServer(processor agent.TaskProcessor, taskRunner *runner.TaskRunner, ...) *Server + func (s *Server) Shutdown(ctx context.Context) error + func (s *Server) Start() error + type ThreadHandler struct + func NewThreadHandler(store *store.MongoStore, logger zerolog.Logger) *ThreadHandler + func (h *ThreadHandler) Create(w http.ResponseWriter, r *http.Request) + func (h *ThreadHandler) Delete(w http.ResponseWriter, r *http.Request) + func (h *ThreadHandler) Get(w http.ResponseWriter, r *http.Request) + func (h *ThreadHandler) History(w http.ResponseWriter, r *http.Request) + func (h *ThreadHandler) Patch(w http.ResponseWriter, r *http.Request) + func (h *ThreadHandler) Search(w http.ResponseWriter, r *http.Request)