Documentation
¶
Index ¶
- Variables
- func BindPodToNode(podName string, namespace string, nodeName string)
- func DeletePod(podName string, namespace string)
- func GenerateUUID(seed string) string
- func GetClientConfig(kubeconfig string) (*rest.Config, error)
- func HashCombine(valueOne, valueTwo interface{}) uint64
- func New(schedulerName string, kubeConfig string, ...)
- type Node
- type NodePhase
- type NodeWatcher
- type Pod
- type PodIdentifier
- type PodPhase
- type PodWatcher
- type Queue
- type Type
Constants ¶
This section is empty.
Variables ¶
View Source
var NodeToRTND map[string]*firmament.ResourceTopologyNodeDescriptor
View Source
var NodesCond *sync.Cond
Used to guard access to the node and resource related maps.
View Source
var PodToTD map[PodIdentifier]*firmament.TaskDescriptor
View Source
var PodsCond *sync.Cond
Used to guard access to the pod, task and job related maps.
View Source
var ResIDToNode map[string]string
View Source
var TaskIDToPod map[uint64]PodIdentifier
Functions ¶
func BindPodToNode ¶
func GenerateUUID ¶
func HashCombine ¶
func HashCombine(valueOne, valueTwo interface{}) uint64
Types ¶
type NodeWatcher ¶
type NodeWatcher struct {
// contains filtered or unexported fields
}
func NewNodeWatcher ¶
func NewNodeWatcher(client kubernetes.Interface, fc firmament.FirmamentSchedulerClient) *NodeWatcher
func (*NodeWatcher) Run ¶
func (this *NodeWatcher) Run(stopCh <-chan struct{}, nWorkers int)
type PodIdentifier ¶
func (*PodIdentifier) UniqueName ¶
func (this *PodIdentifier) UniqueName() string
type PodPhase ¶
type PodPhase string
const ( PodPending PodPhase = "Pending" PodRunning PodPhase = "Running" PodSucceeded PodPhase = "Succeeded" PodFailed PodPhase = "Failed" PodUnknown PodPhase = "Unknown" // Internal phase used for removed pods. PodDeleted PodPhase = "Deleted" // Internal phase for pods that are externally updated. PodUpdated PodPhase = "Updated" )
type PodWatcher ¶
type PodWatcher struct {
// contains filtered or unexported fields
}
func NewPodWatcher ¶
func NewPodWatcher(kubeVerMajor, kubeVerMinor int, schedulerName string, client kubernetes.Interface, fc firmament.FirmamentSchedulerClient) *PodWatcher
func (*PodWatcher) Run ¶
func (this *PodWatcher) Run(stopCh <-chan struct{}, nWorkers int)
type Type ¶
type Type struct {
// contains filtered or unexported fields
}
func NewKeyedQueue ¶
func NewKeyedQueue() *Type
func (*Type) ShutDown ¶
func (q *Type) ShutDown()
After ShutDown is called new items will not be appended to the queue. Only already appended items will be drained.
func (*Type) ShuttingDown ¶
Click to show internal directories.
Click to hide internal directories.