store

Nov 30, 2018

Changes in this version

type Options

+ TableName string

Nov 29, 2018

Changes in this version

+ var DefaultPayload = &defaultPayload

+ var ErrAssertFail = errors.New("assert failure")

+ var ErrMessageDone = errors.New("the message is consumed")

+ var ErrMessageIng = errors.New("the message is consuming")

+ var ErrMessageNotStart = errors.New("message not start")

+ func NewMysqlStoreWithDB(opts *Options, db *gorm.DB, payloader Payloader) (*mysqlStore, error)

+ type MQStatus int

+ const StatusDoing

+ const StatusDone

+ const StatusUndo

+ type Options struct

+ ReadRepeatTimeout time.Duration

+ type OptionsWithDB struct

+ Address string

+ DBName string

+ Debug bool

+ Password string

+ ReadTimeout string

+ TableName string

+ Timeout string

+ User string

+ type Payloader interface

+ Decode func(topic string, payload []byte) (interface{}, error)

+ Encode func(topic string, payload interface{}) ([]byte, error)

Sep 7, 2018

Changes in this version

+ type MQHelp struct

+ Id int64

+ NextId int64

+ type MysqlStore struct

+ func NewMysqlStore(log logrus.FieldLogger, db *gorm.DB, taskTimeout time.Duration, ...) *MysqlStore

+ func (ms *MysqlStore) Done(task mqq.Task) error

+ func (ms *MysqlStore) FetchNext(done <-chan struct{}) (mqq.NextFunc, error)

+ func (ms *MysqlStore) Insert(topic string, payload []byte) error

+ func (ms *MysqlStore) Select(id int64) (*mqq.MQStore, error)

+ func (ms *MysqlStore) Start(task mqq.Task) error