scheduler

Documentation

Index

• Constants
• func New(logger *zap.Logger, client kubernetes.Interface, cfg api.Config) *worker
• func NewInformerFactory(k8s kubernetes.Interface, tags []string) (informers.SharedInformerFactory, error)
• func NewJobWrapper(logger *zap.Logger, job *monitor.Job, config api.Config) *jobWrapper
• func NewPodCompletionWatcher(logger *zap.Logger, k8s kubernetes.Interface) *completionsWatcher
• type KubernetesPlugin
• type MaxInFlightLimiter
  • func NewLimiter(logger *zap.Logger, scheduler monitor.JobHandler, maxInFlight int) *MaxInFlightLimiter
  • func (l *MaxInFlightLimiter) Create(ctx context.Context, job *monitor.Job) error
  • func (l *MaxInFlightLimiter) InFlight() int
  • func (l *MaxInFlightLimiter) OnAdd(obj interface{})
  • func (l *MaxInFlightLimiter) OnDelete(obj interface{})
  • func (l *MaxInFlightLimiter) OnUpdate(_, obj interface{})
  • func (l *MaxInFlightLimiter) RegisterInformer(ctx context.Context, factory informers.SharedInformerFactory) error
• type Metadata

Constants

const (
	AgentContainerName = "agent"
)

Functions

func New

func New(logger *zap.Logger, client kubernetes.Interface, cfg api.Config) *worker

func NewInformerFactory

func NewInformerFactory(k8s kubernetes.Interface, tags []string) (informers.SharedInformerFactory, error)

returns an informer factory configured to watch resources (pods, jobs) created by the scheduler

func NewJobWrapper

func NewJobWrapper(logger *zap.Logger, job *monitor.Job, config api.Config) *jobWrapper

func NewPodCompletionWatcher

func NewPodCompletionWatcher(logger *zap.Logger, k8s kubernetes.Interface) *completionsWatcher

Types

type KubernetesPlugin

type KubernetesPlugin struct {
	PodSpec    *corev1.PodSpec
	GitEnvFrom []corev1.EnvFromSource
	Sidecars   []corev1.Container `json:"sidecars,omitempty"`
	Metadata   Metadata
}

type MaxInFlightLimiter

type MaxInFlightLimiter struct {
	MaxInFlight int
	// contains filtered or unexported fields
}

func NewLimiter

func NewLimiter(logger *zap.Logger, scheduler monitor.JobHandler, maxInFlight int) *MaxInFlightLimiter

func (*MaxInFlightLimiter) Create

func (l *MaxInFlightLimiter) Create(ctx context.Context, job *monitor.Job) error

func (*MaxInFlightLimiter) InFlight

func (l *MaxInFlightLimiter) InFlight() int

func (*MaxInFlightLimiter) OnAdd

func (l *MaxInFlightLimiter) OnAdd(obj interface{})

load jobs at controller startup/restart

func (*MaxInFlightLimiter) OnDelete

func (l *MaxInFlightLimiter) OnDelete(obj interface{})

if jobs are deleted before they complete, ensure we remove them from inFlight

func (*MaxInFlightLimiter) OnUpdate

func (l *MaxInFlightLimiter) OnUpdate(_, obj interface{})

if a job is still running, add it to inFlight, otherwise try to remove it

func (*MaxInFlightLimiter) RegisterInformer

func (l *MaxInFlightLimiter) RegisterInformer(ctx context.Context, factory informers.SharedInformerFactory) error

Creates a Jobs informer, registers the handler on it, and waits for cache sync

type Metadata

type Metadata struct {
	Annotations map[string]string
	Labels      map[string]string
}