Versions in this module Expand all Collapse all v0 v0.4.5 Jun 23, 2026 v0.4.4 Jun 11, 2026 Changes in this version + func NewDelegate(name, version string, connectors map[string]llm.Connector, ...) *delegate + type ConnectorProbe interface + Probe func(ctx context.Context, auth func(err error, config *authclient.Config) error) (*schema.ConnectorState, error) + type Manager struct + func New(ctx context.Context, name, version string, pool pg.PoolConn, opts ...Opt) (*Manager, error) + func (m *Manager) Ask(ctx context.Context, request schema.AskRequest, user *auth.UserInfo, ...) (_ *schema.AskResponse, err error) + func (m *Manager) CallAgent(ctx context.Context, name string, req schema.CallAgentRequest, ...) (result llm.Resource, err error) + func (m *Manager) CallTool(ctx context.Context, name string, req schema.CallToolRequest, ...) (result llm.Resource, err error) + func (m *Manager) Chat(ctx context.Context, req schema.ChatRequest, fn opt.StreamFn, ...) (_ *schema.ChatResponse, err error) + func (m *Manager) CreateConnector(ctx context.Context, req schema.ConnectorInsert, user *auth.UserInfo) (_ *schema.Connector, _ *oidc.BaseConfiguration, _ []string, err error) + func (m *Manager) CreateCredential(ctx context.Context, req schema.CredentialInsert) (_ *schema.Credential, err error) + func (m *Manager) CreateProvider(ctx context.Context, req schema.ProviderInsert) (*schema.Provider, error) + func (m *Manager) CreateSession(ctx context.Context, req schema.SessionInsert, user *auth.UserInfo) (_ *schema.Session, err error) + func (m *Manager) CreateUsage(ctx context.Context, req schema.UsageInsert) (_ *schema.Usage, err error) + func (m *Manager) DeleteConnector(ctx context.Context, url string) (_ *schema.Connector, err error) + func (m *Manager) DeleteModel(ctx context.Context, req schema.DeleteModelRequest, user *auth.UserInfo) (result *schema.Model, err error) + func (m *Manager) DeleteProvider(ctx context.Context, name string) (*schema.Provider, error) + func (m *Manager) DeleteSession(ctx context.Context, session uuid.UUID, user *auth.UserInfo) (_ *schema.Session, err error) + func (m *Manager) DownloadModel(ctx context.Context, req schema.DownloadModelRequest, user *auth.UserInfo, ...) (result *schema.Model, err error) + func (m *Manager) Embedding(ctx context.Context, request schema.EmbeddingRequest, user *auth.UserInfo) (_ *schema.EmbeddingResponse, err error) + func (m *Manager) GetAgent(ctx context.Context, name string, user *auth.UserInfo) (result *schema.AgentMeta, err error) + func (m *Manager) GetConnector(ctx context.Context, url string, user *auth.UserInfo) (_ *schema.Connector, err error) + func (m *Manager) GetModel(ctx context.Context, req schema.GetModelRequest, user *auth.UserInfo) (_ *schema.Model, err error) + func (m *Manager) GetProvider(ctx context.Context, name string) (*schema.Provider, error) + func (m *Manager) GetSession(ctx context.Context, session uuid.UUID, user *auth.UserInfo) (_ *schema.Session, err error) + func (m *Manager) GetTool(ctx context.Context, name string, user *auth.UserInfo) (result *schema.ToolMeta, err error) + func (m *Manager) ListAgents(ctx context.Context, req schema.AgentListRequest, user *auth.UserInfo) (result *schema.AgentList, err error) + func (m *Manager) ListConnectors(ctx context.Context, req schema.ConnectorListRequest, user *auth.UserInfo) (_ *schema.ConnectorList, err error) + func (m *Manager) ListMessages(ctx context.Context, req schema.MessageListRequest, user *auth.UserInfo) (_ *schema.MessageList, err error) + func (m *Manager) ListModels(ctx context.Context, req schema.ModelListRequest, user *auth.UserInfo) (_ *schema.ModelList, err error) + func (m *Manager) ListProviders(ctx context.Context, req schema.ProviderListRequest) (*schema.ProviderList, error) + func (m *Manager) ListSessions(ctx context.Context, req schema.SessionListRequest, user *auth.UserInfo) (_ *schema.SessionList, err error) + func (m *Manager) ListTools(ctx context.Context, req schema.ToolListRequest, user *auth.UserInfo) (result *schema.ToolList, err error) + func (m *Manager) Run(ctx context.Context, logger *slog.Logger) error + func (m *Manager) SubscribeSession(ctx context.Context, session uuid.UUID, callback SessionFeedCallback, ...) error + func (m *Manager) SyncProviders(ctx context.Context) ([]string, []string, error) + func (m *Manager) UpdateConnector(ctx context.Context, url string, meta schema.ConnectorMeta) (_ *schema.Connector, err error) + func (m *Manager) UpdateProvider(ctx context.Context, name string, meta schema.ProviderMeta) (*schema.Provider, error) + func (m *Manager) UpdateSession(ctx context.Context, session uuid.UUID, meta schema.SessionMeta, ...) (_ *schema.Session, err error) + type Opt func(*manageropt) error + func WithClientOpts(opts ...client.ClientOpt) Opt + func WithConnector(name string, connector llm.Connector) Opt + func WithMeter(meter metric.Meter) Opt + func WithNotificationChannel(name string) Opt + func WithPassphrase(version uint64, passphrase string) Opt + func WithPrompts(opts ...llm.Prompt) Opt + func WithResources(opts ...llm.Resource) Opt + func WithSchemas(llm, auth string) Opt + func WithTools(opts ...llm.Tool) Opt + func WithTracer(tracer trace.Tracer) Opt + type SessionFeed struct + func NewSessionFeed(ctx context.Context, conn pg.Conn, delay time.Duration) (*SessionFeed, error) + func (s *SessionFeed) Subscribe(ctx context.Context, session uuid.UUID, callback SessionFeedCallback) error + type SessionFeedCallback func([]*schema.Message)
Go to main page