Version: v0.0.0-...-a69e935 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Oct 1, 2019 License: Apache-2.0 Imports: 19 Imported by: 0




This section is empty.


This section is empty.


func CreateEmptyResourceUsageMap

func CreateEmptyResourceUsageMap() map[string]float64

CreateEmptyResourceUsageMap creates a resource usage map with usage stats initialized to 0

func CreateInitializingTask

func CreateInitializingTask(jobID *peloton.JobID, instanceID uint32, jobConfig *job.JobConfig) *task.RuntimeInfo

CreateInitializingTask for insertion into the storage layer, before being enqueued.

func CreateResourceUsageMap

func CreateResourceUsageMap(
	resourceConfig *task.ResourceConfig,
	startTimeStr, completionTimeStr string) (map[string]float64, error)

CreateResourceUsageMap creates a resource usage map with usage stats calculated as resource limit * duration

func CreateSecretProto

func CreateSecretProto(id, path string, data []byte) *peloton.Secret

CreateSecretProto creates secret proto message from secret-id, path and data

func CreateSecretsFromVolumes

func CreateSecretsFromVolumes(
	secretVolumes []*mesos_v1.Volume) []*peloton.Secret

CreateSecretsFromVolumes creates secret proto message list from the given list of secret volumes.

func CreateV1AlphaSecretProto

func CreateV1AlphaSecretProto(id, path string, data []byte) *v1alphapeloton.Secret

CreateV1AlphaSecretProto creates v1alpha secret proto message from secret-id, path and data

func EnqueueGangs

EnqueueGangs enqueues all tasks organized in gangs to respool in resmgr.

func GetDefaultPodGoalState

func GetDefaultPodGoalState(jobType job.JobType) pod.PodState

GetDefaultPodGoalState from the job type.

func GetDefaultTaskGoalState

func GetDefaultTaskGoalState(jobType job.JobType) task.TaskState

GetDefaultTaskGoalState from the job type.

func KillOrphanTask

func KillOrphanTask(
	ctx context.Context,
	lm lifecyclemgr.Manager,
	taskInfo *task.TaskInfo,
) error

KillOrphanTask kills a non-stateful Mesos task with unterminated state


This section is empty.

Source Files


Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL