Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrEmptyQueue is returned from Pop. ErrEmptyQueue = errors.New("No pod queued") // ErrDifferentNames is returned from Update. ErrDifferentNames = errors.New("Original and new pods have different names") )
Functions ¶
This section is empty.
Types ¶
type ErrNoMatchingPod ¶
type ErrNoMatchingPod struct {
// contains filtered or unexported fields
}
ErrNoMatchingPod is returned from Update.
func (*ErrNoMatchingPod) Error ¶
func (e *ErrNoMatchingPod) Error() string
type FIFOQueue ¶
type FIFOQueue struct {
// contains filtered or unexported fields
}
FIFOQueue stores pods in a FIFO queue.
type PodQueue ¶
type PodQueue interface { // Push pushes the pod to the "end" of this PodQueue. Push(key string, pod *utils.AppGroup) error // Pop pops the pod on the "front" of this PodQueue. // This method never blocks; Immediately returns ErrEmptyQueue if the queue is empty. Pop() (*utils.AppGroup, string, error) // Front refers (not pops) the pod on the "front" of this PodQueue. // This method never bocks; Immediately returns ErrEmptyQueue if the queue is empty. Front() (*utils.AppGroup, string, error) // Get fifoQueue key Get() map[string]*utils.AppGroup }
PodQueue defines the interface of pod queues.
Click to show internal directories.
Click to hide internal directories.