memory

Documentation

Index

• Constants
• type Memory
  • func New(concurrency uint) (memory *Memory)
  • func (m *Memory) Add(payload *job.Job, executionTimeout time.Duration, userID string) (taskID string)
  • func (m *Memory) GetTaskStatus(taskID string) (info []byte, userID string)
  • func (m *Memory) ListAllTasks() (tasks []*scheduler.Task)
  • func (m *Memory) MoveToWorkQeueu(taskID string) (err error)
• type Queue

Constants

const Concurency uint = 5

Types

type Memory

type Memory struct {
	Wait         *Queue
	Work         *Queue
	Done         *Queue
	InputChannel chan *scheduler.Task
	DemoLock     *demolock.DemoLock
	// contains filtered or unexported fields
}

func New

func New(concurrency uint) (memory *Memory)

func (*Memory) Add

func (m *Memory) Add(payload *job.Job, executionTimeout time.Duration, userID string) (taskID string)

Adds task to queue (wait)

func (*Memory) GetTaskStatus

func (m *Memory) GetTaskStatus(taskID string) (info []byte, userID string)

func (*Memory) ListAllTasks

func (m *Memory) ListAllTasks() (tasks []*scheduler.Task)

func (*Memory) MoveToWorkQeueu

func (m *Memory) MoveToWorkQeueu(taskID string) (err error)

Move Item from the Wait to the Work queue

type Queue

type Queue struct {
	Tasks *[]*scheduler.Task
	Mutex sync.Mutex
}