models

Documentation

Index

• func NextPage(page, perPage, total int64) (int64, int64)
• func Pagination(page, perPage int) (int, int)
• func TaskInsert(db *xorm.Engine, task *Task) error
• func TaskPut(db *xorm.Engine, id string, task map[string]interface{}) error
• type JsonTime
  • func (j JsonTime) MarshalJSON() ([]byte, error)
• type Task
  • func TaskGet(db *xorm.Engine, id int) (Task, error)
  • func TaskRandom(db *xorm.Engine, n int) (tasks []Task, err error)
  • func TaskRange(db *xorm.Engine, status, page, perPage int) ([]Task, int64, error)
• type TaskStatus
  • func (t TaskStatus) String() string

Functions

func NextPage

func NextPage(page, perPage, total int64) (int64, int64)

func Pagination

func Pagination(page, perPage int) (int, int)

func TaskInsert

func TaskInsert(db *xorm.Engine, task *Task) error

func TaskPut

func TaskPut(db *xorm.Engine, id string, task map[string]interface{}) error

Types

type JsonTime

type JsonTime time.Time

func (JsonTime) MarshalJSON

func (j JsonTime) MarshalJSON() ([]byte, error)

type Task

type Task struct {
	Id        int64             `json:"id"`
	CreatedAt JsonTime          `json:"created_at" xorm:"created"`
	UpdatedAt JsonTime          `json:"updated_at" xorm:"updated"`
	TaskID    string            `json:"task_id" xorm:"varchar(100) notnull unique 'task_id'"`
	Service   string            `json:"service"`
	Attempts  uint16            `json:"attempts"`
	Priority  uint8             `json:"priority"`
	Timestamp int64             `json:"timestamp"`
	Status    TaskStatus        `json:"status" xorm:"int notnull index 'status'"`
	Method    string            `json:"method"`
	Body      []byte            `json:"body"`
	Header    map[string]string `json:"header"`
}

func TaskGet

func TaskGet(db *xorm.Engine, id int) (Task, error)

func TaskRandom

func TaskRandom(db *xorm.Engine, n int) (tasks []Task, err error)

func TaskRange

func TaskRange(db *xorm.Engine, status, page, perPage int) ([]Task, int64, error)

type TaskStatus

type TaskStatus uint8

const (
	TaskStatusCreated TaskStatus = iota
	TaskStatusPending
	TaskStatusSuccess
	TaskStatusFailed
)

func (TaskStatus) String

func (t TaskStatus) String() string