kernelchaos

Documentation

Index

• Variables
• func NewImpl(c client.Client, log logr.Logger, ...) *impltypes.ChaosImplPair
• type Impl
  • func (impl *Impl) Apply(ctx context.Context, index int, records []*v1alpha1.Record, ...) (v1alpha1.Phase, error)
  • func (impl *Impl) CreateBPFKIConnection(ctx context.Context, c client.Client, pod *v1.Pod) (*grpc.ClientConn, error)
  • func (impl *Impl) Recover(ctx context.Context, index int, records []*v1alpha1.Record, ...) (v1alpha1.Phase, error)

Variables

var Module = fx.Provide(
	fx.Annotated{
		Group:  "impl",
		Target: NewImpl,
	},
)

Functions

func NewImpl

func NewImpl(c client.Client, log logr.Logger, builder *chaosdaemon.ChaosDaemonClientBuilder) *impltypes.ChaosImplPair

Types

type Impl

type Impl struct {
	client.Client
	Log logr.Logger
	// contains filtered or unexported fields
}

func (*Impl) Apply

func (impl *Impl) Apply(ctx context.Context, index int, records []*v1alpha1.Record, obj v1alpha1.InnerObject) (v1alpha1.Phase, error)

Apply applies KernelChaos

func (*Impl) CreateBPFKIConnection

func (impl *Impl) CreateBPFKIConnection(ctx context.Context, c client.Client, pod *v1.Pod) (*grpc.ClientConn, error)

CreateBPFKIConnection create a grpc connection with bpfki

func (*Impl) Recover

func (impl *Impl) Recover(ctx context.Context, index int, records []*v1alpha1.Record, obj v1alpha1.InnerObject) (v1alpha1.Phase, error)

Recover means the reconciler recovers the chaos action