scheduler

Documentation

Index

• Constants
• type DummyScheduler
  • func (s *DummyScheduler) Run(play *corev1alpha1.Play, frameID string) error
• type KubernetesScheduler
  • func NewKubernetesScheduler(c client.Client) *KubernetesScheduler
  • func (ks *KubernetesScheduler) Run(play *corev1alpha1.Play, frameID string) error
• type Scheduler
• type ShellScheduler
  • func (s *ShellScheduler) Run(play *corev1alpha1.Play, frameID string) error

Constants

const (
	// JobLabelPlay is name of a label which stores name of the play that owns frame of this job
	JobLabelPlay = "kuberik.io/play"

	// JobAnnotationFrameID is name of a label which stores ID of the frame that owns the job
	JobAnnotationFrameID = "kuberik.io/frameID"
)

Types

type DummyScheduler

type DummyScheduler struct {
	// Result is a value that dummy scheduler sets as a result status of any frame played
	Result corev1alpha1.FrameResult
}

DummyScheduler implements Scheduler interface but doesn't run any workload

func (*DummyScheduler) Run

func (s *DummyScheduler) Run(play *corev1alpha1.Play, frameID string) error

Run implements Scheduler interface

type KubernetesScheduler

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

KubernetesScheduler defines a Scheduler which executes Plays on Kubernetes

func NewKubernetesScheduler

func NewKubernetesScheduler(c client.Client) *KubernetesScheduler

NewKubernetesScheduler creates a Kubernetes scheduler

func (*KubernetesScheduler) Run

func (ks *KubernetesScheduler) Run(play *corev1alpha1.Play, frameID string) error

Run implements Scheduler interface

type Scheduler

type Scheduler interface {
	Run(play *corev1alpha1.Play, frameID string) error
}

Scheduler implements a way for launching Actions

type ShellScheduler

type ShellScheduler struct{}

ShellScheduler runs workloads directly on the local system

func (*ShellScheduler) Run

func (s *ShellScheduler) Run(play *corev1alpha1.Play, frameID string) error

Run implements Scheduler interface