Documentation
¶
Index ¶
- func NewAsyncqClient() (*asynq.Client, error)
- func NewAsynqServer() *asynq.Server
- func NewRouter(params RouterParams) *gin.Engine
- func RegisterAnalysisRoutes(r *gin.RouterGroup, handler *handler.AnalysisHandler)
- func RegisterAuthRoutes(r *gin.RouterGroup, handler *handler.AuthHandler)
- func RegisterContainerRoutes(r *gin.RouterGroup, handler *handler.ContainerHandler)
- func RegisterDataRoutes(r *gin.RouterGroup, handler *handler.DataHandler)
- func RegisterFileRoutes(r *gin.RouterGroup, handler *handler.FileHandler)
- func RegisterLLMRoutes(r *gin.RouterGroup, handler *handler.LLMHandler)
- func RegisterProjectRoutes(r *gin.RouterGroup, handler *handler.ProjectHandler, ...)
- func RegisterRealtimeRoutes(r *gin.RouterGroup, handler *handler.RealtimeHandler)
- func RegisterSettingRoutes(r *gin.RouterGroup, handler *handler.SettingHandler)
- func RegisterSheetRoutes(r *gin.RouterGroup, handler *handler.SheetHandler)
- func RegisterStoreRoutes(r *gin.RouterGroup, handler *handler.StoreHandler)
- func RegisterSyncHandlers(params SyncTaskParams)
- func RegisterWorkflowRoutes(r *gin.RouterGroup, handler *handler.WorkflowHandler)
- func RunAsynqServer(params AsynqTaskParams) *asynq.ServeMux
- type AsynqTaskParams
- type RouterParams
- type SyncTaskExecutor
- type SyncTaskParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewAsyncqClient ¶
func NewAsynqServer ¶
func NewRouter ¶
func NewRouter(params RouterParams) *gin.Engine
func RegisterAnalysisRoutes ¶
func RegisterAnalysisRoutes(r *gin.RouterGroup, handler *handler.AnalysisHandler)
func RegisterAuthRoutes ¶
func RegisterAuthRoutes(r *gin.RouterGroup, handler *handler.AuthHandler)
func RegisterContainerRoutes ¶
func RegisterContainerRoutes(r *gin.RouterGroup, handler *handler.ContainerHandler)
func RegisterDataRoutes ¶
func RegisterDataRoutes(r *gin.RouterGroup, handler *handler.DataHandler)
func RegisterFileRoutes ¶
func RegisterFileRoutes(r *gin.RouterGroup, handler *handler.FileHandler)
func RegisterLLMRoutes ¶
func RegisterLLMRoutes(r *gin.RouterGroup, handler *handler.LLMHandler)
func RegisterProjectRoutes ¶
func RegisterProjectRoutes(r *gin.RouterGroup, handler *handler.ProjectHandler, uploadHandler *handler.UploadHandler)
func RegisterRealtimeRoutes ¶
func RegisterRealtimeRoutes(r *gin.RouterGroup, handler *handler.RealtimeHandler)
func RegisterSettingRoutes ¶
func RegisterSettingRoutes(r *gin.RouterGroup, handler *handler.SettingHandler)
func RegisterSheetRoutes ¶
func RegisterSheetRoutes(r *gin.RouterGroup, handler *handler.SheetHandler)
func RegisterStoreRoutes ¶
func RegisterStoreRoutes(r *gin.RouterGroup, handler *handler.StoreHandler)
func RegisterSyncHandlers ¶
func RegisterSyncHandlers(params SyncTaskParams)
RegisterSyncHandlers registers all task handlers on the SyncTaskExecutor. Used in Lite mode instead of RunAsynqServer.
func RegisterWorkflowRoutes ¶
func RegisterWorkflowRoutes(r *gin.RouterGroup, handler *handler.WorkflowHandler)
func RunAsynqServer ¶
func RunAsynqServer(params AsynqTaskParams) *asynq.ServeMux
Types ¶
type RouterParams ¶
type RouterParams struct {
dig.In
Config *config.Config
UserService interfaces.UserService
AuthHandler *handler.AuthHandler
ProjectHandler *handler.ProjectHandler
DataHandler *handler.DataHandler
StoreHandler *handler.StoreHandler
ContainerHandler *handler.ContainerHandler
AnalysisHandler *handler.AnalysisHandler
WorkflowHandler *handler.WorkflowHandler
SettingHandler *handler.SettingHandler
SheetHandler *handler.SheetHandler
UploadHandler *handler.UploadHandler
FileHandler *handler.FileHandler
ProxyHandler *handler.ProxyHandler
RealtimeHandler *handler.RealtimeHandler
LLMHandler *handler.LLMHandler
}
type SyncTaskExecutor ¶
type SyncTaskExecutor struct {
// contains filtered or unexported fields
}
SyncTaskExecutor executes tasks synchronously (in a goroutine) without Redis. Used in Lite mode as a drop-in replacement for *asynq.Client.
func NewSyncTaskExecutor ¶
func NewSyncTaskExecutor() *SyncTaskExecutor
func (*SyncTaskExecutor) Enqueue ¶
Enqueue satisfies interfaces.TaskEnqueuer. Instead of queuing to Redis, it dispatches the task to a goroutine. Supports ProcessIn (delay) and MaxRetry options for parity with asynq.
func (*SyncTaskExecutor) RegisterHandler ¶
func (e *SyncTaskExecutor) RegisterHandler(pattern string, handler func(context.Context, *asynq.Task) error)
RegisterHandler registers a handler for a given task type pattern.
type SyncTaskParams ¶
type SyncTaskParams struct {
dig.In
Executor *SyncTaskExecutor
}
Source Files
Click to show internal directories.
Click to hide internal directories.