queue

type Base struct {
	Opts Options

	Debug   bool
	Enqueue func([]byte) error
	// contains filtered or unexported fields
}

type Consumer func(job Jober) error

type Job struct {
	Name     string
	Payload  []byte
	MaxTries int
	Timeout  time.Duration
}

type Jober interface {
	GetName() string
	GetMaxTries() int
	Serialize() ([]byte, error)
	Unserialize() (Job, error)
	PackPayload() ([]byte, error)
	UnpackPayload(interface{}) error
	GetPayload() []byte
}

type Options struct {
	Name        string
	Driver      string
	Parallel    int
	Debug       bool
	Metric      bool
	Consume     bool
	WaitTimeOut time.Duration
	Logger      *logrus.Logger
}

type Queuer interface {
	In(job Jober) (err error)
	Parse(payload string) (j Jober, err error)
	Do(job Jober, fn Consumer, cbs ...func(error)) (err error)
	RegisterConsumer(name string, f Consumer)
	Run()
}