plugins

Documentation

Index

• Variables
• func GetRegisteredJobPluginNames() []string
• func RegisterPlugin(pluginName string, plugin JobPlugin)
• type JobHandler
• type JobPlugin
• type KubernetesResource

Variables

var SupportedJobPlugins = map[string]JobPlugin{}

Functions

func GetRegisteredJobPluginNames

func GetRegisteredJobPluginNames() []string

func RegisterPlugin

func RegisterPlugin(pluginName string, plugin JobPlugin)

Types

type JobHandler

type JobHandler interface {
	Reload()
	Serialize(namespace, name string, job common.Job) (map[KubernetesResource][]byte, string, error)
}

type JobPlugin

type JobPlugin interface {
	CreateJobHandler(dataFolder string, logger *zap.Logger) (JobHandler, error)
}

type KubernetesResource

type KubernetesResource string

const (
	ResDeployment  KubernetesResource = "deployment"
	ResJob         KubernetesResource = "job"
	ResConfigmap   KubernetesResource = "configmap"
	ResUnSupported KubernetesResource = "unsupported"
)