chaos

Documentation

Index

• Constants
• Variables
• func IsJobChanged(ssChaos *v1alpha1.Chaos, requirement JobType, cur *v1.Job) (bool, error)
• func MakeJobName(name string, requirement JobType) string
• func MustInt32(s string) (int32, error)
• func MustInt64(s string) (int64, error)
• func NewCmds(requirement JobType) []string
• func NewJob(ssChaos *v1alpha1.Chaos, requirement JobType) (*v1.Job, error)
• type JobBuilder
  • func NewJobBuilder() JobBuilder
• type JobType

Constants

const (
	DefaultImageName     = "agoiyanzsa/tools-runtime:2.0"
	DefaultContainerName = "tools-runtime"
	DefaultWorkPath      = "/app/start"
	DefaultConfigName    = "cmd-conf"
)

const (
	AnnoJobCompletions             = "jobs.batch/completions"
	AnnoJobActiveDeadlineSeconds   = "jobs.batch/activeDeadlineSeconds"
	AnnoJobParallelism             = "job.batch/parallelism"
	AnnoJobBackoffLimit            = "job.batch/backoffLimit"
	AnnoJobTTLSecondsAfterFinished = "job.batch/ttlSecondsAfterFinished"
	AnnoJobSuspend                 = "job.batch/suspend"
)

const (
	DefaultConfigMapName = "ssChaos-configmap"
)

Variables

var DefaultFileMode int32 = 493

var (
	DefaultTTLSecondsAfterFinished int32 = 300
)

Functions

func IsJobChanged

func IsJobChanged(ssChaos *v1alpha1.Chaos, requirement JobType, cur *v1.Job) (bool, error)

func MakeJobName

func MakeJobName(name string, requirement JobType) string

func MustInt32

func MustInt32(s string) (int32, error)

func MustInt64

func MustInt64(s string) (int64, error)

func NewCmds

func NewCmds(requirement JobType) []string

func NewJob

func NewJob(ssChaos *v1alpha1.Chaos, requirement JobType) (*v1.Job, error)

Types

type JobBuilder

type JobBuilder interface {
	SetName(string) JobBuilder
	SetNamespace(string) JobBuilder
	SetLabels(map[string]string) JobBuilder
	SetCompletions(int32) JobBuilder
	SetActiveDeadlineSeconds(int64) JobBuilder
	SetParallelism(int32) JobBuilder
	SetBackoffLimit(int32) JobBuilder
	SetContainers(*corev1.Container) JobBuilder
	SetTTLSecondsAfterFinished(int32) JobBuilder
	SetSuspend(bool) JobBuilder
	SetVolumes(*corev1.Volume) JobBuilder
	Build() *v1.Job
}

func NewJobBuilder

func NewJobBuilder() JobBuilder

type JobType

type JobType string

var (
	InSteady JobType = "steady"
	InChaos  JobType = "chaos"
)