server

Jun 25, 2026

Changes in this version

+ func PollStale(broadcaster *SSEBroadcaster, store storage.Storage, g interface{ ... }, ...)

type MCPServer

+ func (s *MCPServer) ServeHTTP(addr string) error

+ func (s *MCPServer) ServeHTTPWithShutdown(addr string) (*mcpserver.StreamableHTTPServer, error)

type MemoryEvent

+ Content string

+ NodeID string

+ Timestamp int64

+ Type MemoryEventType

+ type MemoryEventType string

+ const MemoryEventCreated

+ const MemoryEventDeleted

+ const MemoryEventUpdated

type RESTServer

+ func (s *RESTServer) Shutdown(ctx context.Context) error

+ func (s *RESTServer) WithAPIKey(key string) *RESTServer

+ func (s *RESTServer) WithBroadcaster(b *SSEBroadcaster) *RESTServer

+ func (s *RESTServer) WithProjectDir(dir string) *RESTServer

+ type SSEBroadcaster struct

+ func NewSSEBroadcaster(eng *engine.Engine) *SSEBroadcaster

+ func (b *SSEBroadcaster) BroadcastMemoryEvent(evt MemoryEvent)

+ func (b *SSEBroadcaster) BroadcastStaleEvent(evt StaleEvent)

+ func (b *SSEBroadcaster) Start(ctx context.Context)

+ type StaleEvent struct

+ FilePath string

+ NodeID string

+ Reason string

+ Timestamp int64

Apr 28, 2026

Changes in this version

+ func ServeDashboard(mux *http.ServeMux)

+ type GRPCEdge struct

+ Acyclic bool

+ FromID string

+ ID string

+ ToID string

+ Type string

+ Weight float64

+ type GRPCNode struct

+ Confidence float64

+ Content string

+ ID string

+ Project string

+ Scope string

+ SourceAgent string

+ SourceSession string

+ Summary string

+ Tags string

+ Tier int

+ Type string

+ type GRPCServer struct

+ func NewGRPCServer(eng *engine.Engine, addr string) *GRPCServer

+ func (s *GRPCServer) ListenAndServe() error

+ func (s *GRPCServer) NotifyWatchers(event string, node *storage.Node)

+ type MCPServer struct

+ ToolProfile string

+ func NewMCPServer(eng *engine.Engine, profile string) *MCPServer

+ func (s *MCPServer) ServeStdio() error

+ type MemoryEvent struct

+ Event string

+ Node *GRPCNode

+ type RESTServer struct

+ SSE *SSEBroker

+ func NewRESTServer(eng *engine.Engine, addr string) *RESTServer

+ func (s *RESTServer) ListenAndServe() error

+ func (s *RESTServer) RegisterRoutes(mux *http.ServeMux)

+ func (s *RESTServer) WithEmbedder(p embeddings.Provider) *RESTServer

+ func (s *RESTServer) WithTLS(cfg *stdtls.Config) *RESTServer

+ type SSEBroker struct

+ func NewSSEBroker() *SSEBroker

+ func (b *SSEBroker) Publish(event string, data any)

+ func (b *SSEBroker) ServeHTTP(w http.ResponseWriter, r *http.Request)