Versions in this module Expand all Collapse all v1 v1.0.0 Apr 28, 2022 Changes in this version + type Config struct + EventTraceLog string + JobPrepTimeout *Duration + JobTotalTimeout *Duration + LabelPrefix string + Namespace string + type Duration struct + func (d *Duration) UnmarshalYAML(unmarshal func(interface{}) error) error + type Executor struct + Client kubernetes.Interface + Config Config + KubeConfig *rest.Config + OnUpdate func(pod *corev1.Pod, status *pirov1.JobStatus) + func NewExecutor(config Config, kubeConfig *rest.Config) (*Executor, error) + func (js *Executor) GetKnownJobs() (jobs []pirov1.JobStatus, err error) + func (js *Executor) Logs(name string) io.Reader + func (js *Executor) RegisterResult(jobname string, res *pirov1.JobResult) error + func (js *Executor) Run() + func (js *Executor) Start(podspec corev1.PodSpec, metadata pirov1.JobMetadata, options ...StartOpt) (status *pirov1.JobStatus, err error) + func (js *Executor) Stop(name, reason string) error + type StartOpt func(*startOptions) + func WithAnnotation(key, value string) StartOpt + func WithAnnotations(annotations map[string]string) StartOpt + func WithBackoff(limit int) StartOpt + func WithCanReplay(canReplay bool) StartOpt + func WithMutex(name string) StartOpt + func WithName(name string) StartOpt + func WithSidecars(names []string) StartOpt + func WithWaitUntil(t time.Time) StartOpt