atop

Documentation

Index

• func NewConstraint(jobKeyLabel *peloton.Label, cs []*api.Constraint) (*pod.Constraint, error)
• func NewCreateSpec(s *api.JobUpdateSettings) *stateless.CreateSpec
• func NewJobName(k *api.JobKey) string
• func NewJobSpecFromJobUpdateRequest(r *api.JobUpdateRequest, respoolID *peloton.ResourcePoolID, ...) (*stateless.JobSpec, error)
• func NewPodSpec(t *api.TaskConfig, c config.ThermosExecutorConfig) (*pod.PodSpec, error)
• func NewPodState(scheduleStatus api.ScheduleStatus) (pod.PodState, error)
• func NewUpdateSpec(s *api.JobUpdateSettings, inPlace bool) *stateless.UpdateSpec
• func NewWorkflowState(astate api.JobUpdateStatus) (stateless.WorkflowState, error)

Functions

func NewConstraint

func NewConstraint(
	jobKeyLabel *peloton.Label,
	cs []*api.Constraint,
) (*pod.Constraint, error)

NewConstraint creates a new Constraint.

func NewCreateSpec

func NewCreateSpec(s *api.JobUpdateSettings) *stateless.CreateSpec

NewCreateSpec creates a new CreateSpec.

func NewJobName

func NewJobName(k *api.JobKey) string

NewJobName creates a new job name.

func NewJobSpecFromJobUpdateRequest

func NewJobSpecFromJobUpdateRequest(
	r *api.JobUpdateRequest,
	respoolID *peloton.ResourcePoolID,
	c config.ThermosExecutorConfig,
) (*stateless.JobSpec, error)

NewJobSpecFromJobUpdateRequest creates a new JobSpec.

func NewPodSpec

func NewPodSpec(
	t *api.TaskConfig,
	c config.ThermosExecutorConfig,
) (*pod.PodSpec, error)

NewPodSpec creates a new PodSpec.

func NewPodState

func NewPodState(
	scheduleStatus api.ScheduleStatus) (pod.PodState, error)

NewPodState converts Aurora ScheduleStatus enum to Peloton PodState enum.

func NewUpdateSpec

func NewUpdateSpec(
	s *api.JobUpdateSettings,
	inPlace bool,
) *stateless.UpdateSpec

NewUpdateSpec creates a new UpdateSpec.

func NewWorkflowState

func NewWorkflowState(
	astate api.JobUpdateStatus) (stateless.WorkflowState, error)

NewWorkflowState converts aurora update status to peloton job update state