scheduler

Documentation

Index

• Constants
• type SimpleScheduler
  • func InitSimpleScheduler(dbHandler *database.Handler) (*SimpleScheduler, error)
  • func (scheduler *SimpleScheduler) DeleteJob(jobName string) error
  • func (scheduler *SimpleScheduler) GetK8sClient() *kubernetes.Clientset
  • func (scheduler *SimpleScheduler) GetNamespace() string
  • func (scheduler *SimpleScheduler) StartJob(jobID string, jobConfig *api.JobConfig, baktaConfString string) (*batchv1.Job, error)

Constants

const JOBTTL = 100

Types

type SimpleScheduler

type SimpleScheduler struct {
	// contains filtered or unexported fields
}

SimpleScheduler A simple scheduler to run bakta jobs on a Kubernetes cluster The config will be picked up from the

func InitSimpleScheduler

func InitSimpleScheduler(dbHandler *database.Handler) (*SimpleScheduler, error)

InitSimpleScheduler Initiates a scheduler to run bakta jobs

func (*SimpleScheduler) DeleteJob

func (scheduler *SimpleScheduler) DeleteJob(jobName string) error

func (*SimpleScheduler) GetK8sClient

func (scheduler *SimpleScheduler) GetK8sClient() *kubernetes.Clientset

func (*SimpleScheduler) GetNamespace

func (scheduler *SimpleScheduler) GetNamespace() string

func (*SimpleScheduler) StartJob

func (scheduler *SimpleScheduler) StartJob(jobID string, jobConfig *api.JobConfig, baktaConfString string) (*batchv1.Job, error)

StartJob Starts a bakta job on Kubernetes