scheduler

Documentation

Index

• Constants
• func SetPodNodeAffinityPreferred(node *corev1.Node, pod *corev1.Pod)
• func SetPodNodeAffinityRequired(node *corev1.Node, pod *corev1.Pod)
• type Scheduler
  • func (s *Scheduler) SchedulePod(pod *corev1.Pod, step *bitflowv1.BitflowStep, ...) (*corev1.Node, string)

Constants

const (
	HostnameLabel = "kubernetes.io/hostname"
)

Functions

func SetPodNodeAffinityPreferred

func SetPodNodeAffinityPreferred(node *corev1.Node, pod *corev1.Pod)

func SetPodNodeAffinityRequired

func SetPodNodeAffinityRequired(node *corev1.Node, pod *corev1.Pod)

Types

type Scheduler

type Scheduler struct {
	Client    client.Client
	Config    *config.Config
	Namespace string
	IdLabels  map[string]string
}

func (*Scheduler) SchedulePod

func (s *Scheduler) SchedulePod(pod *corev1.Pod, step *bitflowv1.BitflowStep, sources []*bitflowv1.BitflowSource) (*corev1.Node, string)