Documentation
¶
Index ¶
- func BuildModules(migrations *migration.Migration, config2 *configv1.Bootstrap, ...) (module.Modules, func(), error)
- func BuildQueueConsumers(databases map[string]*gorm.Client, baseCase *biz.BaseCase, sseRuntime *sse.SSE) (queue.Consumers, func(), error)
- func BuildStreams(progressManager *codegen.Manager, databases map[string]*gorm.Client, ...) (sse.Streams, func(), error)
- func BuildTasks(databases map[string]*gorm.Client, baseCase *biz.BaseCase, sseRuntime *sse.SSE) (job.Tasks, func(), error)
- func NewModuleResources() module.Resources
- func NewModules(baseServices *base.Services, adminServices *admin.Services, ...) (module.Modules, error)
- func NewQueueConsumers(baseMessageCase *biz.BaseMessageCase, logConsumer data.ConsumerFunc) queue.Consumers
- func ParseAdminAgentTools(services admin.Services) (ai.AdminTools, error)
- func ParseAppAgentTools(services app.Services) (ai.AppTools, error)
- type Module
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func BuildModules ¶ added in v0.0.28
func BuildModules(migrations *migration.Migration, config2 *configv1.Bootstrap, databases map[string]*gorm.Client, baseCase *biz.BaseCase, authorizer engine.Engine, authenticator engine2.Authenticator, userToken *data.UserToken, jobRuntime *job.Job, sseRuntime *sse.SSE, catalog *i18n.I18n, openAPIRuntime *openapi.OpenAPI, redactResolver *kit.RedactPolicyResolver, progressManager *codegen.Manager) (module.Modules, func(), error)
BuildModules 使用宿主共享的任务管理器装配 Admin 协议服务。
func BuildQueueConsumers ¶ added in v0.0.28
func BuildQueueConsumers(databases map[string]*gorm.Client, baseCase *biz.BaseCase, sseRuntime *sse.SSE) (queue.Consumers, func(), error)
BuildQueueConsumers 装配 Admin 队列消费者集合。
func BuildStreams ¶ added in v0.0.28
func BuildStreams(progressManager *codegen.Manager, databases map[string]*gorm.Client, baseCase *biz.BaseCase, catalog *i18n.I18n) (sse.Streams, func(), error)
BuildStreams 使用与协议服务相同的任务管理器装配 Admin SSE 流。
func BuildTasks ¶ added in v0.0.28
func BuildTasks(databases map[string]*gorm.Client, baseCase *biz.BaseCase, sseRuntime *sse.SSE) (job.Tasks, func(), error)
BuildTasks 通过最小依赖集合装配 Admin 定时任务。
func NewModuleResources ¶
NewModuleResources 创建 Admin 在业务对象构建前提供给 Core 的静态资源。
func NewModules ¶
func NewModules( baseServices *base.Services, adminServices *admin.Services, appServices *app.Services, baseConfigCase *biz.BaseConfigCase, baseLoginPolicyCase *biz.BaseLoginPolicyCase, _ *kit.RedactPolicyResolver, ) (module.Modules, error)
NewModules 创建包含 Admin 服务的模块集合。
func NewQueueConsumers ¶
func NewQueueConsumers(baseMessageCase *biz.BaseMessageCase, logConsumer data.ConsumerFunc) queue.Consumers
NewQueueConsumers 提供 Admin 自身投递事件的队列消费者集合。
func ParseAdminAgentTools ¶
func ParseAdminAgentTools(services admin.Services) (ai.AdminTools, error)
ParseAdminAgentTools 创建管理端服务导出的 Eino 工具。
Types ¶
type Module ¶
type Module struct {
// contains filtered or unexported fields
}
Module 聚合 Admin 注册到 Core 宿主的协议服务。
func (*Module) RegisterGRPC ¶
func (m *Module) RegisterGRPC(registrar grpc.ServiceRegistrar)
RegisterGRPC 注册 Admin 的全部 gRPC 服务。
func (*Module) RegisterHTTP ¶
RegisterHTTP 注册 Admin 的全部 HTTP 服务。
func (*Module) RegisterMCP ¶
RegisterMCP 注册 Admin 的全部 MCP 工具。
Source Files
Click to show internal directories.
Click to hide internal directories.