postgres

Documentation

Index

• func BatchInsertOperatorTasks(db *sql.DB, operatorTasks []*OperatorTask) error
• func CountOperatorTasks(db *sql.DB, taskID uint32) (int, 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)
• func UpsertTask(db *sql.DB, task *Task) error
• type Operator
• type OperatorTask
• type Task

Functions

func BatchInsertOperatorTasks

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

func CountOperatorTasks

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

func QueryOperatorAddressesNoRegisteredAt

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

func QueryOperatorIDs

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

func UpdateOperatorRegisteredAt

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

func UpdateTaskResponse

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

func UpsertOperator

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

func UpsertTask

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

Types

type Operator

type Operator struct {
	OperatorAddress string
	OperatorID      string
	Socket          string
	Location        string
	CPUCore         uint32
	Memory          uint32
	Status          string
}

type OperatorTask

type OperatorTask struct {
	OperatorID uint32
	TaskID     uint32
	Status     string
}

type Task

type Task struct {
	TaskID         uint32
	TaskDetail     string
	TaskResponse   string
	CreateTaskTx   string
	CreateTaskAt   time.Time
	ResponseTaskTx string
	ResponseTaskAt time.Time
}