pipe

Documentation

Index

• func DebugLogger[T context.Context](logger logr.Logger) pipeline.Listener[T]
• func NewKubeClient(ctx context.Context) (client.Client, error)
• func UpdateFailedCondition(ctx context.Context, kube client.Client, conds *[]metav1.Condition, ...) error

Functions

func DebugLogger

func DebugLogger[T context.Context](logger logr.Logger) pipeline.Listener[T]

DebugLogger returns a list with a single hook that logs the step name. The logger is retrieved from the given context.

func NewKubeClient

func NewKubeClient(ctx context.Context) (client.Client, error)

NewKubeClient creates a new client.Client using in-cluster config.

func UpdateFailedCondition

func UpdateFailedCondition(ctx context.Context, kube client.Client, conds *[]metav1.Condition, obj client.Object, err error) error