Aivaras Voveris farico

Business Models

Advertising

Models	Examples
Display ads	Yahoo!
Search ads	Google

Akka Streams Backpressure Gauge

Measures if there is backpressure on an Akka Stream at the given stage.

Motivation

When an Akka Stream doesn't perform as intended, it is difficult to tell where the bottleneck is, since all stages operate at the same rate (see e.g. here ).

So when things are not fast as expected, this pressure gauge can help you to narrow down on the slow stage. Imagine

	#!/usr/bin/env sh

	##
	# This is script with usefull tips taken from:
	# https://github.com/mathiasbynens/dotfiles/blob/master/.osx
	#
	# install it:
	# curl -sL https://raw.github.com/gist/2108403/hack.sh \| sh
	#

	import collection.mutable.ListBuffer

	object NetworkUtils {
	def ip2Long(ip: String): Long = {
	val atoms: Array[Long] = ip.split("\\.").map(java.lang.Long.parseLong(_))
	val result: Long = (3 to 0 by -1).foldLeft(0L)(
	(result, position) => result \| (atoms(3 - position) << position * 8))

	result & 0xFFFFFFFF
	}