queue

package module

v0.0.0-...-1449df2 Latest Latest Go to latest Published: Sep 16, 2020 License: MIT Imports: 2 Imported by: 1

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

Repository

github.com/300481/kitops

Links

Open Source Insights

README ¶

pgk queue

This package contains a simple general queue for all data types.

The queue ensures processing with the FIFO principle.

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Consumer ¶

type Consumer interface {
	Process(q *Queue)
}

type Queue ¶

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

func New ¶

func New(consumer Consumer) *Queue

New creates a new Queue and returns *Queue.

func (*Queue) Add ¶

func (q *Queue) Add(v interface{})

Add adds a new commit string as element to the Queue and initiate a threaded processing.

func (*Queue) Current ¶

func (q *Queue) Current() interface{}

Current returns the current element

func (*Queue) Finish ¶

func (q *Queue) Finish(success bool)

Finish finishes the current element processing of the queue and unlock the mutex.

func (*Queue) LastSuccessful ¶

func (q *Queue) LastSuccessful() interface{}

LastSuccessful returns the last successful processed element

func (*Queue) Previous ¶

func (q *Queue) Previous() interface{}

Previous returns the previous element

func (*Queue) StartNext ¶

func (q *Queue) StartNext() interface{}

StartNext returns the next element in the queue and clean the queue by one. It also Locks a Mutex. Must be finalized with Finish() to unlock the mutex.

func (*Queue) Status ¶

func (q *Queue) Status() Status

Status returns the status of the current processed element

type Status ¶

type Status string

const (
	Init       Status = "Init"
	InProgress Status = "InProgress"
	Failed     Status = "Failed"
	Successful Status = "Successful"
)

Source Files ¶

View all Source files

queue.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL