postgres

Dec 11, 2024

Changes in this version

+ func UpsertTask(db *sql.DB, task *Task) error

type Task

+ CreateTaskAt time.Time

+ ResponseTaskAt time.Time

Dec 6, 2024

Changes in this version

+ func BatchInsertOperatorTasks(db *sql.DB, operatorTasks []*OperatorTask) error

+ func CountOperatorTasks(db *sql.DB, taskID uint32) (int, error)

+ func InsertTask(db *sql.DB, task *Task) error

+ func QueryOperatorAddressesNoRegisteredAt(db *sql.DB) ([]string, error)

+ func QueryOperatorIDs(db *sql.DB, operatorAddresses []string) ([]uint32, error)

+ func UpdateOperatorRegisteredAt(db *sql.DB, operatorAddress string, timestamp time.Time) error

+ func UpdateTaskResponse(db *sql.DB, taskID uint32, taskResponse, responseTaskTx string) error

+ func UpsertOperator(db *sql.DB, operator *Operator) (int, error)

+ type Operator struct

+ CPUCore uint32

+ Location string

+ Memory uint32

+ OperatorAddress string

+ OperatorID string

+ Socket string

+ Status string

+ type OperatorTask struct

+ OperatorID uint32

+ Status string

+ TaskID uint32

+ type Task struct

+ CreateTaskTx string

+ ResponseTaskTx string

+ TaskDetail string

+ TaskID uint32

+ TaskResponse string