server

package

Go to main page

Versions in this module

v1

v1.3.0

Jun 1, 2026

Changes in this version

+ type GraphMemoryServer struct

+ func NewGraphMemoryServer(store memory.GraphMemoryStore, logger *zap.Logger) *GraphMemoryServer

+ func (s *GraphMemoryServer) Consolidate(ctx context.Context, req *loomv1.ConsolidateRequest) (*loomv1.ConsolidateResponse, error)

+ func (s *GraphMemoryServer) ContextFor(ctx context.Context, req *loomv1.ContextForRequest) (*loomv1.ContextForResponse, error)

+ func (s *GraphMemoryServer) CreateEntity(ctx context.Context, req *loomv1.CreateEntityRequest) (*loomv1.CreateEntityResponse, error)

+ func (s *GraphMemoryServer) DeleteEntity(ctx context.Context, req *loomv1.DeleteEntityRequest) (*loomv1.DeleteEntityResponse, error)

+ func (s *GraphMemoryServer) Forget(ctx context.Context, req *loomv1.ForgetRequest) (*loomv1.ForgetResponse, error)

+ func (s *GraphMemoryServer) GetEntity(ctx context.Context, req *loomv1.GetEntityRequest) (*loomv1.GetEntityResponse, error)

+ func (s *GraphMemoryServer) GetGraphStats(ctx context.Context, req *loomv1.GetGraphStatsRequest) (*loomv1.GetGraphStatsResponse, error)

+ func (s *GraphMemoryServer) ListEntities(ctx context.Context, req *loomv1.ListEntitiesRequest) (*loomv1.ListEntitiesResponse, error)

+ func (s *GraphMemoryServer) Neighbors(ctx context.Context, req *loomv1.NeighborsRequest) (*loomv1.NeighborsResponse, error)

+ func (s *GraphMemoryServer) Recall(ctx context.Context, req *loomv1.RecallRequest) (*loomv1.RecallResponse, error)

+ func (s *GraphMemoryServer) Relate(ctx context.Context, req *loomv1.RelateRequest) (*loomv1.RelateResponse, error)

+ func (s *GraphMemoryServer) Remember(ctx context.Context, req *loomv1.RememberRequest) (*loomv1.RememberResponse, error)

+ func (s *GraphMemoryServer) Supersede(ctx context.Context, req *loomv1.SupersedeRequest) (*loomv1.SupersedeResponse, error)

+ func (s *GraphMemoryServer) Unrelate(ctx context.Context, req *loomv1.UnrelateRequest) (*loomv1.UnrelateResponse, error)

+ func (s *GraphMemoryServer) UpdateEntity(ctx context.Context, req *loomv1.UpdateEntityRequest) (*loomv1.UpdateEntityResponse, error)

type MultiAgentServer

+ func (s *MultiAgentServer) ClearAllSessions()

+ func (s *MultiAgentServer) CreateWorkflowFromTemplate(ctx context.Context, req *loomv1.CreateWorkflowFromTemplateRequest) (*loomv1.CreateWorkflowFromTemplateResponse, error)

+ func (s *MultiAgentServer) ListAgentPresets(_ context.Context, _ *loomv1.ListAgentPresetsRequest) (*loomv1.ListAgentPresetsResponse, error)

+ func (s *MultiAgentServer) ListAvailableAgents(_ context.Context, _ *builtin.ListAvailableAgentsRequest) (*builtin.ListAvailableAgentsResponse, error)

+ func (s *MultiAgentServer) ListWorkflowTemplates(_ context.Context, _ *loomv1.ListWorkflowTemplatesRequest) (*loomv1.ListWorkflowTemplatesResponse, error)

+ func (s *MultiAgentServer) SetTaskManager(tm *task.Manager)

+ type SkillsImportServer struct

+ func NewSkillsImportServer(cfg SkillsImportServerConfig) (*SkillsImportServer, error)

+ func (s *SkillsImportServer) AddSkill(ctx context.Context, req *loomv1.AddSkillRequest) (*loomv1.AddSkillResponse, error)

+ func (s *SkillsImportServer) BulkImportSkills(req *loomv1.BulkImportSkillsRequest, ...) error

+ func (s *SkillsImportServer) ClassifySkill(ctx context.Context, req *loomv1.ClassifySkillRequest) (*loomv1.ClassifySkillResponse, error)

+ type SkillsImportServerConfig struct

+ Classify types.LLMProvider

+ DefaultOutDir string

+ Logger *zap.Logger

+ Registry *agent.Registry

+ SkillLib *skills.Library

+ Store index.Store

