CoordinatorServer

class CoordinatorServer(comm: InetSocketAddress, logs: InetSocketAddress) : Server

Serves task-execution requests over the coordinator's comm and logs sockets.

Constructors

constructor(comm: InetSocketAddress, logs: InetSocketAddress)

fun serve(bundle: Bundle)

Blocking entry point: connects to the coordinator and serves task-execution requests from the given bundle.

open suspend override fun serveAsync(bundle: Bundle)

Suspending entry point: connects to the coordinator and serves task-execution requests from the given bundle.