task

Documentation

Index

• func CreateEmptyResourceUsageMap() map[string]float64
• func CreateInitializingTask(jobID *peloton.JobID, instanceID uint32, jobConfig *job.JobConfig) *task.RuntimeInfo
• func CreateResourceUsageMap(resourceConfig *task.ResourceConfig, startTimeStr, completionTimeStr string) (map[string]float64, error)
• func CreateSecretProto(id, path string, data []byte) *peloton.Secret
• func CreateSecretsFromVolumes(secretVolumes []*mesos_v1.Volume) []*peloton.Secret
• func CreateV1AlphaSecretProto(id, path string, data []byte) *v1alphapeloton.Secret
• func EnqueueGangs(ctx context.Context, tasks []*task.TaskInfo, jobConfig jobmgrcommon.JobConfig, ...) (*resmgrsvc.EnqueueGangsResponse, error)
• func GetDefaultTaskGoalState(jobType job.JobType) task.TaskState
• func KillOrphanTask(ctx context.Context, lm lifecyclemgr.Manager, taskInfo *task.TaskInfo) error

Functions

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

func EnqueueGangs(
	ctx context.Context,
	tasks []*task.TaskInfo,
	jobConfig jobmgrcommon.JobConfig,
	client resmgrsvc.ResourceManagerServiceYARPCClient) (*resmgrsvc.EnqueueGangsResponse, error)

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

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