+ Tracer observability.Tracer

+ type TaskServiceImpl struct

+ func NewTaskServiceImpl(manager *task.Manager, bus *communication.MessageBus, logger *zap.Logger) *TaskServiceImpl

+ func (s *TaskServiceImpl) ClaimTask(ctx context.Context, req *loomv1.ClaimTaskRequest) (*loomv1.ClaimTaskResponse, error)

+ func (s *TaskServiceImpl) CloseTask(ctx context.Context, req *loomv1.CloseTaskRequest) (*loomv1.CloseTaskResponse, error)

+ func (s *TaskServiceImpl) CreateBoard(ctx context.Context, req *loomv1.CreateBoardRequest) (*loomv1.CreateBoardResponse, error)

+ func (s *TaskServiceImpl) CreateTask(ctx context.Context, req *loomv1.CreateTaskRequest) (*loomv1.CreateTaskResponse, error)

+ func (s *TaskServiceImpl) GetBoard(ctx context.Context, req *loomv1.GetBoardRequest) (*loomv1.GetBoardResponse, error)

+ func (s *TaskServiceImpl) GetReadyFront(ctx context.Context, req *loomv1.GetReadyFrontRequest) (*loomv1.GetReadyFrontResponse, error)

+ func (s *TaskServiceImpl) GetTask(ctx context.Context, req *loomv1.GetTaskRequest) (*loomv1.GetTaskResponse, error)

+ func (s *TaskServiceImpl) ListBoards(ctx context.Context, _ *loomv1.ListBoardsRequest) (*loomv1.ListBoardsResponse, error)

+ func (s *TaskServiceImpl) ListTasks(ctx context.Context, req *loomv1.ListTasksRequest) (*loomv1.ListTasksResponse, error)

+ func (s *TaskServiceImpl) SetBus(bus *communication.MessageBus)

+ func (s *TaskServiceImpl) StreamTaskUpdates(req *loomv1.StreamTaskUpdatesRequest, ...) error

v1.2.0

Mar 19, 2026

Changes in this version

+ const UserIDHeader

+ func ContainsUIIntent(msg string) bool

+ func UIAppTools(compiler AppCompiler, provider AppProvider) []shuttle.Tool

+ func UserIDStreamInterceptor(cfg UserIDConfig) grpc.StreamServerInterceptor

+ func UserIDUnaryInterceptor(cfg UserIDConfig) grpc.UnaryServerInterceptor

+ func ValidateProviders(ctx context.Context, agents map[string]*agent.Agent) error

+ type AdminServer struct

+ func NewAdminServer(store agent.AdminStorage, adminToken string) *AdminServer

+ func (s *AdminServer) CountSessionsByUser(ctx context.Context, req *loomv1.CountSessionsByUserRequest) (*loomv1.CountSessionsByUserResponse, error)

+ func (s *AdminServer) GetSystemStats(ctx context.Context, req *loomv1.GetSystemStatsRequest) (*loomv1.GetSystemStatsResponse, error)

+ func (s *AdminServer) ListAllSessions(ctx context.Context, req *loomv1.ListAllSessionsRequest) (*loomv1.ListAllSessionsResponse, error)

+ type AppCompiler interface

+ Compile func(spec *loomv1.UIAppSpec) ([]byte, error)

+ ListComponentTypes func() []*loomv1.ComponentType

+ Validate func(spec *loomv1.UIAppSpec) error

+ type AppHTMLProvider interface

+ AppHTML func(name string) ([]byte, error)

+ AppNames func() []string

+ type AppProvider interface

+ CreateApp func(name, displayName, description string, html []byte, overwrite bool) (*apps.AppInfo, bool, error)

+ DeleteApp func(name string) error

+ GetAppHTML func(name string) ([]byte, *apps.AppInfo, error)

+ ListAppInfo func() []apps.AppInfo

+ UpdateApp func(name, displayName, description string, html []byte) (*apps.AppInfo, error)

type HTTPServer

+ func (h *HTTPServer) SetAppHTMLProvider(p AppHTMLProvider)

+ type JudgeServer struct

+ func NewJudgeServer(tracer observability.Tracer, logger *zap.Logger) *JudgeServer

+ func (s *JudgeServer) EvaluateWithJudges(ctx context.Context, req *loomv1.EvaluateRequest) (*loomv1.EvaluateResponse, error)

+ func (s *JudgeServer) EvaluateWithJudgesStream(req *loomv1.EvaluateRequest, ...) error

+ func (s *JudgeServer) GetJudgeConfig(id string) (*loomv1.JudgeConfig, error)

+ func (s *JudgeServer) GetJudgeHistory(_ context.Context, _ *loomv1.GetJudgeHistoryRequest) (*loomv1.GetJudgeHistoryResponse, error)

+ func (s *JudgeServer) RegisterJudge(ctx context.Context, req *loomv1.RegisterJudgeRequest) (*loomv1.RegisterJudgeResponse, error)

+ func (s *JudgeServer) SetProviderPool(pool map[string]agent.LLMProvider, defaultP agent.LLMProvider)

type MultiAgentServer

+ func (s *MultiAgentServer) ABTest(req *loomv1.ABTestRequest, stream loomv1.LoomService_ABTestServer) error

+ func (s *MultiAgentServer) CreateAgentFromConfig(ctx context.Context, req *loomv1.CreateAgentRequest) (*loomv1.AgentInfo, error)

+ func (s *MultiAgentServer) CreateUIApp(ctx context.Context, req *loomv1.CreateUIAppRequest) (*loomv1.CreateUIAppResponse, error)

+ func (s *MultiAgentServer) DeleteAgent(ctx context.Context, req *loomv1.DeleteAgentRequest) (*loomv1.DeleteAgentResponse, error)

+ func (s *MultiAgentServer) DeleteUIApp(ctx context.Context, req *loomv1.DeleteUIAppRequest) (*loomv1.DeleteUIAppResponse, error)

+ func (s *MultiAgentServer) GetAgent(ctx context.Context, req *loomv1.GetAgentRequest) (*loomv1.AgentInfo, error)

+ func (s *MultiAgentServer) GetPattern(ctx context.Context, req *loomv1.GetPatternRequest) (*loomv1.Pattern, error)

+ func (s *MultiAgentServer) GetPendingPermissions() map[string]*pendingPermission

+ func (s *MultiAgentServer) GetStorageStatus(ctx context.Context, _ *loomv1.GetStorageStatusRequest) (*loomv1.GetStorageStatusResponse, error)

+ func (s *MultiAgentServer) GetTrace(ctx context.Context, req *loomv1.GetTraceRequest) (*loomv1.Trace, error)

+ func (s *MultiAgentServer) GetUIApp(ctx context.Context, req *loomv1.GetUIAppRequest) (*loomv1.GetUIAppResponse, error)

+ func (s *MultiAgentServer) GrantToolPermission(permID string, granted bool, message string, remember bool) error

+ func (s *MultiAgentServer) ListComponentTypes(ctx context.Context, req *loomv1.ListComponentTypesRequest) (*loomv1.ListComponentTypesResponse, error)

+ func (s *MultiAgentServer) ListPatterns(ctx context.Context, req *loomv1.ListPatternsRequest) (*loomv1.ListPatternsResponse, error)

+ func (s *MultiAgentServer) ListProviders(ctx context.Context, req *loomv1.ListProvidersRequest) (*loomv1.ListProvidersResponse, error)

+ func (s *MultiAgentServer) ListUIApps(ctx context.Context, req *loomv1.ListUIAppsRequest) (*loomv1.ListUIAppsResponse, error)

+ func (s *MultiAgentServer) LoadPatterns(ctx context.Context, req *loomv1.LoadPatternsRequest) (*loomv1.LoadPatternsResponse, error)

+ func (s *MultiAgentServer) RecordTraceSpan(span *observability.Span)

+ func (s *MultiAgentServer) RegisterTool(ctx context.Context, req *loomv1.RegisterToolRequest) (*loomv1.RegisterToolResponse, error)

+ func (s *MultiAgentServer) ReloadAgent(ctx context.Context, req *loomv1.ReloadAgentRequest) (*loomv1.AgentInfo, error)

+ func (s *MultiAgentServer) RequestToolPermission(ctx context.Context, req *loomv1.ToolPermissionRequest) (*loomv1.ToolPermissionResponse, error)

+ func (s *MultiAgentServer) RunMigration(ctx context.Context, req *loomv1.RunMigrationRequest) (*loomv1.RunMigrationResponse, error)

+ func (s *MultiAgentServer) SetAppCompiler(c AppCompiler)

+ func (s *MultiAgentServer) SetAppProvider(p AppProvider)

+ func (s *MultiAgentServer) SetEvalStore(store *evals.Store)

+ func (s *MultiAgentServer) SetJudgeServer(js *JudgeServer)

+ func (s *MultiAgentServer) SetPatternTracker(tracker *learning.PatternEffectivenessTracker)

+ func (s *MultiAgentServer) SetProviderPool(pool map[string]agent.LLMProvider, active string)

