repository

Documentation

Index

• type BaseRepository
  • func (base *BaseRepository) Debug(content interface{})
  • func (base *BaseRepository) Error(err error, content interface{})
  • func (base *BaseRepository) Info(content interface{})
  • func (base *BaseRepository) InitLogger()
  • func (base *BaseRepository) Trace(content interface{})
  • func (base *BaseRepository) Warn(content interface{})
• type ExecutorRepo
  • func NewExecutorRepo() *ExecutorRepo
  • func (repo *ExecutorRepo) DeleteOnce(id int64) error
  • func (repo *ExecutorRepo) GetExecutorById(id int64) (*model.ExecutorInfo, error)
  • func (repo *ExecutorRepo) GetExecutorByTaskId(taskId string) (*model.ExecutorInfo, error)
  • func (repo *ExecutorRepo) InsertOnce(model *model.ExecutorInfo) error
  • func (repo *ExecutorRepo) InsertRunInfo(model *model.ExecutorRunInfo) error
  • func (repo *ExecutorRepo) QueryAllExecutors() ([]*model.ExecutorInfo, error)
  • func (repo *ExecutorRepo) QueryExecutors(pageReq *model.PageRequest) (*model.PageResult, error)
  • func (repo *ExecutorRepo) QueryRunInfo(taskId string) (*model.ExecutorRunInfo, error)
  • func (repo *ExecutorRepo) UpdateOnce(model *model.ExecutorInfo) error
  • func (repo *ExecutorRepo) UpdateRunInfo(model *model.ExecutorRunInfo) error
  • func (repo *ExecutorRepo) UpdateSubmitFlag(id int64, flag bool) error
• type LogRepo
  • func NewLogRepo() *LogRepo
  • func (repo *LogRepo) QueryExecLogs(taskId string, pageReq *model.PageRequest) (*model.PageResult, error)
  • func (repo *LogRepo) QueryNodeTraceLog(nodeId string, pageReq *model.PageRequest) (*model.PageResult, error)
  • func (repo *LogRepo) QueryStateLog(taskId string, pageReq *model.PageRequest) (*model.PageResult, error)
  • func (repo *LogRepo) QueryTaskSubmitLog(taskId string, pageReq *model.PageRequest) (*model.PageResult, error)
  • func (repo *LogRepo) WriteExecLog(log *model.TaskExecLog) (int64, error)
  • func (repo *LogRepo) WriteNodeTraceLog(log *model.NodeTraceLog) (int64, error)
  • func (repo *LogRepo) WriteSubmitLog(log *model.TaskSubmitLog) (int64, error)

Types

type BaseRepository

type BaseRepository struct {
	mysql.MySqlDBContext
	// contains filtered or unexported fields
}

func (*BaseRepository) Debug

func (base *BaseRepository) Debug(content interface{})

func (*BaseRepository) Error

func (base *BaseRepository) Error(err error, content interface{})

func (*BaseRepository) Info

func (base *BaseRepository) Info(content interface{})

func (*BaseRepository) InitLogger

func (base *BaseRepository) InitLogger()

func (*BaseRepository) Trace

func (base *BaseRepository) Trace(content interface{})

func (*BaseRepository) Warn

func (base *BaseRepository) Warn(content interface{})

type ExecutorRepo

type ExecutorRepo struct {
	BaseRepository
}

func NewExecutorRepo

func NewExecutorRepo() *ExecutorRepo

NewExecutorRepo return new ExecutorRepo

func (*ExecutorRepo) DeleteOnce

func (repo *ExecutorRepo) DeleteOnce(id int64) error

DeleteOnce

func (*ExecutorRepo) GetExecutorById

func (repo *ExecutorRepo) GetExecutorById(id int64) (*model.ExecutorInfo, error)

GetExecutorById

func (*ExecutorRepo) GetExecutorByTaskId

func (repo *ExecutorRepo) GetExecutorByTaskId(taskId string) (*model.ExecutorInfo, error)

GetExecutorByTaskId

func (*ExecutorRepo) InsertOnce

func (repo *ExecutorRepo) InsertOnce(model *model.ExecutorInfo) error

InsertOnce

func (*ExecutorRepo) InsertRunInfo

func (repo *ExecutorRepo) InsertRunInfo(model *model.ExecutorRunInfo) error

InsertRunInfo

func (*ExecutorRepo) QueryAllExecutors

func (repo *ExecutorRepo) QueryAllExecutors() ([]*model.ExecutorInfo, error)

QueryAllExecutors

func (*ExecutorRepo) QueryExecutors

func (repo *ExecutorRepo) QueryExecutors(pageReq *model.PageRequest) (*model.PageResult, error)

QueryExecutors

func (*ExecutorRepo) QueryRunInfo

func (repo *ExecutorRepo) QueryRunInfo(taskId string) (*model.ExecutorRunInfo, error)

QueryRunInfo

func (*ExecutorRepo) UpdateOnce

func (repo *ExecutorRepo) UpdateOnce(model *model.ExecutorInfo) error

UpdateOnce

func (*ExecutorRepo) UpdateRunInfo

func (repo *ExecutorRepo) UpdateRunInfo(model *model.ExecutorRunInfo) error

UpdateRunInfo

func (*ExecutorRepo) UpdateSubmitFlag

func (repo *ExecutorRepo) UpdateSubmitFlag(id int64, flag bool) error

UpdateSubmitFlag

type LogRepo

type LogRepo struct {
	BaseRepository
}

func NewLogRepo

func NewLogRepo() *LogRepo

NewLogRepo return new ExecutorRepo

func (*LogRepo) QueryExecLogs

func (repo *LogRepo) QueryExecLogs(taskId string, pageReq *model.PageRequest) (*model.PageResult, error)

QueryExecLogs

func (*LogRepo) QueryNodeTraceLog

func (repo *LogRepo) QueryNodeTraceLog(nodeId string, pageReq *model.PageRequest) (*model.PageResult, error)

QueryNodeTraceLog

func (*LogRepo) QueryStateLog

func (repo *LogRepo) QueryStateLog(taskId string, pageReq *model.PageRequest) (*model.PageResult, error)

QueryStateLog

func (*LogRepo) QueryTaskSubmitLog

func (repo *LogRepo) QueryTaskSubmitLog(taskId string, pageReq *model.PageRequest) (*model.PageResult, error)

QueryTaskSubmitLog

func (*LogRepo) WriteExecLog

func (repo *LogRepo) WriteExecLog(log *model.TaskExecLog) (int64, error)

WriteExecLog

func (*LogRepo) WriteNodeTraceLog

func (repo *LogRepo) WriteNodeTraceLog(log *model.NodeTraceLog) (int64, error)

WriteNodeTraceLog

func (*LogRepo) WriteSubmitLog

func (repo *LogRepo) WriteSubmitLog(log *model.TaskSubmitLog) (int64, error)

WriteSubmitLog