sql

Documentation

Index

• Variables
• type DBTimer
  • func NewDBTimer(service string, db *gorm.DB, opts ...Option) *DBTimer
  • func (t *DBTimer) Cancel(key string) error
  • func (t *DBTimer) RegisterTimerHandler(cb ddd.TimerHandler)
  • func (t *DBTimer) RunCron(key, cronExp string, data []byte) error
  • func (t *DBTimer) RunOnce(key string, runTime time.Time, data []byte) error
  • func (t *DBTimer) Start(ctx context.Context)
• type Option
• type Options
• type TimerJob
  • func (t *TimerJob) Close(err error)
  • func (t *TimerJob) Next() error
  • func (t *TimerJob) Reset() error
  • func (t *TimerJob) TableName() string
• type TimerStatus

Variables

var ErrTimerOverdue = fmt.Errorf("timer overdue")

Types

type DBTimer

type DBTimer struct {
	// contains filtered or unexported fields
}

func NewDBTimer

func NewDBTimer(service string, db *gorm.DB, opts ...Option) *DBTimer

func (*DBTimer) Cancel

func (t *DBTimer) Cancel(key string) error

func (*DBTimer) RegisterTimerHandler

func (t *DBTimer) RegisterTimerHandler(cb ddd.TimerHandler)

func (*DBTimer) RunCron

func (t *DBTimer) RunCron(key, cronExp string, data []byte) error

func (*DBTimer) RunOnce

func (t *DBTimer) RunOnce(key string, runTime time.Time, data []byte) error

func (*DBTimer) Start

func (t *DBTimer) Start(ctx context.Context)

type Option

type Option func(opt *Options)

type Options

type Options struct {
	RunInterval time.Duration
	Logger      logr.Logger
}

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"`
}

func (*TimerJob) Close

func (t *TimerJob) Close(err error)

func (*TimerJob) Next

func (t *TimerJob) Next() error

func (*TimerJob) Reset

func (t *TimerJob) Reset() error

func (*TimerJob) TableName

func (t *TimerJob) TableName() string

type TimerStatus

type TimerStatus int

const (
	TimerToRun    TimerStatus = 1
	TimerFinished TimerStatus = 2
	TimerFailed   TimerStatus = 3
)