olix0r

#!/bin/sh

set -e

# When the current branch has been merged to the origin, update master
# and delete the local branch.

branch=$(git rev-parse --abbrev-ref HEAD)

if [ -z "$branch" ]; then

olix0r

def call(): Future[String] = ???

val strings = Var.async[Try[String]](None) { strings =>
  def loop(): Future[Unit] =
    call().transform {
      case Return(s) =>
        strings() = Return(s)
        Future.sleep(1.minute).before(loop())
      case Throw(NonFatal(e)) =>
        strings() = Throw(e)

olix0r

import com.twitter.concurrent.AsyncStream
import com.twitter.conversions.time._
import com.twitter.finagle._
import com.twitter.finagle.util.DefaultTimer
import com.twitter.io.{Buf, Reader}
import com.twitter.util._

object StreamProxy {
  implicit val timer = DefaultTimer.twitter

olix0r

/*
 * check a condition asynchronously until it's true and then do another thing
 */

def checkCond: Future[Boolean] = ???
def doThing[T]: Future[T] = ???
implicit val timer = DefaultTimer.twitter

def untilCondition(backoff: Stream[Duration]): Future[Unit] =
  checkCond.flatMap {

olix0r

package main

import (
	"flag"
	"fmt"
	"math/rand"
	"net/http"
	"os"
)

olix0r

import com.twitter.conversions.time._
import com.twitter.finagle.util.DefaultTimer
import com.twitter.util._
import java.util.concurrent.atomic.AtomicInteger
import scala.util.control.NoStackTrace

object Cancellator {

  class Cancelled(n: Int) extends NoStackTrace

olix0r

  case class AuthRequest(
    loginEndpoint: String,
    uid: String,
    privateKey: String,
    algorithm: JwtAlgorithm = JwtAlgorithm.RS256
  ) {
    val path: String = new URL(loginEndpoint).getPath
    val jwt: String = {
      val token = Jwt.encode(s"""{"uid":"$uid"}""", privateKey, algorithm)

olix0r

version: '2'

services:

  l5d:
    image: buoyantio/linkerd:nightly
    container_name: l5d
    ports:
      - 4142:4142
      - 9990:9990

olix0r

package main

import (
	"flag"
	"fmt"
	"net/http"
	"os"
)

func dieIf(err error) {

olix0r

#!/bin/sh

set -e

# When the current branch has been merged to the origin, update master
# and delete the local branch.

branch=$(git rev-parse --abbrev-ref HEAD)

if [ -z "$branch" ]; then