store

Documentation

Index

• Variables
• func NewMysqlStore(opts *OptionsWithDB, payloader Payloader) (*mysqlStore, error)
• func NewMysqlStoreWithDB(opts *Options, db *gorm.DB, payloader Payloader) (*mysqlStore, error)
• type MQStatus
• type Options
• type OptionsWithDB
• type Payloader

Variables

var (
	ErrMessageIng  = errors.New("the message is consuming")
	ErrMessageDone = errors.New("the message is consumed")
	ErrAssertFail  = errors.New("assert failure")
)

var DefaultPayload = &defaultPayload{}

Functions

func NewMysqlStore

func NewMysqlStore(opts *OptionsWithDB, payloader Payloader) (*mysqlStore, error)

func NewMysqlStoreWithDB

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

Types

type MQStatus

type MQStatus int

const (
	StatusUndo  MQStatus = 0
	StatusDoing MQStatus = 1
	StatusDone  MQStatus = 2
)

type Options

type Options struct {
	TableName string
	// 假设任务最长执行时间为 a
	// 假设宕机最长时间为 b
	// 下面时间为 c
	// 应当满足 b < c < a
	ReadRepeatTimeout time.Duration
}

type OptionsWithDB

type OptionsWithDB struct {
	Options

	Debug bool

	User     string
	Password string
	Address  string
	DBName   string

	Timeout     string
	ReadTimeout string
}

type Payloader

type Payloader interface {
	Encode(topic string, payload interface{}) ([]byte, error)
	Decode(topic string, payload []byte) (interface{}, error)
}