xqueue

Aug 1, 2024

Changes in this version

+ func AddMap(funs map[string]func(param []byte) error)

+ type Xq struct

+ func WithDervice(c Queue) *Xq

+ func (xq *Xq) Set(funs string, param any) error

+ func (xq *Xq) SetDef(funs string, param any, def time.Duration) error

Jul 31, 2024

Changes in this version

+ func Add(funs string, conf *FuncConf)

+ func List() map[string]FuncConf

+ func Listen()

+ func Remove(fun string)

+ func Set(funs string, param any) error

+ func SetDef(funs string, param any, def time.Duration) error

+ func SetDervice(c Queue)

+ func SetLogInsert(c func(log *QueueLog))

+ func SetOlnyWrite(c bool)

+ type FuncConf struct

+ Desc string

+ Func func(param []byte) error

+ Name string

+ type Queue interface

+ Listen func(f func(dat []byte) error) error

+ Set func(dat []byte) error

+ SetDef func(dat []byte, t time.Duration) error

+ type QueueLog struct

+ CreatedAt int64

+ Desc string

+ Error string

+ Id uint

+ IsError int8

+ Key string

+ Name string

+ Param string

+ Type uint8

+ func (c *QueueLog) TableName() string