cetokjob

Documentation

Index

• type JobConfig
  • func LoadJobConfig(path string) ([]JobConfig, error)
• type JobGenerator
  • func NewJobGenerator(ns string, clientset kubernetes.Interface, jcs []JobConfig) *JobGenerator
  • func (creator *JobGenerator) GenerateJob(envMap map[string]string) ([]batchv1.Job, error)

Types

type JobConfig

type JobConfig struct {
	Name      string   `json:"name"`
	Image     string   `json:"image"`
	Command   []string `json:"command"`
	Args      []string `json:"args"`
	Configmap string   `json:"configmap"`
	Secret    string   `json:"secret"`
}

JobConfig represents the configuration of a job.

func LoadJobConfig

func LoadJobConfig(path string) ([]JobConfig, error)

LoadJobConfig reads the configuration file and returns []JobConfig

type JobGenerator

type JobGenerator struct {
	// Configs of job to be Generated
	JobConfigs []JobConfig
	// contains filtered or unexported fields
}

JobGenerator is an object to generate jobs

func NewJobGenerator

func NewJobGenerator(ns string, clientset kubernetes.Interface, jcs []JobConfig) *JobGenerator

NewJobGenerator generate JobGenerator

func (*JobGenerator) GenerateJob

func (creator *JobGenerator) GenerateJob(envMap map[string]string) ([]batchv1.Job, error)

GenerateJob creates a job by adding environment variables to a specified job