Documentation
¶
Index ¶
- func NewCreateJobHandler(rm *ResourcesManager) api.ProtoHandler
- func NewPollTaskStatusHandler(rm *ResourcesManager) api.ProtoHandler
- func NewQueryJobStatusAllHandler(rm *ResourcesManager) api.ProtoHandler
- func NewStartJobHandler(rm *ResourcesManager) api.ProtoHandler
- func NewStartTaskHandler(rm *ResourcesManager) api.ProtoHandler
- func NewStopJobHandler(rm *ResourcesManager) api.ProtoHandler
- func NewStopTaskHandler(rm *ResourcesManager) api.ProtoHandler
- type QueryJobStatusAllRequest
- type ResourcesManager
- func (m *ResourcesManager) DeleteJobTaskInfoBy(jobID string)
- func (m *ResourcesManager) DeleteTaskJobInfoBy(taskID string)
- func (m *ResourcesManager) InsertJob(jobID string)
- func (m *ResourcesManager) InsertTask(jobID string, taskID string) error
- func (m *ResourcesManager) IsJobExist(jobID string) bool
- func (m *ResourcesManager) IsTaskExist(taskID string) bool
- func (m *ResourcesManager) Run(ctx context.Context)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewCreateJobHandler ¶
func NewCreateJobHandler(rm *ResourcesManager) api.ProtoHandler
NewCreateJobHandler returns a createJobHandler instance.
func NewPollTaskStatusHandler ¶
func NewPollTaskStatusHandler(rm *ResourcesManager) api.ProtoHandler
NewPollTaskStatusHandler returns a pollTaskStatusHandler instance.
func NewQueryJobStatusAllHandler ¶
func NewQueryJobStatusAllHandler(rm *ResourcesManager) api.ProtoHandler
NewQueryJobStatusAllHandler returns a queryJobStatusAllHandler instance.
func NewStartJobHandler ¶
func NewStartJobHandler(rm *ResourcesManager) api.ProtoHandler
NewStartJobHandler returns a startJobHandler instance.
func NewStartTaskHandler ¶
func NewStartTaskHandler(rm *ResourcesManager) api.ProtoHandler
NewStartTaskHandler returns a startTaskHandler instance.
func NewStopJobHandler ¶
func NewStopJobHandler(rm *ResourcesManager) api.ProtoHandler
NewStopJobHandler returns a stopJobHandler instance.
func NewStopTaskHandler ¶
func NewStopTaskHandler(rm *ResourcesManager) api.ProtoHandler
NewStopTaskHandler returns a stopTaskHandler instance.
Types ¶
type QueryJobStatusAllRequest ¶
type QueryJobStatusAllRequest struct {
api.ProtoRequest
JobID string `form:"job_id"`
}
QueryJobStatusAllRequest defines the request body info for querying job status.
type ResourcesManager ¶
type ResourcesManager struct {
KusciaClient kusciaclientset.Interface
KjLister kuscialistersv1alpha1.KusciaJobLister
KtLister kuscialistersv1alpha1.KusciaTaskLister
AppImageLister kuscialistersv1alpha1.AppImageLister
// contains filtered or unexported fields
}
ResourcesManager manages kuscia resources.
func NewResourcesManager ¶
func NewResourcesManager(ctx context.Context, kusciaClient kusciaclientset.Interface) (*ResourcesManager, error)
NewResourcesManager returns a resources manager instance.
func (*ResourcesManager) DeleteJobTaskInfoBy ¶
func (m *ResourcesManager) DeleteJobTaskInfoBy(jobID string)
DeleteJobTaskInfoBy deletes job info by jobID.
func (*ResourcesManager) DeleteTaskJobInfoBy ¶
func (m *ResourcesManager) DeleteTaskJobInfoBy(taskID string)
DeleteTaskJobInfoBy deletes task info by taskID.
func (*ResourcesManager) InsertJob ¶
func (m *ResourcesManager) InsertJob(jobID string)
InsertJob inserts job info.
func (*ResourcesManager) InsertTask ¶
func (m *ResourcesManager) InsertTask(jobID string, taskID string) error
InsertTask inserts task info.
func (*ResourcesManager) IsJobExist ¶
func (m *ResourcesManager) IsJobExist(jobID string) bool
IsJobExist checks if job exist.
func (*ResourcesManager) IsTaskExist ¶
func (m *ResourcesManager) IsTaskExist(taskID string) bool
IsTaskExist checks if task exist.
func (*ResourcesManager) Run ¶
func (m *ResourcesManager) Run(ctx context.Context)
Run will start related workers.
Source Files