Documentation
¶
Overview ¶
Package rruntime implements runtime for Controllers (which reconcile full set of inputs on each iteration).
Index ¶
- type Adapter
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
CleanupOutputs destroys all output resources that were not tracked.
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) StartTrackingOutputs ¶
func (adapter *Adapter) StartTrackingOutputs()
StartTrackingOutputs enables output tracking for the controller.
func (*Adapter) UpdateInputs ¶
func (adapter *Adapter) UpdateInputs(deps []controller.Input) error
UpdateInputs implements controller.Runtime interface.
func (*Adapter) WatchTrigger ¶
WatchTrigger is called by common controller runtime when there is a change in the watched resources.
Source Files