api

Documentation

Index

• type Handler
  • 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
  • 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
  • func NewServer(processor agent.TaskProcessor, taskRunner *runner.TaskRunner, ...) *Server
  • func (s *Server) Shutdown(ctx context.Context) error
  • func (s *Server) Start() error
• type ThreadHandler
  • 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)

Types

type Handler

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

func NewHandler

func NewHandler(processor agent.TaskProcessor, logger zerolog.Logger) *Handler

func (*Handler) HandleHealth

func (h *Handler) HandleHealth(w http.ResponseWriter, r *http.Request)

func (*Handler) HandleTask

func (h *Handler) HandleTask(w http.ResponseWriter, r *http.Request)

func (*Handler) HandleTaskStream

func (h *Handler) HandleTaskStream(w http.ResponseWriter, r *http.Request)

type RunHandler

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

func NewRunHandler

func NewRunHandler(runner *runner.TaskRunner, store *store.MongoStore, logger zerolog.Logger) *RunHandler

func (*RunHandler) CancelRun

func (h *RunHandler) CancelRun(w http.ResponseWriter, r *http.Request)

POST /runs/{run_id}/cancel

func (*RunHandler) CreateOnThread

func (h *RunHandler) CreateOnThread(w http.ResponseWriter, r *http.Request)

POST /threads/{thread_id}/runs — create background run

func (*RunHandler) CreateOnThreadAndStream

func (h *RunHandler) CreateOnThreadAndStream(w http.ResponseWriter, r *http.Request)

POST /threads/{thread_id}/runs/stream — create run on thread, SSE stream

func (*RunHandler) CreateOnThreadAndWait

func (h *RunHandler) CreateOnThreadAndWait(w http.ResponseWriter, r *http.Request)

POST /threads/{thread_id}/runs/wait — create run on thread, wait for result

func (*RunHandler) CreateStateless

func (h *RunHandler) CreateStateless(w http.ResponseWriter, r *http.Request)

POST /runs — background stateless run

func (*RunHandler) CreateStatelessStream

func (h *RunHandler) CreateStatelessStream(w http.ResponseWriter, r *http.Request)

POST /runs/stream — stateless run (creates ephemeral thread)

func (*RunHandler) CreateStatelessWait

func (h *RunHandler) CreateStatelessWait(w http.ResponseWriter, r *http.Request)

POST /runs/wait — stateless run, wait for result

func (*RunHandler) GetRun

func (h *RunHandler) GetRun(w http.ResponseWriter, r *http.Request)

GET /runs/{run_id}

func (*RunHandler) ListByThread

func (h *RunHandler) ListByThread(w http.ResponseWriter, r *http.Request)

GET /threads/{thread_id}/runs — list runs for thread

func (*RunHandler) StreamRun

func (h *RunHandler) StreamRun(w http.ResponseWriter, r *http.Request)

GET /runs/{run_id}/stream — reconnect to an existing run's SSE stream

func (*RunHandler) WaitRun

func (h *RunHandler) WaitRun(w http.ResponseWriter, r *http.Request)

GET /runs/{run_id}/wait — wait for run to finish

type Server

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

func NewServer

func NewServer(processor agent.TaskProcessor, taskRunner *runner.TaskRunner, mongoStore *store.MongoStore, port string, logger zerolog.Logger) *Server

func (*Server) Shutdown

func (s *Server) Shutdown(ctx context.Context) error

func (*Server) Start

func (s *Server) Start() error

type ThreadHandler

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

func NewThreadHandler

func NewThreadHandler(store *store.MongoStore, logger zerolog.Logger) *ThreadHandler

func (*ThreadHandler) Create

func (h *ThreadHandler) Create(w http.ResponseWriter, r *http.Request)

POST /threads

func (*ThreadHandler) Delete

func (h *ThreadHandler) Delete(w http.ResponseWriter, r *http.Request)

DELETE /threads/{thread_id}

func (*ThreadHandler) Get

func (h *ThreadHandler) Get(w http.ResponseWriter, r *http.Request)

GET /threads/{thread_id}

func (*ThreadHandler) History

func (h *ThreadHandler) History(w http.ResponseWriter, r *http.Request)

GET /threads/{thread_id}/history

func (*ThreadHandler) Patch

func (h *ThreadHandler) Patch(w http.ResponseWriter, r *http.Request)

PATCH /threads/{thread_id}

func (*ThreadHandler) Search

func (h *ThreadHandler) Search(w http.ResponseWriter, r *http.Request)

POST /threads/search