README
¶
自动化执行
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ProviderSet = wire.NewSet(web.NewHandler, dispatch.NewTaskDispatcher, service.NewService, repository.NewTaskRepository, InitTaskDAO, scheduler.NewScheduler)
Functions ¶
func InitCollectionOnce ¶ added in v1.11.0
func InitCrypto ¶ added in v1.9.1
func InitCrypto(reg *cryptox.CryptoRegistry) cryptox.Crypto
Types ¶
type Module ¶
type Module struct {
Svc Service
Hdl *web.Handler
StartTaskJob *StartTaskJob
PassProcessTaskJob *PassProcessTaskJob
TaskRecoveryJob *TaskRecoveryJob
TaskExecutionSyncJob *TaskExecutionSyncJob
// contains filtered or unexported fields
}
func InitModule ¶
func InitModule(q mq.MQ, db *mongox.Mongo, orderModule *order.Module, workflowModule *workflow.Module, engineModule *engine.Module, codebookModule *codebook.Module, workerModule *worker.Module, runnerModule *runner.Module, userModule *user.Module, discoveryModule *discovery.Module, lark2 *lark.Client, crypto *cryptox.CryptoRegistry, sender2 sender.NotificationSender, taskClient taskv1.TaskServiceClient, executorClient executorv1.TaskExecutionServiceClient) (*Module, error)
type PassProcessTaskJob ¶
type PassProcessTaskJob = job.PassProcessTaskJob
type StartTaskJob ¶
type StartTaskJob = job.StartTaskJob
type TaskExecutionSyncJob ¶ added in v1.11.0
type TaskExecutionSyncJob = job.TaskExecutionSyncJob
type TaskRecoveryJob ¶ added in v1.11.0
type TaskRecoveryJob = job.TaskRecoveryJob
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
internal
|
|
|
Package taskmocks is a generated GoMock package.
|
Package taskmocks is a generated GoMock package. |
Click to show internal directories.
Click to hide internal directories.