kubernetes

Documentation

Index

• type KubernetesWorkerInterface
  • func NewKubernetesWorkerInterface(db db.VizierDBInterface) (*KubernetesWorkerInterface, error)
  • func (d *KubernetesWorkerInterface) CleanWorkers(studyId string) error
  • func (d *KubernetesWorkerInterface) IsWorkerComplete(wID string) (bool, error)
  • func (d *KubernetesWorkerInterface) SpawnWorker(wid string, workerConf *api.WorkerConfig) error
  • func (d *KubernetesWorkerInterface) StopWorkers(studyId string, wIDs []string, iscomplete bool) error
  • func (d *KubernetesWorkerInterface) StoreWorkerLog(wID string) error
  • func (d *KubernetesWorkerInterface) UpdateWorkerStatus(studyId string) error

Types

type KubernetesWorkerInterface

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

func NewKubernetesWorkerInterface

func NewKubernetesWorkerInterface(db db.VizierDBInterface) (*KubernetesWorkerInterface, error)

func (*KubernetesWorkerInterface) CleanWorkers

func (d *KubernetesWorkerInterface) CleanWorkers(studyId string) error

func (*KubernetesWorkerInterface) IsWorkerComplete

func (d *KubernetesWorkerInterface) IsWorkerComplete(wID string) (bool, error)

func (*KubernetesWorkerInterface) SpawnWorker

func (d *KubernetesWorkerInterface) SpawnWorker(wid string, workerConf *api.WorkerConfig) error

func (*KubernetesWorkerInterface) StopWorkers

func (d *KubernetesWorkerInterface) StopWorkers(studyId string, wIDs []string, iscomplete bool) error

func (*KubernetesWorkerInterface) StoreWorkerLog

func (d *KubernetesWorkerInterface) StoreWorkerLog(wID string) error

func (*KubernetesWorkerInterface) UpdateWorkerStatus

func (d *KubernetesWorkerInterface) UpdateWorkerStatus(studyId string) error