model

Nov 7, 2020

Changes in this version

+ type DBDrv interface

+ Clear func(t time.Time, cur []string) (err error)

+ Create func(i *Item) (err error)

+ Delete func(id string, cur []string) (err error)

+ Detail func(id string) (ret types.Detail, err error)

+ ForceClear func(t time.Time, cur []string) (err error)

+ Pending func(now int64, max uint32, drvs, ids []string) (ret *Item, err error)

+ Resend func(id string, max uint32) (err error)

+ Result func(id string) (ret []byte, err error)

+ Status func(id string) (ret types.Status, err error)

+ Update func(id string, tried uint32, next int64, state types.State, resp []byte) (err error)

+ type DrvBase struct

+ DB *sql.DB

+ func NewDrvBase(db *sql.DB) (ret *DrvBase)

+ func (d *DrvBase) Prepare(qstr string, e error) (err error)

+ func (d *DrvBase) Stmt(qstr string) (ret *sql.Stmt)

+ type E404 struct

+ func (e *E404) Error() string

+ type Item struct

+ Content []byte

+ CreateAt int64

+ Driver string

+ Endpoint string

+ ID string

+ NextAt int64

+ State types.State

+ Tried uint32