taskqueue

package

v1.7.0 Latest Latest Go to latest Published: Feb 14, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Package taskqueue contains task queue

This section is empty.

This section is empty.

This section is empty.

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

TaskQueue manages a work queue through an independent worker that invokes the given sync function for every work item inserted.

func NewTaskQueue(syncFn func(string, interface{}) error) *TaskQueue

NewTaskQueue creates a new task queue with the given sync function. The sync function is called for every element inserted into the queue.

func (tq *TaskQueue) Enqueue(name string, data interface{})

Enqueue enqueues ns/name of the given api object in the task queue.

func (tq *TaskQueue) Len() int

Len returns the length of the queue.

func (tq *TaskQueue) Requeue(task task, err error)

Requeue adds the task to the queue again and logs the given error.

func (tq *TaskQueue) RequeueAfter(t task, err error, after time.Duration)

RequeueAfter adds the task to the queue after the given duration.

func (tq *TaskQueue) Run(period time.Duration, stopCh <-chan struct{})

Run begins running the worker for the given duration.

func (tq *TaskQueue) Shutdown()

Shutdown shuts down the work queue and waits for the worker to ACK.