adapter

Documentation

Index

• func GenerateKusciaJobFrom(jobInfo *InterConnJobInfo) (*kusciaapisv1alpha1.KusciaJob, error)
• type InterConnJobInfo
  • func GenerateInterConnJobInfoFrom(kusciaJob *kusciaapisv1alpha1.KusciaJob, ...) (*InterConnJobInfo, error)
• type JobParamsResources

Functions

func GenerateKusciaJobFrom

func GenerateKusciaJobFrom(jobInfo *InterConnJobInfo) (*kusciaapisv1alpha1.KusciaJob, error)

GenerateKusciaJobFrom generates kuscia job from interconn job info.

Types

type InterConnJobInfo

type InterConnJobInfo struct {
	DAG    *interconn.DAG    `json:"dag"`
	Config *interconn.Config `json:"config"`
	JodID  string            `json:"job_id"`
	FlowID string            `json:"flow_id"`
}

InterConnJobInfo defines interconn job info.

func GenerateInterConnJobInfoFrom

func GenerateInterConnJobInfoFrom(kusciaJob *kusciaapisv1alpha1.KusciaJob, appImageLister kuscialistersv1alpha1.AppImageLister) (*InterConnJobInfo, error)

GenerateInterConnJobInfoFrom generates interconn job info from kuscia job.

type JobParamsResources

type JobParamsResources struct {
	Disk   float64 `json:"disk"`
	Memory float64 `json:"memory"`
	CPU    float64 `json:"cpu"`
}

JobParamsResources defines resources of job params.