queuer

Documentation

Overview

Package queuer implements a Pod Queuer which stores and yields pods waiting being scheduled.

Index

• type Pod
  • func NewPod(pod *api.Pod, opt ...PodOpt) *Pod
  • func (p *Pod) Breaker() queue.BreakChan
  • func (p *Pod) Copy() queue.Copyable
  • func (dp *Pod) Deadline() (time.Time, bool)
  • func (dp *Pod) GetDelay() time.Duration
  • func (p *Pod) GetUID() string
  • func (p *Pod) String() string
• type PodOpt
  • func Deadline(deadline time.Time) PodOpt
  • func Delay(delay time.Duration) PodOpt
  • func Notify(notify queue.BreakChan) PodOpt
• type Queuer
  • func New(queue *queue.DelayFIFO, updates queue.FIFO) Queuer

Types

type Pod

type Pod struct {
	*api.Pod
	// contains filtered or unexported fields
}

wrapper for the k8s pod type so that we can define additional methods on a "pod"

func NewPod

func NewPod(pod *api.Pod, opt ...PodOpt) *Pod

func (*Pod) Breaker

func (p *Pod) Breaker() queue.BreakChan

func (*Pod) Copy

func (p *Pod) Copy() queue.Copyable

implements Copyable

func (*Pod) Deadline

func (dp *Pod) Deadline() (time.Time, bool)

implements Deadlined

func (*Pod) GetDelay

func (dp *Pod) GetDelay() time.Duration

func (*Pod) GetUID

func (p *Pod) GetUID() string

implements Unique

func (*Pod) String

func (p *Pod) String() string

type PodOpt

type PodOpt func(*Pod)

functional Pod option

func Deadline

func Deadline(deadline time.Time) PodOpt

Deadline sets the deadline for a Pod

func Delay

func Delay(delay time.Duration) PodOpt

Delay sets the delay for a Pod

func Notify

func Notify(notify queue.BreakChan) PodOpt

Notify sets the breakout notification channel for a Pod

type Queuer

type Queuer interface {
	InstallDebugHandlers(mux *http.ServeMux)
	UpdatesAvailable()
	Dequeue(id string)
	Requeue(pod *Pod)
	Reoffer(pod *Pod)

	Yield() *api.Pod

	Run(done <-chan struct{})
}

func New

func New(queue *queue.DelayFIFO, updates queue.FIFO) Queuer