queue

package

v0.3.3 Latest Latest Go to latest Published: Mar 31, 2022 License: BSD-3-Clause Imports: 13 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func (e *Encoding) Decode(raw []byte) (*task.Task, error)

func (e *Encoding) Encode(t *task.Task) ([]byte, error)

type Queue struct {
	sync.RWMutex

	BatchEnded chan bool

	Sink events.Sink
	// contains filtered or unexported fields
}

Queue struct use to put and get job items

func NewQueue(sto storage.Storage, runner *run.Runner, sink events.Sink) Queue

NewQueue inits a new queue struct

func (q *Queue) DequeueWhile()

DequeueWhile start maxDequeue workers while the queue is not empty

func (q *Queue) Len() int

Len of the current dequeue

func (q *Queue) Put(item *task.Task, env map[string]string) error

Put a new item into the queue and the storage