pipengine

package

v1.2.0 Latest Latest Go to latest Published: Aug 13, 2021 License: AGPL-3.0 Imports: 9 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

This section is empty.

This section is empty.

This section is empty.

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

func New(
	dbClient *dbclient.Client,
) *Engine

func (engine *Engine) OnceDo(
	r *reconciler.Reconciler,
) error

func (engine *Engine) Send(pipelineID uint64)

func (engine *Engine) Start()

func (engine *Engine) WaitDBGC(pipelineID uint64, ttl uint64, needArchive bool)

Path	Synopsis
actionexecutor
plugins/apitest
plugins/apitest/logic
plugins/demo
plugins/memory
plugins/scheduler
plugins/scheduler/executor
plugins/scheduler/executor/plugins/k8sflink
plugins/scheduler/executor/plugins/k8sjob
plugins/scheduler/executor/plugins/k8sspark
plugins/scheduler/executor/types
plugins/scheduler/logic
types
pvolumes
queue Package queue includes: - priority queue - enhanced queue based on priority queue - throttler for pipeline based on enhanced queue	Package queue includes: - priority queue - enhanced queue based on priority queue - throttler for pipeline based on enhanced queue
enhancedqueue
priorityqueue
snapshot
throttler
reconciler
queuemanage/manager
queuemanage/queue
queuemanage/types
rlog
taskrun
taskrun/taskop