+ func (s *MultiAgentServer) SetServerConfig(config *loomv1.ServerConfig)

+ func (s *MultiAgentServer) SetStorageBackend(sb backend.StorageBackend)

+ func (s *MultiAgentServer) SetStorageBackendType(backendType loomv1.StorageBackendType)

+ func (s *MultiAgentServer) SetTraceStore(maxAge time.Duration)

+ func (s *MultiAgentServer) StartAgent(ctx context.Context, req *loomv1.StartAgentRequest) (*loomv1.AgentInfo, error)

+ func (s *MultiAgentServer) StopAgent(ctx context.Context, req *loomv1.StopAgentRequest) (*loomv1.AgentInfo, error)

+ func (s *MultiAgentServer) UpdateUIApp(ctx context.Context, req *loomv1.UpdateUIAppRequest) (*loomv1.UpdateUIAppResponse, error)

type Server

+ func (s *Server) ABTest(req *loomv1.ABTestRequest, stream loomv1.LoomService_ABTestServer) error

+ func (s *Server) GetProviderPool() map[string]agent.LLMProvider

+ func (s *Server) ListProviders(_ context.Context, _ *loomv1.ListProvidersRequest) (*loomv1.ListProvidersResponse, error)

+ func (s *Server) SetActiveProviderName(name string)

+ func (s *Server) SetEvalStore(store *evals.Store)

+ func (s *Server) SetJudgeServer(js *JudgeServer)

+ func (s *Server) SetProviderPool(pool map[string]agent.LLMProvider, active string)

+ type UserIDConfig struct

+ DefaultUserID string

+ Logger *zap.Logger

+ RequireUserID bool

v1.1.0

Feb 5, 2026

Changes in this version

+ type BusMessage struct

type MultiAgentServer

+ func (s *MultiAgentServer) DespawnSubAgent(ctx context.Context, req *builtin.DespawnSubAgentRequest) (*builtin.DespawnSubAgentResponse, error)

+ func (s *MultiAgentServer) GetWorkflowExecution(ctx context.Context, req *loomv1.GetWorkflowExecutionRequest) (*loomv1.WorkflowExecution, error)

+ func (s *MultiAgentServer) ListWorkflowExecutions(ctx context.Context, req *loomv1.ListWorkflowExecutionsRequest) (*loomv1.ListWorkflowExecutionsResponse, error)

+ func (s *MultiAgentServer) SetTracer(tracer observability.Tracer)

+ func (s *MultiAgentServer) SpawnSubAgent(ctx context.Context, req *builtin.SpawnSubAgentRequest) (*builtin.SpawnSubAgentResponse, error)

+ type PubSubEvent struct

+ Content string

+ FromAgent string

+ Timestamp time.Time

+ ToAgents int

+ Topic string

+ Type string

v1.0.2

Jan 15, 2026

Changes in this version

+ type CORSConfig struct

+ AllowCredentials bool

+ AllowedHeaders []string

+ AllowedMethods []string

+ AllowedOrigins []string

+ Enabled bool

+ ExposedHeaders []string

+ MaxAge int

+ func DefaultCORSConfig() CORSConfig

type HTTPServer

+ func NewHTTPServerWithCORS(grpcServer *MultiAgentServer, httpAddr, grpcAddr string, logger *zap.Logger, ...) *HTTPServer

v1.0.1

Jan 13, 2026

Changes in this version

+ const DefaultProgressBufferSize

+ func ConvertMessage(m *agent.Message) *loomv1.Message

+ func ConvertSession(s *agent.Session) *loomv1.Session

+ func ConvertTool(t shuttle.Tool) *loomv1.ToolDefinition

+ func GenerateSessionID() string

+ type HTTPServer struct

+ func NewHTTPServer(grpcServer *MultiAgentServer, httpAddr, grpcAddr string, logger *zap.Logger) *HTTPServer

+ func (h *HTTPServer) Start(ctx context.Context) error

+ func (h *HTTPServer) Stop(ctx context.Context) error

+ type LearningService struct

+ func NewLearningService(agent *learning.LearningAgent) *LearningService

+ func (s *LearningService) AnalyzePatternEffectiveness(ctx context.Context, req *loomv1.AnalyzePatternEffectivenessRequest) (*loomv1.PatternAnalysisResponse, error)

+ func (s *LearningService) ApplyImprovement(ctx context.Context, req *loomv1.ApplyImprovementRequest) (*loomv1.ApplyImprovementResponse, error)

