jq

type Job struct {
	Id      string        `json:"id"`
	Data    []byte        `json:"data"`
	Timeout time.Duration `json:"timeout"`
	// contains filtered or unexported fields
}

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

type JqOptions struct {
	QueueCheckInterval time.Duration
	CocurrentWorkerNum int
}

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

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

type Msg struct {
	Type MsgType `json:"type"`
	Data []byte  `json:"data"`
}

type MsgType int

type Queue interface {
	Push([]byte) error
	Pop() ([]byte, error)
	Len() int
	Name() string
}

type QueueFactory func(name string) Queue

type QueueManager interface {
	Exists(name string) (bool, error)
	Get(name string) (Queue, error)
	GetOrCreate(name string) (Queue, error)
	Del(name string) error
}

type QueueManagerFactory func(QueueFactory) QueueManager

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

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

type WorkerFunc func(input []byte, ret chan<- []byte, done chan<- struct{}, err chan<- error)