Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrTimerOverdue = fmt.Errorf("timer overdue")
Functions ¶
This section is empty.
Types ¶
type DBTimer ¶
type DBTimer struct {
// contains filtered or unexported fields
}
func (*DBTimer) RegisterTimerHandler ¶
func (t *DBTimer) RegisterTimerHandler(cb ddd.TimerHandler)
type TimerJob ¶
type TimerJob struct { ID int64 `gorm:"primaryKey;column:id;autoIncrement"` Service string `gorm:"column:service;type:varchar(30)"` Key string `gorm:"column:key;type:varchar(30);uniqueIndex;not null"` Cron string `gorm:"column:cron;type:varchar(30);null"` NextTime time.Time `gorm:"column:next_time;type:datetime;index;not null"` Status TimerStatus `gorm:"column:status;type:tinyint"` Msg string `gorm:"column:msg;type:varchar(128)"` Payload []byte `gorm:"column:payload;type:text"` CreatedAt time.Time `gorm:"index;type:datetime"` }
type TimerStatus ¶
type TimerStatus int
const ( TimerToRun TimerStatus = 1 TimerFinished TimerStatus = 2 TimerFailed TimerStatus = 3 )
Click to show internal directories.
Click to hide internal directories.