handler

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 NewResourcesManager(ctx context.Context, kusciaClient kusciaclientset.Interface) (*ResourcesManager, error)
  • 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)

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.