job

Documentation

Index

• type ActiveClustersFunc
• type ActiveQueuesFunc
• type ClusterRuntimeInfo
  • func NewClusterRuntimeInfo(name string, r runtime.RuntimeService) *ClusterRuntimeInfo
• type ClusterRuntimes
  • func NewClusterRuntimes() ClusterRuntimes
  • func (cr *ClusterRuntimes) Delete(id api.ClusterID)
  • func (cr *ClusterRuntimes) Get(id api.ClusterID) (*ClusterRuntimeInfo, bool)
  • func (cr *ClusterRuntimes) Store(id api.ClusterID, runtimeInfo *ClusterRuntimeInfo)
• type JobManagerImpl
  • func NewJobManagerImpl() (*JobManagerImpl, error)
  • func (m *JobManagerImpl) GetQueue(queueID api.QueueID) (*clusterQueue, bool)
  • func (m *JobManagerImpl) Run(runtimeService runtime.RuntimeService, stopCh <-chan struct{}, ...)
  • func (m *JobManagerImpl) Start(activeClusters ActiveClustersFunc, activeQueueJobs QueueJobsFunc)
• type QueueJobsFunc

Types

type ActiveClustersFunc

type ActiveClustersFunc func() []models.ClusterInfo

type ActiveQueuesFunc

type ActiveQueuesFunc func() []models.Queue

type ClusterRuntimeInfo

type ClusterRuntimeInfo struct {
	Name       string
	StopCh     chan struct{}
	RuntimeSvc runtime.RuntimeService
}

ClusterRuntimeInfo defines cluster runtime

func NewClusterRuntimeInfo

func NewClusterRuntimeInfo(name string, r runtime.RuntimeService) *ClusterRuntimeInfo

type ClusterRuntimes

type ClusterRuntimes struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

ClusterRuntimes contains cluster runtimes

func NewClusterRuntimes

func NewClusterRuntimes() ClusterRuntimes

func (*ClusterRuntimes) Delete

func (cr *ClusterRuntimes) Delete(id api.ClusterID)

func (*ClusterRuntimes) Get

func (cr *ClusterRuntimes) Get(id api.ClusterID) (*ClusterRuntimeInfo, bool)

func (*ClusterRuntimes) Store

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)

type QueueJobsFunc

type QueueJobsFunc func(string, []schema.JobStatus) []models.Job