Versions in this module Expand all Collapse all v1 v1.3.8 May 19, 2026 Changes in this version + func DecodePayload(payload map[string]any, target any) error + func WriteRequest(w io.Writer, request Request) error + func WriteResponse(w io.Writer, response Response) error + type Backend struct + func NewBackend(repo *store.Repository, kgStore *kg.Store, diaryStore *diary.Store, ...) *Backend + func (b *Backend) Close() error + func (b *Backend) Handle(ctx context.Context, request Request) Response + type CorpusDocumentPayload struct + Content string + CreatedAt string + Depth int + Extract string + ID string + Mode string + UpdatedAt string + type EnsureCorpusPayload struct + Documents []CorpusDocumentPayload + Key string + type Request struct + Command string + ID string + Payload map[string]any + func ReadRequest(r io.Reader) (Request, error) + type Response struct + Error string + ID string + Payload map[string]any + Success bool + func Call(ctx context.Context, socketPath string, request Request) (Response, error) + func ReadResponse(r io.Reader) (Response, error) + type SearchCorpusPayload struct + Key string + Limit int + Query string + type Server struct + func NewServer(socketPath string, backend *Backend) *Server + func (s *Server) Run(ctx context.Context) error
Go to main page