db

Documentation

Index

• type DBClient
  • func (db *DBClient) CreateRunnerTask(request *pb.RunnerTaskCreateRequest) (uint64, error)
  • func (db *DBClient) GetFirstPendingTask(orgIDs []int64) (*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
  • func (task RunnerTask) ToPbData() *pb.RunnerTask

Types

type DBClient

type DBClient struct {
	*dbengine.DBEngine
}

func (*DBClient) CreateRunnerTask

func (db *DBClient) CreateRunnerTask(request *pb.RunnerTaskCreateRequest) (uint64, error)

func (*DBClient) GetFirstPendingTask

func (db *DBClient) GetFirstPendingTask(orgIDs []int64) (*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"`
	OrgID          int64  `json:"org_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

func (RunnerTask) ToPbData

func (task RunnerTask) ToPbData() *pb.RunnerTask