Handle shared Job routes.

The function will process the tasks locally.

The function will process the tasks globally within the cluster network.

Return a map of routes - AbstractArray

Generate abstract from hits array

io => []map[string]string

Local implementation of rpc method Distribute()

Flush hits from observed channels into hits array

[]map[string]string => []interface{}

map[string]string => struct

AdaptLimiter adapts the HTTP handler f to a limited handler that allows events up to rate lr and permits bursts of at most lb tokens.

count the number of tasks that the are queuing in channel

count the number of workers that are governed by the current master

current RPC port

Local implementation of rpc method Distribute()