kubernetes

Documentation

Index

• func CheckAll(logger logrus.FieldLogger, clientset kubernetes.Interface, config *viper.Viper) bool
• func CreateManagerPod(logger logrus.FieldLogger, clientset kubernetes.Interface, config *viper.Viper, ...)
• func DeleteAll(logger logrus.FieldLogger, clientset kubernetes.Interface, config *viper.Viper)
• func DeleteAllManager(logger logrus.FieldLogger, clientset kubernetes.Interface, config *viper.Viper)
• func DeployJobsLocal(logger logrus.FieldLogger, clientset kubernetes.Interface, config *viper.Viper, ...)
• func DeployJobsRemote(logger logrus.FieldLogger, clientset kubernetes.Interface, config *viper.Viper, ...)
• type ManagerController
  • func NewManagerController(logger logrus.FieldLogger, clientset kubernetes.Interface, config *viper.Viper) *ManagerController
  • func (c *ManagerController) Run(threadiness int, duration time.Duration)

Functions

func CheckAll

func CheckAll(logger logrus.FieldLogger, clientset kubernetes.Interface, config *viper.Viper) bool

CheckAll will check if exist any kubernetes resources that have been allocated to make the jobs

func CreateManagerPod

func CreateManagerPod(logger logrus.FieldLogger, clientset kubernetes.Interface, config *viper.Viper, specs []*models.Spec, duration time.Duration, shouldReportMetrics bool)

CreateManagerPod will deploy a kubernetes pod containing a pitaya-bot manager

func DeleteAll

func DeleteAll(logger logrus.FieldLogger, clientset kubernetes.Interface, config *viper.Viper)

DeleteAll will delete all kubernetes resources that have been allocated to make the jobs

func DeleteAllManager

func DeleteAllManager(logger logrus.FieldLogger, clientset kubernetes.Interface, config *viper.Viper)

DeleteAllManager will delete all pitaya-bot managers that have been allocated inside kubernetes cluster

func DeployJobsLocal

func DeployJobsLocal(logger logrus.FieldLogger, clientset kubernetes.Interface, config *viper.Viper, specs []*models.Spec, duration time.Duration, shouldReportMetrics bool)

DeployJobsLocal will deploy as many kubernetes jobs as number of spec files from local

func DeployJobsRemote

func DeployJobsRemote(logger logrus.FieldLogger, clientset kubernetes.Interface, config *viper.Viper, specs []*models.Spec, duration time.Duration, shouldReportMetrics bool)

DeployJobsRemote will deploy as many kubernetes jobs as number of spec files from remote

Types

type ManagerController

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

ManagerController represents the pitaya-bot manager kubernetes controller that will be watching all job processes and clean everything up at the end of the whole execution

func NewManagerController

func NewManagerController(logger logrus.FieldLogger, clientset kubernetes.Interface, config *viper.Viper) *ManagerController

NewManagerController is the ManagerController constructor

func (*ManagerController) Run

func (c *ManagerController) Run(threadiness int, duration time.Duration)

Run is the main loop which the pitaya-bot kubernetes controller will executing