priority

Documentation

Index

• func Contains(sl []string, item string) bool
• type Item
• type Position
• type Queue
  • func NewQueue(redisOpts *redis.Options) *Queue
  • func (q *Queue) Inc(stream Item) error
  • func (q *Queue) Pop() (*Position, error)
  • func (q *Queue) Return(position *Position) error
• type TaskManager
  • func (m *TaskManager) LoadTasks() error
• type TaskReport
• type TaskRunner
  • func (r *TaskRunner) GetInitialTasks()

Functions

func Contains

func Contains(sl []string, item string) bool

Types

type Item

type Item struct {
	URL string
}

type Position

type Position struct {
	Score float64
	Item  Item
}

type Queue

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

func NewQueue

func NewQueue(redisOpts *redis.Options) *Queue

func (*Queue) Inc

func (q *Queue) Inc(stream Item) error

func (*Queue) Pop

func (q *Queue) Pop() (*Position, error)

func (*Queue) Return

func (q *Queue) Return(position *Position) error

type TaskManager

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

func (*TaskManager) LoadTasks

func (m *TaskManager) LoadTasks() error

type TaskReport

type TaskReport struct {
	ULID       string
	Status     string
	Progress   float32
	ReceivedAt time.Time
}

type TaskRunner

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

func (*TaskRunner) GetInitialTasks

func (r *TaskRunner) GetInitialTasks()