+ func (s *LearningService) GenerateImprovements(ctx context.Context, req *loomv1.GenerateImprovementsRequest) (*loomv1.ImprovementsResponse, error)

+ func (s *LearningService) GetImprovementHistory(ctx context.Context, req *loomv1.GetImprovementHistoryRequest) (*loomv1.ImprovementHistoryResponse, error)

+ func (s *LearningService) RollbackImprovement(ctx context.Context, req *loomv1.RollbackImprovementRequest) (*loomv1.RollbackImprovementResponse, error)

+ func (s *LearningService) StreamPatternMetrics(req *loomv1.StreamPatternMetricsRequest, ...) error

+ type MultiAgentServer struct

+ func NewMultiAgentServer(agents map[string]*agent.Agent, store *agent.SessionStore) *MultiAgentServer

+ func (s *MultiAgentServer) AddAgent(id string, ag *agent.Agent)

+ func (s *MultiAgentServer) AddMCPServer(ctx context.Context, req *loomv1.AddMCPServerRequest) (*loomv1.AddMCPServerResponse, error)

+ func (s *MultiAgentServer) AnswerClarificationQuestion(ctx context.Context, req *loomv1.AnswerClarificationRequest) (*loomv1.AnswerClarificationResponse, error)

+ func (s *MultiAgentServer) ConfigureCommunication(bus *communication.MessageBus, queue *communication.MessageQueue, ...) error

+ func (s *MultiAgentServer) ConfigureLegacyCommunication(refStore communication.ReferenceStore, policy *communication.PolicyManager) error

+ func (s *MultiAgentServer) ConfigureScheduler(sched *scheduler.Scheduler)

+ func (s *MultiAgentServer) ConfigureSharedMemory(config *storage.Config) error

+ func (s *MultiAgentServer) ConfigureTLS(manager *tls.Manager, config *loomv1.ServerConfig)

+ func (s *MultiAgentServer) CreatePattern(ctx context.Context, req *loomv1.CreatePatternRequest) (*loomv1.CreatePatternResponse, error)

+ func (s *MultiAgentServer) CreateSession(ctx context.Context, req *loomv1.CreateSessionRequest) (*loomv1.Session, error)

+ func (s *MultiAgentServer) DeleteArtifact(ctx context.Context, req *loomv1.DeleteArtifactRequest) (*loomv1.DeleteArtifactResponse, error)

+ func (s *MultiAgentServer) DeleteMCPServer(ctx context.Context, req *loomv1.DeleteMCPServerRequest) (*loomv1.DeleteMCPServerResponse, error)

+ func (s *MultiAgentServer) DeleteScheduledWorkflow(ctx context.Context, req *loomv1.DeleteScheduledWorkflowRequest) (*emptypb.Empty, error)

+ func (s *MultiAgentServer) DeleteSession(ctx context.Context, req *loomv1.DeleteSessionRequest) (*loomv1.DeleteSessionResponse, error)

+ func (s *MultiAgentServer) DeleteSharedMemory(ctx context.Context, req *loomv1.DeleteSharedMemoryRequest) (*loomv1.DeleteSharedMemoryResponse, error)

+ func (s *MultiAgentServer) ExecuteWorkflow(ctx context.Context, req *loomv1.ExecuteWorkflowRequest) (*loomv1.ExecuteWorkflowResponse, error)

+ func (s *MultiAgentServer) GetAgentIDs() []string

+ func (s *MultiAgentServer) GetArtifact(ctx context.Context, req *loomv1.GetArtifactRequest) (*loomv1.GetArtifactResponse, error)

+ func (s *MultiAgentServer) GetArtifactContent(ctx context.Context, req *loomv1.GetArtifactContentRequest) (*loomv1.GetArtifactContentResponse, error)

+ func (s *MultiAgentServer) GetArtifactStats(ctx context.Context, req *loomv1.GetArtifactStatsRequest) (*loomv1.GetArtifactStatsResponse, error)

+ func (s *MultiAgentServer) GetCommunicationComponents() (*communication.MessageBus, *communication.MessageQueue, ...)

+ func (s *MultiAgentServer) GetCommunicationPolicy() *communication.PolicyManager

+ func (s *MultiAgentServer) GetConversationHistory(ctx context.Context, req *loomv1.GetConversationHistoryRequest) (*loomv1.ConversationHistory, error)

+ func (s *MultiAgentServer) GetHealth(ctx context.Context, req *loomv1.GetHealthRequest) (*loomv1.HealthStatus, error)

+ func (s *MultiAgentServer) GetMCPServer(ctx context.Context, req *loomv1.GetMCPServerRequest) (*loomv1.MCPServerInfo, error)

