Uses of Class
de.uni_kiel.rz.fdr.repl.REPLJob
Packages that use REPLJob
-
Uses of REPLJob in de.uni_kiel.rz.fdr.repl
Methods in de.uni_kiel.rz.fdr.repl that return REPLJobModifier and TypeMethodDescriptionstatic REPLJob
Get a loaded job by key.REPLJob.JobEvent.job()
Returns the value of thejob
record component.static REPLJob
Loads an archived job without preparing it for resuming.static REPLJob
Loads an archived job without preparing it for resuming.static REPLJob
REPLJob.repljob
(groovy.lang.Closure<Serializable> closure, List<Serializable> inputs) Creates a new job with inputs and no concurrency that is ready to be started.static REPLJob
REPLJob.repljob
(groovy.lang.Closure<Serializable> closure, List<Serializable> inputs, int concurrency) Creates a new job with inputs that is ready to be started.static REPLJob
REPLJob.repljob
(groovy.lang.Closure<Serializable> closure, List<Serializable> inputs, int concurrency, String name) Creates a new job with inputs that is ready to be started.static REPLJob
REPLJob.repljob
(groovy.lang.Closure<Serializable> closure, List<Serializable> inputs, int concurrency, String name, boolean becomeDelegate) Creates a new job with inputs that is ready to be started.static REPLJob
REPLJob.repljob
(groovy.lang.Closure<Serializable> closure, List<Serializable> inputs, String name) Creates a new job with inputs and no concurrency that is ready to be started.static REPLJob
REPLJob.repljob
(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs) Creates a new job with inputs or concurrency that is ready to be started.static REPLJob
REPLJob.repljob
(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs, int concurrency) Creates a new job with inputs that is ready to be started.static REPLJob
REPLJob.repljob
(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs, int concurrency, String name) Creates a new job with inputs that is ready to be started.static REPLJob
REPLJob.repljob
(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs, String name) Creates a new job with inputs and no concurrency that is ready to be started.static REPLJob
REPLJob.repljob
(Supplier<Serializable> supplier) Creates a new job without inputs or concurrency that is ready to be started.static REPLJob
REPLJob.repljob
(Supplier<Serializable> supplier, int concurrency) Creates a new job without inputs that is ready to be started.static REPLJob
REPLJob.repljob
(Supplier<Serializable> supplier, String name) Creates a new job without inputs or concurrency that is ready to be started.static REPLJob
REPLJob.resume
(File path, groovy.lang.Closure<Serializable> closure) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJob
REPLJob.resume
(File path, groovy.lang.Closure<Serializable> closure, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.static REPLJob
REPLJob.resume
(File path, groovy.lang.Closure<Serializable> closure, boolean retrySuccess, boolean retryErrors, boolean becomeDelegate) Loads an archived job instance and prepares it for resuming.static REPLJob
REPLJob.resume
(File path, BiFunction<Serializable, REPLJob, Serializable> function) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJob
REPLJob.resume
(File path, BiFunction<Serializable, REPLJob, Serializable> function, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.static REPLJob
REPLJob.resume
(File path, Supplier<Serializable> supplier) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJob
REPLJob.resume
(File path, Supplier<Serializable> supplier, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.static REPLJob
REPLJob.resume
(String key, groovy.lang.Closure<Serializable> closure) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJob
REPLJob.resume
(String key, groovy.lang.Closure<Serializable> closure, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.static REPLJob
REPLJob.resume
(String key, groovy.lang.Closure<Serializable> closure, boolean retrySuccess, boolean retryErrors, boolean becomeDelegate) Loads an archived job instance and prepares it for resuming.static REPLJob
REPLJob.resume
(String key, BiFunction<Serializable, REPLJob, Serializable> function) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJob
REPLJob.resume
(String key, BiFunction<Serializable, REPLJob, Serializable> function, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.static REPLJob
REPLJob.resume
(String key, Supplier<Serializable> supplier) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJob
REPLJob.resume
(String key, Supplier<Serializable> supplier, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.Methods in de.uni_kiel.rz.fdr.repl that return types with arguments of type REPLJobModifier and TypeMethodDescriptionREPLJob.list()
Get the list of all jobs that are not archived - that is: loaded in memory.REPLJob.streamArchived()
Stream all archived jobs without adding them to the list of active jobs.Methods in de.uni_kiel.rz.fdr.repl with parameters of type REPLJobModifier and TypeMethodDescriptionstatic boolean
Archives a loaded job.Method parameters in de.uni_kiel.rz.fdr.repl with type arguments of type REPLJobModifier and TypeMethodDescriptionstatic REPLJob
REPLJob.repljob
(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs) Creates a new job with inputs or concurrency that is ready to be started.static REPLJob
REPLJob.repljob
(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs, int concurrency) Creates a new job with inputs that is ready to be started.static REPLJob
REPLJob.repljob
(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs, int concurrency, String name) Creates a new job with inputs that is ready to be started.static REPLJob
REPLJob.repljob
(BiFunction<Serializable, REPLJob, Serializable> function, List<Serializable> inputs, String name) Creates a new job with inputs and no concurrency that is ready to be started.static REPLJob
REPLJob.resume
(File path, BiFunction<Serializable, REPLJob, Serializable> function) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJob
REPLJob.resume
(File path, BiFunction<Serializable, REPLJob, Serializable> function, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.static REPLJob
REPLJob.resume
(String key, BiFunction<Serializable, REPLJob, Serializable> function) Loads an archived job instance and prepares unfinished and unsuccessful inputs for resuming.static REPLJob
REPLJob.resume
(String key, BiFunction<Serializable, REPLJob, Serializable> function, boolean retrySuccess, boolean retryErrors) Loads an archived job instance and prepares it for resuming.Constructors in de.uni_kiel.rz.fdr.repl with parameters of type REPLJobModifierConstructorDescriptionJobEvent
(REPLJob job, Instant timestamp, REPLJob.JobEventType eventType, Integer inputIndex) Creates an instance of aJobEvent
record class.