kubernetes: k8s.io/kubernetes/pkg/apis/batch/fuzzer Index | Files

package fuzzer

import "k8s.io/kubernetes/pkg/apis/batch/fuzzer"

Index

Package Files

fuzzer.go

Variables

var Funcs = func(codecs runtimeserializer.CodecFactory) []interface{} {
    return []interface{}{
        func(j *batch.Job, c fuzz.Continue) {
            c.FuzzNoCustom(j)

            if len(j.Labels) == 0 {
                j.Labels = j.Spec.Template.Labels
            }
        },
        func(j *batch.JobSpec, c fuzz.Continue) {
            c.FuzzNoCustom(j)
            completions := int32(c.Rand.Int31())
            parallelism := int32(c.Rand.Int31())
            backoffLimit := int32(c.Rand.Int31())
            j.Completions = &completions
            j.Parallelism = &parallelism
            j.BackoffLimit = &backoffLimit
            if c.Rand.Int31()%2 == 0 {
                j.ManualSelector = newBool(true)
            } else {
                j.ManualSelector = nil
            }
        },
        func(sj *batch.CronJobSpec, c fuzz.Continue) {
            c.FuzzNoCustom(sj)
            suspend := c.RandBool()
            sj.Suspend = &suspend
            sds := int64(c.RandUint64())
            sj.StartingDeadlineSeconds = &sds
            sj.Schedule = c.RandString()
            successfulJobsHistoryLimit := int32(c.Rand.Int31())
            sj.SuccessfulJobsHistoryLimit = &successfulJobsHistoryLimit
            failedJobsHistoryLimit := int32(c.Rand.Int31())
            sj.FailedJobsHistoryLimit = &failedJobsHistoryLimit
        },
        func(cp *batch.ConcurrencyPolicy, c fuzz.Continue) {
            policies := []batch.ConcurrencyPolicy{batch.AllowConcurrent, batch.ForbidConcurrent, batch.ReplaceConcurrent}
            *cp = policies[c.Rand.Intn(len(policies))]
        },
    }
}

Funcs returns the fuzzer functions for the batch api group.

Package fuzzer imports 3 packages (graph) and is imported by 32 packages. Updated 2018-07-18. Refresh now. Tools for package owners.