records

README

Records Controller

Records controller controls the .Status.Experiment.Records field with the steps below:

1. if the records are nil, try to select new objects and save to the records.
2. iterate over records, for every record, if the Phase of it doesn't match the DesiredPhase, try to sync them through Apply or Recover, and update the Phase accordingly.
3. if the records has changed, upload them to the kubernetes server.

Design Discussion

The implementation of chaos should be simple

The definition of every chaos should be simple. It needs a configuration, one or more selectors, and an implementation for a single object. For example, the implementation of PodKill should only kill one pod, but not "select", "iterate" and delete all of them. These things (like "select", "iterate") should be done in the powerful controller.

Selector should be powerful

1. "Pod" is not the only target of chaos. We could inject chaos on volume, container, pod, ec2 machine... The selector abstraction should be able to handle the diversity.

2. One chaos definition should be able to have a lot of selector, e.g. the NetworkChaos.

Documentation

Index

• func Step(ctx *pipeline.PipelineContext) reconcile.Reconciler
• type Operation
• type Reconciler
  • func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Functions

func Step

func Step(ctx *pipeline.PipelineContext) reconcile.Reconciler

Types

type Operation

type Operation string

const (
	Apply   Operation = "apply"
	Recover Operation = "recover"
	Nothing Operation = ""
)

type Reconciler

type Reconciler struct {
	Impl types.ChaosImpl

	// Object is used to mark the target type of this Reconciler
	Object v1alpha1.InnerObject

	// Client is used to operate on the Kubernetes cluster
	client.Client
	client.Reader

	Recorder recorder.ChaosRecorder

	Selector *selector.Selector

	Log logr.Logger
}

Reconciler for chaos records

func (*Reconciler) Reconcile

func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile the chaos records