job

type Configuration struct {
	Workers  int            `toml:"workers"`
	TimeoutI int            `toml:"timeout"`
	QueuesM  map[string]int `toml:"queues"`
}

type Message struct {
	Id      string    `json:"id"`
	Title   string    `json:"title"`
	Body    []byte    `json:"body"`
	Created time.Time `json:"created"`
}

type RedisStore struct {
	// contains filtered or unexported fields
}

type Store interface {
	Push(queue string, msg *Message) error
	Pop(timeout time.Duration, queues ...string) (string, *Message, error)
	Done(queue string, msg *Message, err error)
}

type Worker interface {
	Do(msg *Message) error
}