httpapi

Documentation

Overview

Package httpapi serves the 2dph brain over HTTP.

Async by design: every request runs on its own goroutine, and CPU-heavy searches are serialized through a bounded worker pool so N requests can't spawn N backends at once.

Used by bin/brain/serve.go. Tests inject a fake API (no exec, no ladybug).

Index

• func NewServer(api API, workers int) http.Handler
• func Run(api API)
• type API
• type ExecSearcher
  • func (ExecSearcher) Audit(context.Context) ([]byte, error)
  • func (ExecSearcher) Get(context.Context, string, bool) ([]byte, error)
  • func (ExecSearcher) Ingest(context.Context) ([]byte, error)
  • func (b ExecSearcher) Search(ctx context.Context, query string, limit int) ([]byte, error)
  • func (ExecSearcher) Stats(context.Context) ([]byte, error)
• type Server
  • func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

Functions

func NewServer

func NewServer(api API, workers int) http.Handler

func Run

func Run(api API)

Run starts the HTTP server with an injected API (in-process brain, or ExecSearcher).

Types

type API

type API interface {
	Search(ctx context.Context, query string, limit int) ([]byte, error)
	Get(ctx context.Context, id string, body bool) ([]byte, error)
	Stats(ctx context.Context) ([]byte, error)
	Audit(ctx context.Context) ([]byte, error)
	Ingest(ctx context.Context) ([]byte, error)
}

API is the in-process brain surface. Production serve.go wires internal/brain.

type ExecSearcher

type ExecSearcher struct {
	CmdPath string
	Timeout time.Duration
}

ExecSearcher shells out to var/bin/brain-search. Fallback when the serve binary is built without ladybug cgo (CI / tags=brain_serve only).

func (ExecSearcher) Audit

func (ExecSearcher) Audit(context.Context) ([]byte, error)

func (ExecSearcher) Get

func (ExecSearcher) Get(context.Context, string, bool) ([]byte, error)

func (ExecSearcher) Ingest

func (ExecSearcher) Ingest(context.Context) ([]byte, error)

func (ExecSearcher) Search

func (b ExecSearcher) Search(ctx context.Context, query string, limit int) ([]byte, error)

func (ExecSearcher) Stats

func (ExecSearcher) Stats(context.Context) ([]byte, error)

type Server

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

func (*Server) ServeHTTP

func (s *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)