Documentation
¶
Index ¶
Constants ¶
View Source
const (
// EnvRuntimeVersion contains the version of PaddleFlow runtime
EnvRuntimeVersion = "PF_RUNTIME_VERSION"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ActiveClustersFunc ¶
type ActiveClustersFunc func() []model.ClusterInfo
type ActiveQueuesFunc ¶
type ClusterRuntimeInfo ¶ added in v0.14.3
type ClusterRuntimeInfo struct {
Name string
StopCh chan struct{}
RuntimeSvc runtime.RuntimeService
RuntimeV2Svc runtime_v2.RuntimeService
}
ClusterRuntimeInfo defines cluster runtime
func NewClusterRuntimeInfo ¶ added in v0.14.3
func NewClusterRuntimeInfo(name string, r runtime.RuntimeService) *ClusterRuntimeInfo
func NewClusterRuntimeV2Info ¶ added in v0.14.5
func NewClusterRuntimeV2Info(name string, r runtime_v2.RuntimeService) *ClusterRuntimeInfo
type ClusterRuntimes ¶ added in v0.14.3
ClusterRuntimes contains cluster runtimes
func NewClusterRuntimes ¶ added in v0.14.3
func NewClusterRuntimes() ClusterRuntimes
func (*ClusterRuntimes) Delete ¶ added in v0.14.3
func (cr *ClusterRuntimes) Delete(id api.ClusterID)
func (*ClusterRuntimes) Get ¶ added in v0.14.3
func (cr *ClusterRuntimes) Get(id api.ClusterID) (*ClusterRuntimeInfo, bool)
func (*ClusterRuntimes) Store ¶ added in v0.14.3
func (cr *ClusterRuntimes) Store(id api.ClusterID, runtimeInfo *ClusterRuntimeInfo)
type JobManagerImpl ¶
type JobManagerImpl struct {
// contains filtered or unexported fields
}
func NewJobManagerImpl ¶
func NewJobManagerImpl() (*JobManagerImpl, error)
func (*JobManagerImpl) GetQueue ¶
func (m *JobManagerImpl) GetQueue(queueID api.QueueID) (*clusterQueue, bool)
func (*JobManagerImpl) Run ¶
func (m *JobManagerImpl) Run(runtimeService runtime.RuntimeService, stopCh <-chan struct{}, clusterID api.ClusterID)
func (*JobManagerImpl) Start ¶
func (m *JobManagerImpl) Start(activeClusters ActiveClustersFunc, activeQueueJobs QueueJobsFunc)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.