+ func (s *MultiAgentServer) GetReferenceStore() communication.ReferenceStore

+ func (s *MultiAgentServer) GetScheduleHistory(ctx context.Context, req *loomv1.GetScheduleHistoryRequest) (*loomv1.GetScheduleHistoryResponse, error)

+ func (s *MultiAgentServer) GetScheduledWorkflow(ctx context.Context, req *loomv1.GetScheduledWorkflowRequest) (*loomv1.ScheduledWorkflow, error)

+ func (s *MultiAgentServer) GetServerConfig(ctx context.Context, req *loomv1.GetServerConfigRequest) (*loomv1.ServerConfig, error)

+ func (s *MultiAgentServer) GetSession(ctx context.Context, req *loomv1.GetSessionRequest) (*loomv1.Session, error)

+ func (s *MultiAgentServer) GetSharedMemory(ctx context.Context, req *loomv1.GetSharedMemoryRequest) (*loomv1.GetSharedMemoryResponse, error)

+ func (s *MultiAgentServer) GetSharedMemoryStats(ctx context.Context, req *loomv1.GetSharedMemoryStatsRequest) (*loomv1.SharedMemoryStats, error)

+ func (s *MultiAgentServer) GetTLSStatus(ctx context.Context, req *loomv1.GetTLSStatusRequest) (*loomv1.TLSStatus, error)

+ func (s *MultiAgentServer) HealthCheckMCPServers(ctx context.Context, req *loomv1.HealthCheckMCPServersRequest) (*loomv1.HealthCheckMCPServersResponse, error)

+ func (s *MultiAgentServer) ListAgents(ctx context.Context, req *loomv1.ListAgentsRequest) (*loomv1.ListAgentsResponse, error)

+ func (s *MultiAgentServer) ListArtifacts(ctx context.Context, req *loomv1.ListArtifactsRequest) (*loomv1.ListArtifactsResponse, error)

+ func (s *MultiAgentServer) ListAvailableModels(ctx context.Context, req *loomv1.ListAvailableModelsRequest) (*loomv1.ListAvailableModelsResponse, error)

+ func (s *MultiAgentServer) ListMCPServerTools(ctx context.Context, req *loomv1.ListMCPServerToolsRequest) (*loomv1.ListMCPServerToolsResponse, error)

+ func (s *MultiAgentServer) ListMCPServers(ctx context.Context, req *loomv1.ListMCPServersRequest) (*loomv1.ListMCPServersResponse, error)

+ func (s *MultiAgentServer) ListScheduledWorkflows(ctx context.Context, req *loomv1.ListScheduledWorkflowsRequest) (*loomv1.ListScheduledWorkflowsResponse, error)

+ func (s *MultiAgentServer) ListSessions(ctx context.Context, req *loomv1.ListSessionsRequest) (*loomv1.ListSessionsResponse, error)

+ func (s *MultiAgentServer) ListSharedMemoryKeys(ctx context.Context, req *loomv1.ListSharedMemoryKeysRequest) (*loomv1.ListSharedMemoryKeysResponse, error)

+ func (s *MultiAgentServer) ListTools(ctx context.Context, req *loomv1.ListToolsRequest) (*loomv1.ListToolsResponse, error)

+ func (s *MultiAgentServer) PauseSchedule(ctx context.Context, req *loomv1.PauseScheduleRequest) (*emptypb.Empty, error)

+ func (s *MultiAgentServer) Publish(ctx context.Context, req *loomv1.PublishRequest) (*loomv1.PublishResponse, error)

+ func (s *MultiAgentServer) PutSharedMemory(ctx context.Context, req *loomv1.PutSharedMemoryRequest) (*loomv1.PutSharedMemoryResponse, error)

+ func (s *MultiAgentServer) RegisterServerProgressListener(agentName string, logger *zap.Logger)

+ func (s *MultiAgentServer) RemoveAgent(id string) error

+ func (s *MultiAgentServer) RenewCertificate(ctx context.Context, req *loomv1.RenewCertificateRequest) (*loomv1.RenewCertificateResponse, error)

+ func (s *MultiAgentServer) RestartMCPServer(ctx context.Context, req *loomv1.RestartMCPServerRequest) (*loomv1.MCPServerInfo, error)

+ func (s *MultiAgentServer) ResumeSchedule(ctx context.Context, req *loomv1.ResumeScheduleRequest) (*emptypb.Empty, error)

+ func (s *MultiAgentServer) ScheduleWorkflow(ctx context.Context, req *loomv1.ScheduleWorkflowRequest) (*loomv1.ScheduleWorkflowResponse, error)

