pipe

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