pipengine

package

v1.3.2 Latest Latest Go to latest Published: Oct 19, 2021 License: Apache-2.0 Imports: 10 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) StartGC(ctx context.Context)

func (engine *Engine) StartReconciler(ctx context.Context)

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
plugins/wait
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 @Title This file is used to cache the objects that need to be reused in the reconciler @Description The cached data is placed in the global sync.Map, you need to call clearPipelineContextCaches to clean up the corresponding data after you use it at will	@Title This file is used to cache the objects that need to be reused in the reconciler @Description The cached data is placed in the global sync.Map, you need to call clearPipelineContextCaches to clean up the corresponding data after you use it at will
queuemanage/manager
queuemanage/queue
queuemanage/types
rlog
taskrun
taskrun/taskop