qruntime

package

v0.4.2 Latest Latest Go to latest Published: Apr 25, 2024 License: MPL-2.0 Imports: 19 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

Repository

github.com/cosi-project/runtime

Links

Open Source Insights

Documentation ¶

Overview ¶

Package qruntime implements queue-based runtime for controllers.

Index ¶

Constants
type Adapter
- func NewAdapter(ctrl controller.QController, adapterOptions adapter.Options) (*Adapter, error)
- func (adapter *Adapter) Run(ctx context.Context)
- func (adapter *Adapter) WatchTrigger(md *reduced.Metadata)
type QItem
- func NewQItem(md resource.Pointer, job QJob) QItem
- func NewQItemFromReduced(md *reduced.Metadata, job QJob) QItem
type QJob
- func (job QJob) String() string

Constants ¶

View Source

const DefaultConcurrency = 1

DefaultConcurrency is the default concurrency for the QController.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Adapter ¶

type Adapter struct {
	controllerstate.StateAdapter
	// contains filtered or unexported fields
}

Adapter implements QRuntime interface for the QController.

func NewAdapter ¶

func NewAdapter(
	ctrl controller.QController,
	adapterOptions adapter.Options,
) (*Adapter, error)

NewAdapter creates a new QRuntime adapter for the QController.

func (*Adapter) Run ¶

func (adapter *Adapter) Run(ctx context.Context)

Run the QController.

func (*Adapter) WatchTrigger ¶

func (adapter *Adapter) WatchTrigger(md *reduced.Metadata)

WatchTrigger is called by common controller runtime when there is a change in the watched resources.

type QItem ¶

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

QItem is stored in the reconcile queue.

func NewQItem ¶

func NewQItem(md resource.Pointer, job QJob) QItem

NewQItem creates a new QItem.

func NewQItemFromReduced ¶

func NewQItemFromReduced(md *reduced.Metadata, job QJob) QItem

NewQItemFromReduced creates a new QItem from a reduced Metadata.

func (QItem) ID ¶

func (item QItem) ID() resource.ID

ID implements resource.Pointer interface.

func (QItem) Namespace ¶

func (item QItem) Namespace() resource.Namespace

Namespace implements resource.Pointer interface.

func (QItem) Type ¶

func (item QItem) Type() resource.Type

Type implements resource.Pointer interface.

type QJob ¶

type QJob int

QJob is a job to be executed by the reconcile queue.

const (
	QJobReconcile QJob = iota
	QJobMap
)

QJob constants.

func (QJob) String ¶

func (job QJob) String() string

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
internal
containers Package containers provides helper containers for qruntime.	Package containers provides helper containers for qruntime.
queue Package queue implements a concurrent queue of reconcile items.	Package queue implements a concurrent queue of reconcile items.
timer Package timer provides a resettable timer.	Package timer provides a resettable timer.

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