+ func (s *MultiAgentServer) SearchArtifacts(ctx context.Context, req *loomv1.SearchArtifactsRequest) (*loomv1.SearchArtifactsResponse, error)

+ func (s *MultiAgentServer) SendAndReceive(ctx context.Context, req *loomv1.SendAndReceiveRequest) (*loomv1.SendAndReceiveResponse, error)

+ func (s *MultiAgentServer) SendAsync(ctx context.Context, req *loomv1.SendAsyncRequest) (*loomv1.SendAsyncResponse, error)

+ func (s *MultiAgentServer) SetAgentRegistry(registry *agent.Registry)

+ func (s *MultiAgentServer) SetArtifactStore(store artifacts.ArtifactStore)

+ func (s *MultiAgentServer) SetClarificationConfig(channelSendTimeoutMs int)

+ func (s *MultiAgentServer) SetLLMConcurrencyLimit(limit int)

+ func (s *MultiAgentServer) SetLogger(logger *zap.Logger)

+ func (s *MultiAgentServer) SetMCPManager(mgr *manager.Manager, configPath string, logger *zap.Logger)

+ func (s *MultiAgentServer) SetProgressMultiplexer(agentID string, pm *metaagent.ProgressMultiplexer)

+ func (s *MultiAgentServer) SetProviderFactory(f *factory.ProviderFactory)

+ func (s *MultiAgentServer) SetToolRegistry(registry *toolregistry.Registry)

+ func (s *MultiAgentServer) SharedMemoryStore() *storage.SharedMemoryStore

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

+ func (s *MultiAgentServer) StartHotReload(ctx context.Context, logger *zap.Logger) error

+ func (s *MultiAgentServer) StartMessageQueueMonitor(ctx context.Context)

+ func (s *MultiAgentServer) StopHotReload() error

+ func (s *MultiAgentServer) StreamPatternUpdates(req *loomv1.StreamPatternUpdatesRequest, ...) error

+ func (s *MultiAgentServer) StreamWeave(req *loomv1.WeaveRequest, stream loomv1.LoomService_StreamWeaveServer) error

+ func (s *MultiAgentServer) StreamWorkflow(req *loomv1.ExecuteWorkflowRequest, ...) error

+ func (s *MultiAgentServer) Subscribe(req *loomv1.SubscribeRequest, stream loomv1.LoomService_SubscribeServer) error

+ func (s *MultiAgentServer) SubscribeToSession(req *loomv1.SubscribeToSessionRequest, ...) error

+ func (s *MultiAgentServer) SwitchModel(ctx context.Context, req *loomv1.SwitchModelRequest) (*loomv1.SwitchModelResponse, error)

+ func (s *MultiAgentServer) TestMCPServerConnection(ctx context.Context, req *loomv1.TestMCPServerConnectionRequest) (*loomv1.TestMCPServerConnectionResponse, error)

+ func (s *MultiAgentServer) TriggerScheduledWorkflow(ctx context.Context, req *loomv1.TriggerScheduledWorkflowRequest) (*loomv1.ExecuteWorkflowResponse, error)

+ func (s *MultiAgentServer) UpdateAgent(id string, ag *agent.Agent) error

+ func (s *MultiAgentServer) UpdateMCPServer(ctx context.Context, req *loomv1.UpdateMCPServerRequest) (*loomv1.MCPServerInfo, error)

+ func (s *MultiAgentServer) UpdateScheduledWorkflow(ctx context.Context, req *loomv1.UpdateScheduledWorkflowRequest) (*loomv1.ScheduleWorkflowResponse, error)

+ func (s *MultiAgentServer) UploadArtifact(ctx context.Context, req *loomv1.UploadArtifactRequest) (*loomv1.UploadArtifactResponse, error)

+ func (s *MultiAgentServer) WatchSharedMemory(req *loomv1.WatchSharedMemoryRequest, ...) error

+ func (s *MultiAgentServer) Weave(ctx context.Context, req *loomv1.WeaveRequest) (*loomv1.WeaveResponse, error)

+ type PatternEventBroadcaster struct

+ func NewPatternEventBroadcaster() *PatternEventBroadcaster

+ func (b *PatternEventBroadcaster) Broadcast(event *loomv1.PatternUpdateEvent)

+ func (b *PatternEventBroadcaster) BroadcastPatternCreated(agentID, patternName, category, filePath string)

+ func (b *PatternEventBroadcaster) BroadcastPatternDeleted(agentID, patternName, category string)

