api

Documentation

Index

• func StartMeshServer(port int, agents []core.Agent, store memory.Store, embedder llm.Embedder) error
• type MeshServer
  • func NewMeshServer() *MeshServer
  • func (s *MeshServer) DelegateTask(ctx context.Context, req *mesh.TaskRequest) (*mesh.TaskResponse, error)
  • func (s *MeshServer) IndexKnowledge(ctx context.Context, req *mesh.IndexRequest) (*mesh.IndexResponse, error)
  • func (s *MeshServer) SearchKnowledge(ctx context.Context, req *mesh.SearchRequest) (*mesh.SearchResponse, error)
  • func (s *MeshServer) Start(port string) error
• type Server
  • func NewServer() *Server
  • func (s *Server) Run(addr string) error
  • func (s *Server) ServeStatic(fs http.FileSystem)

Functions

func StartMeshServer

func StartMeshServer(port int, agents []core.Agent, store memory.Store, embedder llm.Embedder) error

StartMeshServer starts the gRPC server on the given port.

Types

type MeshServer

type MeshServer struct {
	mesh.UnimplementedMeshServiceServer
	// contains filtered or unexported fields
}

MeshServer implements the MeshService gRPC server.

func NewMeshServer

func NewMeshServer() *MeshServer

func (*MeshServer) DelegateTask

func (s *MeshServer) DelegateTask(ctx context.Context, req *mesh.TaskRequest) (*mesh.TaskResponse, error)

func (*MeshServer) IndexKnowledge

func (s *MeshServer) IndexKnowledge(ctx context.Context, req *mesh.IndexRequest) (*mesh.IndexResponse, error)

func (*MeshServer) SearchKnowledge

func (s *MeshServer) SearchKnowledge(ctx context.Context, req *mesh.SearchRequest) (*mesh.SearchResponse, error)

func (*MeshServer) Start

func (s *MeshServer) Start(port string) error

Start launches the gRPC server on the given port.

type Server

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

Server represents the API and Streaming server.

func NewServer

func NewServer() *Server

NewServer creates a new API server with CORS enabled.

func (*Server) Run

func (s *Server) Run(addr string) error

Run starts the server on the given address.

func (*Server) ServeStatic

func (s *Server) ServeStatic(fs http.FileSystem)

ServeStatic enables the delivery of static files from an embedded filesystem.