rruntime

Documentation

Overview

Package rruntime implements runtime for Controllers (which reconcile full set of inputs on each iteration).

Index

• type Adapter
  • func NewAdapter(ctrl controller.Controller, adapterOptions adapter.Options) (*Adapter, error)
  • func (adapter *Adapter) CleanupOutputs(ctx context.Context, outputs ...resource.Kind) error
  • func (adapter *Adapter) Create(ctx context.Context, r resource.Resource) error
  • func (adapter *Adapter) EventCh() <-chan controller.ReconcileEvent
  • func (adapter *Adapter) Modify(ctx context.Context, emptyResource resource.Resource, ...) error
  • func (adapter *Adapter) ModifyWithResult(ctx context.Context, emptyResource resource.Resource, ...) (resource.Resource, error)
  • func (adapter *Adapter) QueueReconcile()
  • func (adapter *Adapter) ResetRestartBackoff()
  • func (adapter *Adapter) Run(ctx context.Context)
  • func (adapter *Adapter) StartTrackingOutputs()
  • func (adapter *Adapter) Update(ctx context.Context, newResource resource.Resource) error
  • func (adapter *Adapter) UpdateInputs(deps []controller.Input) error
  • func (adapter *Adapter) WatchTrigger(md *reduced.Metadata)

Types

type Adapter

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

Adapter connects common controller-runtime and rruntime controller.

func NewAdapter

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

NewAdapter creates a new Adapter for the Controller.

func (*Adapter) CleanupOutputs

func (adapter *Adapter) CleanupOutputs(ctx context.Context, outputs ...resource.Kind) error

CleanupOutputs destroys all output resources that were not tracked.

func (*Adapter) Create

func (adapter *Adapter) Create(ctx context.Context, r resource.Resource) error

Create augments StateAdapter Create with output tracking.

func (*Adapter) EventCh

func (adapter *Adapter) EventCh() <-chan controller.ReconcileEvent

EventCh implements controller.Runtime interface.

func (*Adapter) Modify

func (adapter *Adapter) Modify(ctx context.Context, emptyResource resource.Resource, updateFunc func(resource.Resource) error) error

Modify augments StateAdapter Modify with output tracking.

func (*Adapter) ModifyWithResult

func (adapter *Adapter) ModifyWithResult(ctx context.Context, emptyResource resource.Resource, updateFunc func(resource.Resource) error) (resource.Resource, error)

ModifyWithResult augments StateAdapter ModifyWithResult with output tracking.

func (*Adapter) QueueReconcile

func (adapter *Adapter) QueueReconcile()

QueueReconcile implements controller.Runtime interface.

func (*Adapter) ResetRestartBackoff

func (adapter *Adapter) ResetRestartBackoff()

ResetRestartBackoff implements controller.Runtime interface.

func (*Adapter) Run

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

Run the controller loop via the adapter.

func (*Adapter) StartTrackingOutputs

func (adapter *Adapter) StartTrackingOutputs()

StartTrackingOutputs enables output tracking for the controller.

func (*Adapter) Update

func (adapter *Adapter) Update(ctx context.Context, newResource resource.Resource) error

Update augments StateAdapter Update with output tracking.

func (*Adapter) UpdateInputs

func (adapter *Adapter) UpdateInputs(deps []controller.Input) error

UpdateInputs implements controller.Runtime interface.

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.