Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FilterPods ¶
filterPods returns pods based on their phase.
func GetPodResourcesByPhase ¶
GetPodResourcesByPhase returns pods based on their phase.
func PendingPodsFailedSchd ¶
func PendingPodsFailedSchd(pods []*v1.Pod) map[string][]v1.PodCondition
PendingPodsFailedSchd checks if pods pending have failed scheduling
Types ¶
type Interface ¶
type Interface interface {
UpdateQueueJobStatus(queuejob *qjobv1.AppWrapper) error
// TODO: Add to calculate more accurate partial deployments while job is being realized
// GetAggregatedResourcesByPhase(phase v1.PodPhase, queuejob *qjobv1.AppWrapper) *clusterstateapi.Resource
Run(stopCh <-chan struct{})
}
Interface is an abstract interface for queue job resource management.
type RegisteredResources ¶
type RegisteredResources struct {
// contains filtered or unexported fields
}
RegisteredResources : registered resources
func (*RegisteredResources) InitQueueJobResource ¶
func (rres *RegisteredResources) InitQueueJobResource(t qjobv1.ResourceType, config *rest.Config) (Interface, bool, error)
InitQueueJobResource creates an instance of the type queue job resource. It returns `false` if the type is not known.
func (*RegisteredResources) Register ¶
func (rres *RegisteredResources) Register(t qjobv1.ResourceType, factory Factory)
Register registers a Factory by type. This is expected to happen during app startup.
func (*RegisteredResources) Registered ¶
func (rres *RegisteredResources) Registered() []qjobv1.ResourceType
Registered enumerates the names of all registered plugins.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.