manager

func (*Manager) Ask ¶

func (m *Manager) Ask(ctx context.Context, request schema.AskRequest, fn opt.StreamFn) (*schema.AskResponse, error)

Ask processes a message and returns a response, outside of a session context (stateless). If fn is non-nil, text chunks are streamed to the callback as they arrive.

func (*Manager) Chat ¶

func (m *Manager) Chat(ctx context.Context, request schema.ChatRequest, fn opt.StreamFn) (*schema.ChatResponse, error)

Chat processes a message within a session context (stateful). If fn is non-nil, text chunks are streamed to the callback as they arrive.

func (*Manager) Close ¶

func (m *Manager) Close() error

func (*Manager) CreateAgent ¶

func (m *Manager) CreateAgent(ctx context.Context, meta schema.AgentMeta) (*schema.Agent, error)

CreateAgent creates a new agent from the given metadata.

func (*Manager) CreateAgentSession ¶

func (m *Manager) CreateAgentSession(ctx context.Context, id string, request schema.CreateAgentSessionRequest) (*schema.CreateAgentSessionResponse, error)

CreateAgentSession resolves an agent by ID or name, validates input against the agent's schema, executes the agent's template, and creates a new session with merged GeneratorMeta and agent labels. If Parent is provided, the parent session's GeneratorMeta is used as defaults (agent fields take precedence). The returned response contains the session ID, rendered text, and tools, which the caller can pass to Chat.

func (*Manager) CreateSession ¶

func (m *Manager) CreateSession(ctx context.Context, meta schema.SessionMeta) (*schema.Session, error)

CreateSession creates a new session for the given model.

func (*Manager) DeleteAgent ¶

func (m *Manager) DeleteAgent(ctx context.Context, id string) (*schema.Agent, error)

DeleteAgent deletes an agent by ID or name and returns it.

func (*Manager) DeleteSession ¶

func (m *Manager) DeleteSession(ctx context.Context, session string) (*schema.Session, error)

DeleteSession deletes a session by ID and returns it.

func (*Manager) Embedding ¶

func (m *Manager) Embedding(ctx context.Context, request *schema.EmbeddingRequest) (*schema.EmbeddingResponse, error)

func (*Manager) GetAgent ¶

func (m *Manager) GetAgent(ctx context.Context, id string) (*schema.Agent, error)

GetAgent retrieves an agent by ID or name.

func (*Manager) GetModel ¶

func (m *Manager) GetModel(ctx context.Context, req schema.GetModelRequest) (*schema.Model, error)

func (*Manager) GetSession ¶

func (m *Manager) GetSession(ctx context.Context, session string) (*schema.Session, error)

GetSession retrieves a session by ID.

func (*Manager) GetTool ¶

func (m *Manager) GetTool(_ context.Context, name string) (*schema.ToolMeta, error)

GetTool returns tool metadata by name.

func (*Manager) ListAgents ¶

func (m *Manager) ListAgents(ctx context.Context, req schema.ListAgentRequest) (*schema.ListAgentResponse, error)

ListAgents returns agents with pagination support.

func (*Manager) ListModels ¶

func (m *Manager) ListModels(ctx context.Context, req schema.ListModelsRequest) (*schema.ListModelsResponse, error)

func (*Manager) ListSessions ¶

func (m *Manager) ListSessions(ctx context.Context, req schema.ListSessionRequest) (*schema.ListSessionResponse, error)

ListSessions returns sessions with pagination support.

func (*Manager) ListTools ¶

func (m *Manager) ListTools(_ context.Context, req schema.ListToolRequest) (*schema.ListToolResponse, error)

ListTools returns paginated tool metadata.

func (*Manager) UpdateAgent ¶

func (m *Manager) UpdateAgent(ctx context.Context, id string, meta schema.AgentMeta) (*schema.Agent, error)

UpdateAgent updates an agent's metadata and creates a new version. If Model or Provider are changed, they are validated against the registered providers first.

func (*Manager) UpdateSession ¶

func (m *Manager) UpdateSession(ctx context.Context, id string, meta schema.SessionMeta) (*schema.Session, error)

UpdateSession updates a session's metadata. If Model or Provider are changed, they are validated against the registered providers first.