state

package

v0.3.0 Latest Latest Go to latest Published: Feb 21, 2020 License: Apache-2.0 Imports: 4 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/SkinyMonkey/volcano

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func TotalTasks(job *vcbatch.Job) int32
type ActionFn
type KillActionFn
type PhaseMap
type State
- func NewState(jobInfo *apis.JobInfo) State
type UpdateStatusFn

Constants ¶

View Source

const DefaultMaxRetry int32 = 3

DefaultMaxRetry is the default number of retries.

Variables ¶

View Source

var (
	// SyncJob will create or delete Pods according to Job's spec.
	SyncJob ActionFn
	// KillJob kill all Pods of Job with phase not in podRetainPhase.
	KillJob KillActionFn
)

View Source

var PodRetainPhaseNone = PhaseMap{}

PodRetainPhaseNone stores no phase

View Source

var PodRetainPhaseSoft = PhaseMap{
	v1.PodSucceeded: {},
	v1.PodFailed:    {},
}

PodRetainPhaseSoft stores PodSucceeded and PodFailed Phase

Functions ¶

func TotalTasks ¶

func TotalTasks(job *vcbatch.Job) int32

TotalTasks returns number of tasks in a given volcano job

Types ¶

type ActionFn ¶

type ActionFn func(job *apis.JobInfo, fn UpdateStatusFn) error

ActionFn will create or delete Pods according to Job's spec.

type KillActionFn ¶

type KillActionFn func(job *apis.JobInfo, podRetainPhase PhaseMap, fn UpdateStatusFn) error

KillActionFn kill all Pods of Job with phase not in podRetainPhase.

type PhaseMap ¶

type PhaseMap map[v1.PodPhase]struct{}

PhaseMap to store the pod phases.

type State ¶

type State interface {
	// Execute executes the actions based on current state.
	Execute(act vcbatch.Action) error
}

State interface

func NewState ¶

func NewState(jobInfo *apis.JobInfo) State

NewState gets the state from the volcano job Phase

type UpdateStatusFn ¶

type UpdateStatusFn func(status *vcbatch.JobStatus) (jobPhaseChanged bool)

UpdateStatusFn updates the job status.

Source Files ¶

View all Source files

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