ueokande

#!/usr/bin/env ruby

utsname = []
topic = []

if ARGV.length < 1
  STDERR.puts("Missing arguments")
  exit 1
end

ueokande

# -*- mode: ruby -*-
# vi: set ft=ruby :

Vagrant.configure("2") do |config|

  (1..2).each do |n|
    config.vm.define "ap-#{n}" do |node|
      node.vm.provider "docker" do |docker|
        docker.build_dir = "vanilla"    
        docker.expose = [8000, 12201]   

ueokande

bootstrap.servers

A list of host/port pairs to use for establishing the initial connection to the Kafka cluster. The client will make use of all servers irrespective of which servers are specified here for bootstrapping—this list only impacts the initial hosts used to discover the full set of servers. This list should be in the form host1:port1,host2:port2,.... Since these servers are just used for the initial connection to discover the full cluster membership (which may change dynamically), this list need not contain the full set of servers (you may want more than one, though, in case a server is down).

key.deserializer

Deserializer class for key that implements the Deserializer interface.

value.deserializer

ueokande

#!/bin/sh

ID=$(uuidgen)
LEADER_KEY="localhost:2379/v2/keys/master"
TTL=5
INTERVAL=1

i_am_leader() {
  echo "I am leader";
  while true; do

ueokande

#!/bin/sh

# converts IPv4 as "A.B.C.D" to integer
# ip4_to_int 192.168.0.1
# => 3232235521
ip4_to_int() {
  IFS=. read -r i j k l <<EOF
$1
EOF
  echo $(( (i << 24) + (j << 16) + (k << 8) + l ))

ueokande

xwininfo

ffmpeg -video_size ${w}x${height} -framerate 12 -f x11grab -i :0.0+${x},${y} output/%04d.png

ueokande

package main

import (
	"context"
	"fmt"
	"os"
	"time"

	"github.com/coreos/etcd/clientv3"
)

ueokande

sudo modprobe v4l2loopback

ffmpeg -video_size 3840x2160 -framerate 30 -f x11grab -i :0.0 -f v4l2 /dev/video0 

ueokande

package main

import (
	"bufio"
	"encoding/json"
	"errors"
	"fmt"
	"os"
	"strings"
)

ueokande

struct Document<'a> {
    fields: Vec<Box<Field + 'a>>,
}

impl<'a> Document<'a> {
    fn new() -> Document<'a> {
        Document { fields: Vec::new() }
    }

    fn add_field<T>(&mut self, field: T)