chaos

package

v0.0.0-...-f5de34e Latest Latest Go to latest Published: Dec 28, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/apache/shardingsphere-on-cloud

Links

Open Source Insights

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 ¶

View Source

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

View Source

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"
)

View Source

const (
	DefaultConfigMapName = "ssChaos-configmap"
)

Variables ¶

View Source

var DefaultFileMode int32 = 493

View Source

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"
)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL