framework

type JobGetter interface {
	Job(fwVersion pfschema.KindGroupVersion) 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(kindVersion pfschema.KindGroupVersion) 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, kindVersion pfschema.KindGroupVersion) (interface{}, error)

	Create(resource interface{}, kindVersion pfschema.KindGroupVersion) error

	Delete(namespace string, name string, kindVersion pfschema.KindGroupVersion) error

	Patch(namespace string, name string, kindVersion pfschema.KindGroupVersion, data []byte) error

	Update(resource interface{}, kindVersion pfschema.KindGroupVersion) error

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

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