crew_class_launcher_cluster | R Documentation |
R6
class to help develop specific cluster launcher plugins.
See crew_launcher_cluster()
.
The template files at
https://github.com/mschubert/clustermq/tree/master/inst
informed the development of the crew
launcher plugins in
crew.cluster
, and we would like to thank
Michael Schubert for developing clustermq
and releasing it under
the permissive Apache License 2.0.
See the NOTICE
and README.md
files in the crew.cluster
source code for additional attribution.
crew::crew_class_launcher
-> crew_class_launcher_cluster
options_cluster
See crew_launcher_cluster()
.
crew::crew_class_launcher$call()
crew::crew_class_launcher$crashes()
crew::crew_class_launcher$launch()
crew::crew_class_launcher$poll()
crew::crew_class_launcher$resolve()
crew::crew_class_launcher$scale()
crew::crew_class_launcher$set_name()
crew::crew_class_launcher$settings()
crew::crew_class_launcher$start()
crew::crew_class_launcher$terminate()
crew::crew_class_launcher$terminate_workers()
crew::crew_class_launcher$update()
new()
Abstract launcher constructor.
crew_class_launcher_cluster$new( name = NULL, workers = NULL, seconds_interval = NULL, seconds_timeout = NULL, seconds_launch = NULL, seconds_idle = NULL, seconds_wall = NULL, tasks_max = NULL, tasks_timers = NULL, reset_globals = NULL, reset_packages = NULL, reset_options = NULL, garbage_collection = NULL, tls = NULL, r_arguments = NULL, options_metrics = NULL, options_cluster = NULL )
name
See crew_launcher_cluster()
.
workers
See crew_launcher_cluster()
.
seconds_interval
See crew_launcher_cluster()
.
seconds_timeout
See crew_launcher_cluster()
.
seconds_launch
See crew_launcher_cluster()
.
seconds_idle
See crew_launcher_cluster()
.
seconds_wall
See crew_launcher_cluster()
.
tasks_max
See crew_launcher_cluster()
.
tasks_timers
See crew_launcher_cluster()
.
reset_globals
See crew_launcher_cluster()
.
reset_packages
See crew_launcher_cluster()
.
reset_options
See crew_launcher_cluster()
.
garbage_collection
See crew_launcher_cluster()
.
tls
See crew_launcher_cluster()
.
r_arguments
See crew_launcher_cluster()
.
options_metrics
See crew_launcher_cluster()
.
options_cluster
See crew_launcher_cluster()
.
An abstract launcher object.
validate()
Validate the launcher.
crew_class_launcher_cluster$validate()
NULL
(invisibly). Throws an error if a field is invalid.
launch_worker()
Launch a local process worker which will dial into a socket.
crew_class_launcher_cluster$launch_worker( call, name, launcher, worker, instance = NULL )
call
Character string, a namespaced call to
crew::crew_worker()
which will run in the worker and accept tasks.
name
Character string, an informative worker name.
launcher
Character string, name of the launcher.
worker
Character string, name of the worker instance.
instance
Deprecated in crew.cluster
The call
argument is R code that will run to
initiate the worker.
A handle object to allow the termination of the worker later on.
terminate_worker()
Terminate a local process worker.
crew_class_launcher_cluster$terminate_worker(handle)
handle
A process handle object previously
returned by launch_worker()
.
NULL
(invisibly).
Other cluster:
crew_class_monitor_cluster
,
crew_launcher_cluster()
,
crew_monitor_cluster()
,
crew_options_cluster()
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.