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

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

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

#!/bin/sh

set -e

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

olix0r

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

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

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

---
apiVersion: v1
kind: Namespace
metadata:
  name: bot

---
apiVersion: v1
kind: Service
metadata:

olix0r

#!/bin/sh

set -eu

DEFAULT_URL="http://localhost:4191/metrics"
DEFAULT_CURL="curl"

curl="${CURL:-$DEFAULT_CURL}"
url="${1:-$DEFAULT_URL}"
while true ; do

olix0r

# Examples:
#
# # Deploy everything
# :; kubectl apply -f strest.yml --prune -l 'app=strest'
#
# # Add server instances
# :;  kubectl -n strest scale -l 'strest-server-profile=fast' --replicas=10

---
kind: Namespace