package
Version:
v1.3.1
Opens a new window with list of versions in this module.
Published: Jul 17, 2016
License: Apache-2.0
Opens a new window with license information.
Imports: 11
Opens a new window with list of imports.
Imported by: 0
Opens a new window with list of known importers.
Documentation
¶
Package queuer implements a Pod Queuer which stores and yields pods waiting
being scheduled.
type Pod struct {
*api.Pod
}
wrapper for the k8s pod type so that we can define additional methods on a "pod"
func NewPod(pod *api.Pod, opt ...PodOpt) *Pod
func (p *Pod) Breaker() queue.BreakChan
func (p *Pod) Copy() queue.Copyable
implements Copyable
func (dp *Pod) Deadline() (time.Time, bool)
implements Deadlined
func (dp *Pod) GetDelay() time.Duration
func (p *Pod) GetUID() string
implements Unique
func (p *Pod) String() string
functional Pod option
func Deadline(deadline time.Time) PodOpt
Deadline sets the deadline for a Pod
func Delay(delay time.Duration) PodOpt
Delay sets the delay for a Pod
func Notify(notify queue.BreakChan) PodOpt
Notify sets the breakout notification channel for a Pod
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(queue *queue.DelayFIFO, updates queue.FIFO) Queuer
Source Files
¶
Click to show internal directories.
Click to hide internal directories.
