task

Documentation

Index

• func RunnerJob(instance *openstackv1beta1.RallyTask, cluster *openstackv1beta1.Rally, ...) *batchv1.Job
• type Reporter
  • func NewReporter(instance *openstackv1beta1.RallyTask, k8sClient client.Client, ...) *Reporter
  • func (r *Reporter) Completed(ctx context.Context) error
  • func (r *Reporter) Pending(ctx context.Context, message string, args ...any) error

Functions

func RunnerJob

func RunnerJob(instance *openstackv1beta1.RallyTask, cluster *openstackv1beta1.Rally, env []corev1.EnvVar, volumes []corev1.Volume) *batchv1.Job

Types

type Reporter

type Reporter struct {
	// contains filtered or unexported fields
}

func NewReporter

func NewReporter(instance *openstackv1beta1.RallyTask, k8sClient client.Client, recorder record.EventRecorder) *Reporter

func (*Reporter) Completed

func (r *Reporter) Completed(ctx context.Context) error

func (*Reporter) Pending

func (r *Reporter) Pending(ctx context.Context, message string, args ...any) error