framework

type JobGetter interface {
	Job(fwVersion pfschema.FrameworkVersion) JobInterface
}

type JobInterface interface {
	// Submit PaddleFlow Server operate on cluster
	Submit(ctx context.Context, job *api.PFJob) error

	Stop(ctx context.Context, job *api.PFJob) error

	Update(ctx context.Context, job *api.PFJob) error

	Delete(ctx context.Context, job *api.PFJob) error

	GetLog(ctx context.Context, jobLogRequest pfschema.JobLogRequest) (pfschema.JobLogInfo, error)

	// AddEventListener add jobListener, taskLister to notify PaddleFlow Server when job is updated
	AddEventListener(ctx context.Context, listenerType string, eventQueue workqueue.RateLimitingInterface, informer interface{}) error
}

type JobPlugin = func(RuntimeClientInterface) JobInterface

type JobSample struct {
}

type QueueGetter interface {
	Queue(quotaType pfschema.FrameworkVersion) QueueInterface
}

type QueueInterface interface {
	// PaddleFlow Server operate on Cluster
	Create(ctx context.Context, q *api.QueueInfo) error

	Delete(ctx context.Context, q *api.QueueInfo) error

	Update(ctx context.Context, q *api.QueueInfo) error

	// AddEventListener add queueListener to notify PaddleFlow Server when queue is updated
	AddEventListener(ctx context.Context, listenerType string, eventQueue workqueue.RateLimitingInterface, informer interface{}) error
}

type QueuePlugin = func(RuntimeClientInterface) QueueInterface

type QueueSample struct {
}

type RuntimeClientInterface interface {
	Cluster() string

	ClusterID() string

	ClusterName() string

	Get(namespace string, name string, fv pfschema.FrameworkVersion) (interface{}, error)

	Create(resource interface{}, fv pfschema.FrameworkVersion) error

	Delete(namespace string, name string, fv pfschema.FrameworkVersion) error

	Patch(namespace, name string, fv pfschema.FrameworkVersion, data []byte) error

	Update(resource interface{}, fv pfschema.FrameworkVersion) error

	// RegisterListener register job/task/queue listener
	RegisterListener(listenerType string, workQueue workqueue.RateLimitingInterface) error

	StartListener(listenerType string, stopCh <-chan struct{}) error

	// ListNodeQuota resource api for cluster nodes
	ListNodeQuota(ctx context.Context) (pfschema.QuotaSummary, []pfschema.NodeQuotaInfo, error)

	GetJobTypeFramework(fv pfschema.FrameworkVersion) (pfschema.JobType, pfschema.Framework)

	JobFrameworkVersion(jobType pfschema.JobType, fw pfschema.Framework) pfschema.FrameworkVersion
}