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

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

extern crate rand;

use rand::Rng;
use std::cell::RefCell;
use std::collections::HashMap;
use std::rc::Rc;
use std::thread;
use std::time::Duration;

fn main() {

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

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

  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

admin:
  port: 9989
  metricsIntervalSecs: 10

routers:

  - label: default

    interpreter:
      kind: io.l5d.namerd.http

olix0r

use futures::{Future, Stream, Poll, Async, AsyncSink, Sink, StartSend};
use futures::unsync::{oneshot, mpsc};
use std::cell::RefCell;
use std::collections::VecDeque;
use std::rc::Rc;

/// Creates a dispatching channel.
///
/// This channel supports a single producer task and many consumers.
/// It is intended to be used by a producer task that pushes T-typed