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 GetDefaultPodGoalState(jobType job.JobType) pod.PodState
- func GetDefaultTaskGoalState(jobType job.JobType) task.TaskState
- func KillOrphanTask(ctx context.Context, lm lifecyclemgr.Manager, taskInfo *task.TaskInfo) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateEmptyResourceUsageMap ¶
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 ¶
CreateSecretProto creates secret proto message from secret-id, path and data
func CreateSecretsFromVolumes ¶
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 GetDefaultPodGoalState ¶
GetDefaultPodGoalState from the job type.
func GetDefaultTaskGoalState ¶
GetDefaultTaskGoalState from the job type.
func KillOrphanTask ¶
KillOrphanTask kills a non-stateful Mesos task with unterminated state
Types ¶
This section is empty.
Source Files
Directories