plugins

Documentation

Index

• func RegisterRuntimePlugin(runtime string, runtimeInterface RuntimeInterface)
• type RuntimeInterface
  • func GetRuntimePlugin(runtime string) (RuntimeInterface, error)

Functions

func RegisterRuntimePlugin

func RegisterRuntimePlugin(runtime string, runtimeInterface RuntimeInterface)

Types

type RuntimeInterface

type RuntimeInterface interface {
	// Parse package and conf into cluster which clusterManager will register into db.
	ParseClusterConf(versionId, conf string) (*models.ClusterWrapper, error)
	SplitJobIntoTasks(job *models.Job) (*models.TaskLayer, error)
	HandleSubtask(task *models.Task) error
	WaitSubtask(taskId string, timeout time.Duration, waitInterval time.Duration) error
}

func GetRuntimePlugin

func GetRuntimePlugin(runtime string) (RuntimeInterface, error)