delay

Documentation

Index

• func Add(ctx context.Context, id string, d time.Duration)
• func NewDelayTask(d *Delay) scheduler.Task
• type Delay
  • func FromBytes(b []byte) *Delay
  • func (d *Delay) Run(ctx context.Context, schedulerTime scheduler.UnixTimeSecond)
  • func (d *Delay) ToBytes() []byte

Functions

func Add

func Add(ctx context.Context, id string, d time.Duration)

func NewDelayTask

func NewDelayTask(d *Delay) scheduler.Task

Types

type Delay

type Delay struct {
	TryCount  uint16                   `json:"try"`
	Id        string                   `json:"id"`
	TimePoint scheduler.UnixTimeSecond `json:"tp"`
}

func FromBytes

func FromBytes(b []byte) *Delay

func (*Delay) Run

func (d *Delay) Run(ctx context.Context, schedulerTime scheduler.UnixTimeSecond)

func (*Delay) ToBytes

func (d *Delay) ToBytes() []byte