qruntime

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
  • func (item QItem) ID() resource.ID
  • func (item QItem) Namespace() resource.Namespace
  • func (item QItem) Type() resource.Type
• type QJob
  • func (job QJob) String() string

Constants

const DefaultConcurrency = 1

DefaultConcurrency is the default concurrency for the QController.

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