service

package

v0.0.0-...-25da3cc Latest Latest Go to latest Published: Jul 8, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/devfeel/rockman

Links

Open Source Insights

Documentation ¶

Index ¶

func GetLogger() dotlog.Logger
type BaseService
type ExecutorService
- func NewExecutorService() *ExecutorService
type LogService
- func NewLogService() *LogService

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetLogger ¶

func GetLogger() dotlog.Logger

Types ¶

type BaseService ¶

type BaseService struct {
	RedisCache cache.RedisCache
}

type ExecutorService ¶

type ExecutorService struct {
	BaseService
	// contains filtered or unexported fields
}

func NewExecutorService ¶

func NewExecutorService() *ExecutorService

func (*ExecutorService) AddExecutor ¶

func (service *ExecutorService) AddExecutor(model *model.ExecutorInfo) *core.Result

AddExecutor

func (*ExecutorService) QueryAllExecutors ¶

func (service *ExecutorService) QueryAllExecutors() ([]*model.ExecutorInfo, error)

QueryAllExecutors

func (*ExecutorService) QueryExecutorById ¶

func (service *ExecutorService) QueryExecutorById(id int64) (*model.ExecutorInfo, error)

QueryExecutorById

func (*ExecutorService) QueryExecutorByTaskId ¶

func (service *ExecutorService) QueryExecutorByTaskId(taskId string) (*model.ExecutorInfo, error)

QueryExecutorByTaskId

func (*ExecutorService) QueryExecutors ¶

func (service *ExecutorService) QueryExecutors(pageReq *model.PageRequest) (*model.PageResult, error)

QueryExecutors

func (*ExecutorService) RemoveExecutor ¶

func (service *ExecutorService) RemoveExecutor(id int64) error

RemoveExecutor

func (*ExecutorService) SetExecutorRunInfo ¶

func (service *ExecutorService) SetExecutorRunInfo(model *model.ExecutorRunInfo) error

SetExecutorRunInfo if exists, update it if not exists, insert it

func (*ExecutorService) UpdateExecutor ¶

func (service *ExecutorService) UpdateExecutor(model *model.ExecutorInfo) *core.Result

UpdateExecutor

func (*ExecutorService) UpdateSubmitFlag ¶

func (service *ExecutorService) UpdateSubmitFlag(id int64, flag bool) *core.Result

UpdateSubmitFlag

type LogService ¶

type LogService struct {
	BaseService
	// contains filtered or unexported fields
}

func NewLogService ¶

func NewLogService() *LogService

func (*LogService) QueryExecLogs ¶

func (service *LogService) QueryExecLogs(taskId string, pageReq *model.PageRequest) (*model.PageResult, error)

QueryExecLogs

func (*LogService) QueryNodeTraceLog ¶

func (service *LogService) QueryNodeTraceLog(nodeId string, pageReq *model.PageRequest) (*model.PageResult, error)

QueryNodeTraceLog

func (*LogService) QueryStateLog ¶

func (service *LogService) QueryStateLog(taskId string, pageReq *model.PageRequest) (*model.PageResult, error)

QueryStateLog

func (*LogService) QueryTaskSubmitLog ¶

func (service *LogService) QueryTaskSubmitLog(taskId string, pageReq *model.PageRequest) (*model.PageResult, error)

QueryTaskSubmitLog

func (*LogService) WriteExecLog ¶

func (service *LogService) WriteExecLog(log *model.TaskExecLog) error

WriteExecLog

func (*LogService) WriteNodeTraceLog ¶

func (service *LogService) WriteNodeTraceLog(log *model.NodeTraceLog) error

WriteNodeTraceLog

func (*LogService) WriteSubmitLog ¶

func (service *LogService) WriteSubmitLog(log *model.TaskSubmitLog) error

WriteSubmitLog

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL