dbclient

Documentation

Index

• type DBClient
  • func Open() (*DBClient, error)
  • func (db *DBClient) Close() error
  • func (db *DBClient) CreateRunnerTask(request apistructs.CreateRunnerTaskRequest) (uint64, error)
  • func (db *DBClient) GetFirstPendingTask() (*RunnerTask, error)
  • func (db *DBClient) GetRunnerTask(id int64) (*RunnerTask, error)
  • func (db *DBClient) UpdateRunnerTask(task *RunnerTask) error
• type RunnerTask
  • func (RunnerTask) TableName() string
  • func (task RunnerTask) ToApiData() *apistructs.RunnerTask

Types

type DBClient

type DBClient struct {
	*dbengine.DBEngine
}

func Open

func Open() (*DBClient, error)

func (*DBClient) Close

func (db *DBClient) Close() error

func (*DBClient) CreateRunnerTask

func (db *DBClient) CreateRunnerTask(request apistructs.CreateRunnerTaskRequest) (uint64, error)

func (*DBClient) GetFirstPendingTask

func (db *DBClient) GetFirstPendingTask() (*RunnerTask, error)

func (*DBClient) GetRunnerTask

func (db *DBClient) GetRunnerTask(id int64) (*RunnerTask, error)

func (*DBClient) UpdateRunnerTask

func (db *DBClient) UpdateRunnerTask(task *RunnerTask) error

type RunnerTask

type RunnerTask struct {
	dbengine.BaseModel
	JobID          string `json:"job_id"`
	Status         string `json:"status"` // pending running success failed
	OpenApiToken   string `json:"openapi_token"`
	ContextDataUrl string `json:"context_data_url"`
	ResultDataUrl  string `json:"result_data_url"`
	WorkDir        string `json:"workdir"`
	Commands       string `json:"commands"`
	Targets        string `json:"targets"`
}

func (RunnerTask) TableName

func (RunnerTask) TableName() string

TableName set module's corresponding tableName.

func (RunnerTask) ToApiData

func (task RunnerTask) ToApiData() *apistructs.RunnerTask