Documentation
¶
Index ¶
- func NewModule(ctx frame.ContextFramer) frame.ModuleRegister
- func NewTaskAsync(ctx frame.ContextFramer) frame.TaskRegister
- func RegisterRouteHandlers(ctx frame.ContextFramer, app fiber.Router) fiber.Router
- func RegisterSwagger(ctx frame.ContextFramer, app fiber.Router) fiber.Router
- type Module
- type TaskAsync
- func (ta *TaskAsync) AddTaskHandlerToMap(pattern string, handler func(context.Context, *asynq.Task) error)
- func (ta *TaskAsync) GetContext() frame.ContextFramer
- func (ta *TaskAsync) GetName() string
- func (ta *TaskAsync) GetTaskDispatcher() (*frame.TaskDispatcher, error)
- func (ta *TaskAsync) GetTaskHandlerMap() map[string]func(context.Context, *asynq.Task) error
- func (ta *TaskAsync) GetTaskWorker(key string) (*frame.TaskWorker, error)
- func (ta *TaskAsync) RegisterTaskDispatcherToContainer()
- func (ta *TaskAsync) RegisterTaskServerToContainer()
- func (ta *TaskAsync) SetName(name string)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewModule ¶
func NewModule(ctx frame.ContextFramer) frame.ModuleRegister
func NewTaskAsync ¶
func NewTaskAsync(ctx frame.ContextFramer) frame.TaskRegister
func RegisterRouteHandlers ¶
RegisterRouteHandlers 注册各业务模块的路由处理器
func RegisterSwagger ¶
RegisterSwagger 注册Swagger UI route
Types ¶
type Module ¶
type Module struct {
Ctx frame.ContextFramer
// contains filtered or unexported fields
}
Module struct
func (*Module) GetContext ¶
func (m *Module) GetContext() frame.ContextFramer
GetContext get module context
func (*Module) RegisterModuleMiddleware ¶
func (m *Module) RegisterModuleMiddleware(core interface{})
RegisterModuleMiddleware 注册模块(子系统)级中间件
func (*Module) RegisterModuleRouteHandlers ¶
func (m *Module) RegisterModuleRouteHandlers(core interface{})
RegisterModuleRouteHandlers 注册模块(子系统)级路由处理器
func (*Module) RegisterSwagger ¶
func (m *Module) RegisterSwagger(core interface{})
RegisterSwagger 注册swagger
type TaskAsync ¶
type TaskAsync struct {
Ctx frame.ContextFramer
// contains filtered or unexported fields
}
TaskAsync 任务注册器
func (*TaskAsync) AddTaskHandlerToMap ¶
func (ta *TaskAsync) AddTaskHandlerToMap(pattern string, handler func(context.Context, *asynq.Task) error)
AddTaskHandlerToMap 添加新的任务名和任务处理器到map
func (*TaskAsync) GetContext ¶
func (ta *TaskAsync) GetContext() frame.ContextFramer
GetContext 获取应用上下文
func (*TaskAsync) GetTaskDispatcher ¶
func (ta *TaskAsync) GetTaskDispatcher() (*frame.TaskDispatcher, error)
GetTaskDispatcher 从容器获取任务分发器实例
func (*TaskAsync) GetTaskHandlerMap ¶
GetTaskHandlerMap 获取任务处理器map
func (*TaskAsync) GetTaskWorker ¶
func (ta *TaskAsync) GetTaskWorker(key string) (*frame.TaskWorker, error)
GetTaskWorker 从容器获取任务工作服务器实例
func (*TaskAsync) RegisterTaskDispatcherToContainer ¶
func (ta *TaskAsync) RegisterTaskDispatcherToContainer()
RegisterKeyTaskDispatcher 注册异步任务分发器初始化器到全局容器
func (*TaskAsync) RegisterTaskServerToContainer ¶
func (ta *TaskAsync) RegisterTaskServerToContainer()
RegisterKeyTaskServer 注册异步任务服务器/工作器初始化器到全局容器
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.