olix0r

# Examples:
#
# # Deploy everything
# :; target/cli/conduit-latest-macos inject config/strest.yml \
#    | kubectl apply -f - --prune -l 'app=strest'
#
# # Add server instances
# :;  kubectl -n strest scale -l 'strest-role=server' --replicas=3
#
# # Stop a specific test

olix0r

:; cat ~/b/hello-world.yml 

---
apiVersion: v1
kind: Service
metadata:
  name: hello
spec:
  selector:
    app: hello

olix0r

#!/bin/sh

set -e

echo -n -e \\x00\\x00\\x00\\x08\\x4e\\x49\\x5f\\x50\\x49\\x4e\\x47\\x00 | nc $@

olix0r

    Finished dev [unoptimized + debuginfo] target(s) in 0.0 secs
     Running `target/debug/linkerd-tcp example.yml`
DEBUG:linkerd_tcp::balancer::dispatcher: start_send: dispatching waiter
TRACE:linkerd_tcp::balancer::dispatchq : start_send: dispatching sendq=1/1048575 recvq=0
TRACE:linkerd_tcp::balancer::dispatchq : dispatch: took waiter from sendq; polling recvq
TRACE:linkerd_tcp::balancer::dispatchq : dispatch: recvq not ready
TRACE:linkerd_tcp::balancer::dispatchq : start_send: dispatched sendq=1/1048575 recvq=0
DEBUG:linkerd_tcp::balancer::dispatcher: initiating 1 connections
DEBUG:linkerd_tcp::balancer::dispatcher: start_send: dispatched waiter ready=true
DEBUG:linkerd_tcp::balancer::dispatcher: start_send: dispatching waiter

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

olix0r

admin:
  port: 9989
  metricsIntervalSecs: 10

routers:

  - label: default

    interpreter:
      kind: io.l5d.namerd.http

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

#!/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

package main

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

func dieIf(err error) {

olix0r

version: '2'

services:

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