get details on given tasks, updating cache with the results

groupNodeSummary renders the summary for a group node. n.Topology is expected to be of the form: group:container:hostname

handleControl routes control requests from the client to the appropriate probe. Its is blocking.

handleDecodeError logs errors up to the maximum allowed count

this callback exists to close a hole whereby we don't get a kprobe for tcp_accept if accept was called before the probe started. It's fairly safe to a

handleProbeWS accepts websocket connections from the probe and registers them in the control router, such that HandleControl calls can find them.

When there is more than one connection originating from a source endpoint, we cannot be sure that its pid is associated with all of them, since the so

* Determine if all new nodes are 0-degree nodes * Requires cached nodes (implies a previous layout run). * @param {Map} nodes new Map of nodes

* Determine if edge has same endpoints in new nodes as well as in the nodeCache * @param {Map} edge Edge with source and target * @param {Ma

Determine if a TCP segment contains a full DNS message (i.e. not fragmented)

Tries to determine if this report came from a host running Weave Net

hexDecode32big decodes sequences of 32bit big endian bytes.

FIXME: Hideous hack to remove persistent-connection edges to virtual service IPs attributed to the internet. The global service-cluster-ip-range is no

Returns a list of service names. Cannot fail as it will attempt to deliver partial results, though that may end up being no results.

locate the position where key should go, and make room for it if not there already

loop periodically rescans for plugins

periodic loop to wake people up, so they can honour timeouts

Probe handler

Raw report handler

makeTopologyList returns a handler that yields an APITopologyList.

This implementation does not use the intermediate form as that was a performance issue; skipping it saved almost 10% CPU. Note this means we are usin

very similar to ps.Map.String() but with keys sorted

Inverse of mapRead, done for performance. Same comments about undocumented internal APIs apply.

* True if a prefix matches a field label * Slugifies the label (removes all non-alphanumerical chars).

Code adapted from github.com/weaveworks/weave/net/netdev.go Return any non-local IP addresses for processID if in a non-root namespace

starts a rate-limited background goroutine to read the expensive files from proc.