Cluster node initialisers

Initiate one of either worker or locator node.

worker_node(address = NULL, port = 0L, ..., verbose = FALSE)
locator_node(address = NULL, port = 0L, ..., verbose = FALSE)

Arguments

address

character address for the communication node to be reachable by. Leave NULL for localhost.

port

Integer port to bind to.

...

Arguments to pass on to methods

verbose

Logical, start verbose or not.

Value

None; loops.

Examples

##---- Should be DIRECTLY executable !! ----
##-- ==>  Define data, use random,
##--  or do  help(data=index)  for the standard data sets.

## The function is currently defined as
function (address = NULL, port = 0L, ..., verbose = FALSE) 
{
    options(chunknetVerbose = verbose)
    orcv::start(address, port, threads = 1L)
    init_function(...)
    repeat {
        event <- orcv::receive(keep_conn = TRUE)
        handle(event)
        log("...DONE")
    }
  }
#> function (address = NULL, port = 0L, ..., verbose = FALSE) 
#> {
#>     options(chunknetVerbose = verbose)
#>     orcv::start(address, port, threads = 1L)
#>     init_function(...)
#>     repeat {
#>         event <- orcv::receive(keep_conn = TRUE)
#>         handle(event)
#>         log("...DONE")
#>     }
#> }
#> <environment: 0x556233d248d8>