cque

type Client ¶

type Client struct {
	IsQueueEmpty bool

	Result chan Result
	// contains filtered or unexported fields
}

Client is a Que client that can add jobs to the queue and remove jobs from the queue.

func NewQue() *Client

func (c *Client) Enqueue(j Job)

type ErrorMsg ¶

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

type Job ¶

type Job struct {
	Type string
	// Args can be anything depends on the job
	Args interface{}
}

Job is a single unit of work for Que to perform.

func (j *Job) Error(msg string)

type Manager ¶

type Manager struct {
	Interval time.Duration
	// contains filtered or unexported fields
}

Manager is a single "worker" that check for when the job channel is empty This is done by checking the workerstatus channel and look for instances where all workers are waiting for job. This also only works because channel in GO are FIFO so we can get latest workers statuses

func NewManager(ctx context.Context, workercount int, c *Client) *Manager

func (m *Manager) Manage()

type Result ¶

type Result struct {
	JobType string
	// Args can be anything depends on the job
	Result interface{}
}

Result is the output of a Job and can be used to send something back to mainthread.

type WorkFunc ¶

type WorkFunc func(j *Job) error

generic WorkFunc is a function that performs a Job. If an error is returned, the job is reenqueued with exponential backoff.

type WorkMap ¶

type WorkMap map[string]WorkFunc

WorkMap is a map of Job names to WorkFuncs that are used to perform Jobs of a given type.

type Worker ¶

type Worker struct {
	Interval time.Duration
	// contains filtered or unexported fields
}

Worker is a single worker that pulls jobs off the specified Queue. If no Job is found, the Worker will sleep for Interval seconds.

func NewWorker(ctx context.Context, id int, c *Client, m WorkMap) *Worker

func (w *Worker) Work()

func (w *Worker) WorkOne(j *Job)

type WorkerPool ¶

type WorkerPool struct {
	WorkMap  WorkMap
	Interval time.Duration
	// contains filtered or unexported fields
}

WorkerPool is a pool of Workers, each working jobs from the queue Queue at the specified Interval using the WorkMap.

func NewWorkerPool(c *Client, wm WorkMap, count int) *WorkerPool

func (w *WorkerPool) Start(ctx context.Context)

type WorkerWaitStatus ¶

type WorkerWaitStatus struct {
	Id         int
	WaitStatus bool
}