+ func (b *PatternEventBroadcaster) BroadcastPatternModified(agentID, patternName, category, filePath string)

+ func (b *PatternEventBroadcaster) BroadcastPatternValidationFailed(agentID, patternName, errorMsg string)

+ func (b *PatternEventBroadcaster) Close()

+ func (b *PatternEventBroadcaster) Subscribe() chan *loomv1.PatternUpdateEvent

+ func (b *PatternEventBroadcaster) Unsubscribe(ch chan *loomv1.PatternUpdateEvent)

+ type Server struct

+ func NewServer(ag *agent.Agent, store *agent.SessionStore) *Server

+ func (s *Server) CreateSession(ctx context.Context, req *loomv1.CreateSessionRequest) (*loomv1.Session, error)

+ func (s *Server) DeleteSession(ctx context.Context, req *loomv1.DeleteSessionRequest) (*loomv1.DeleteSessionResponse, error)

+ func (s *Server) GetConversationHistory(ctx context.Context, req *loomv1.GetConversationHistoryRequest) (*loomv1.ConversationHistory, error)

+ func (s *Server) GetHealth(ctx context.Context, req *loomv1.GetHealthRequest) (*loomv1.HealthStatus, error)

+ func (s *Server) GetPattern(ctx context.Context, req *loomv1.GetPatternRequest) (*loomv1.Pattern, error)

+ func (s *Server) GetSession(ctx context.Context, req *loomv1.GetSessionRequest) (*loomv1.Session, error)

+ func (s *Server) GetTrace(ctx context.Context, req *loomv1.GetTraceRequest) (*loomv1.Trace, error)

+ func (s *Server) ListAvailableModels(ctx context.Context, req *loomv1.ListAvailableModelsRequest) (*loomv1.ListAvailableModelsResponse, error)

+ func (s *Server) ListAvailableModelsLegacy(ctx context.Context, req *loomv1.ListAvailableModelsRequest) (*loomv1.ListAvailableModelsResponse, error)

+ func (s *Server) ListPatterns(ctx context.Context, req *loomv1.ListPatternsRequest) (*loomv1.ListPatternsResponse, error)

+ func (s *Server) ListSessions(ctx context.Context, req *loomv1.ListSessionsRequest) (*loomv1.ListSessionsResponse, error)

+ func (s *Server) ListTools(ctx context.Context, req *loomv1.ListToolsRequest) (*loomv1.ListToolsResponse, error)

+ func (s *Server) LoadPatterns(ctx context.Context, req *loomv1.LoadPatternsRequest) (*loomv1.LoadPatternsResponse, error)

+ func (s *Server) RegisterTool(ctx context.Context, req *loomv1.RegisterToolRequest) (*loomv1.RegisterToolResponse, error)

+ func (s *Server) RequestToolPermission(ctx context.Context, req *loomv1.ToolPermissionRequest) (*loomv1.ToolPermissionResponse, error)

+ func (s *Server) SetProviderFactory(f *factory.ProviderFactory)

+ func (s *Server) StreamWeave(req *loomv1.WeaveRequest, stream loomv1.LoomService_StreamWeaveServer) error

+ func (s *Server) SwitchModel(ctx context.Context, req *loomv1.SwitchModelRequest) (*loomv1.SwitchModelResponse, error)

+ func (s *Server) Weave(ctx context.Context, req *loomv1.WeaveRequest) (*loomv1.WeaveResponse, error)

+ type WorkflowExecution struct

+ EndTime time.Time

+ Error string

+ ExecutionID string

+ Pattern *loomv1.WorkflowPattern

+ Result *loomv1.WorkflowResult

+ StartTime time.Time

+ Status WorkflowStatus

+ type WorkflowStatus string

+ const WorkflowStatusCanceled

+ const WorkflowStatusCompleted

+ const WorkflowStatusFailed

+ const WorkflowStatusRunning

+ type WorkflowStore struct

+ func NewWorkflowStore() *WorkflowStore

+ func (s *WorkflowStore) Count() int

+ func (s *WorkflowStore) Delete(executionID string) error

+ func (s *WorkflowStore) Get(executionID string) (*WorkflowExecution, error)

+ func (s *WorkflowStore) List(status WorkflowStatus) []*WorkflowExecution

+ func (s *WorkflowStore) Store(exec *WorkflowExecution)

+ func (s *WorkflowStore) StoreResult(executionID string, result *loomv1.WorkflowResult) error

+ func (s *WorkflowStore) UpdateStatus(executionID string, status WorkflowStatus, errorMsg string) error

v1.0.0

Jan 9, 2026

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL