joshrotenberg

input {
 	file {
		path => "/tmp/doof/*"
		codec => "gzip_lines"
		start_position => "beginning"

	}
}
output { 
	kafka {

joshrotenberg

use Mix.Config

config KafkaEx,
 brokers: [{"localhost", 9092}]

joshrotenberg

package consumer

import (
	"errors"
	"testing"

	"github.com/bitly/go-nsq"
)

// tests nsq.HandlerFunc. just write the function in line in the test

joshrotenberg

package groupcache_expire

import (
	"log"
	"strings"
	"time"

	"github.com/golang/groupcache"
)

joshrotenberg

(require '[clojure.walk :refer [postwalk]]
          [clojure.string :as s])
          
(defn keyword-to-property
  "Replace :foo-bar with \"foo.bar\", etc."
  [k]
  (s/replace (name k) #"\-" "."))

(defn propertyize-map
  "Recursively transforms all map keys from keywords to Java property strings and values to strings (if necessary)."

joshrotenberg

package main

// This is a basic example of running an nsqd instance embedded. It creates
// and runs an nsqd with all of the default options, and then produces
// and consumes a single message. You are probably better off running a
// standalone instance, but embedding it can simplify deployment and is
// useful in testing.

// See https://github.com/nsqio/nsq/blob/master/nsqd/options.go and
// https://github.com/nsqio/nsq/blob/master/apps/nsqd/nsqd.go for

joshrotenberg

(ns immutant.init
  (:require [immutant.messaging :as msg]
            [immutant.pipeline :as pl]
            [clojure.tools.logging :as log]))


(defn add-two [m]
  (log/info "add-two processing" m)
  (+ 2 m))

joshrotenberg

This is my recommended path for learning Haskell.

Something to keep in mind: don't sweat the stuff you don't understand immediately. Just keep moving.

Primary course

Installing Haskell

Ubuntu PPA

joshrotenberg

{-# OPTIONS -Wall #-}

module Main where

import Control.Concurrent (threadDelay)
import System.Environment (getArgs)
import System.INotify

main :: IO ()
main = do

joshrotenberg

// Package readyset provides a simple set implementation.
package readyset

import "fmt"

// Set is a container for arbitrary data which ensures that duplicates elements will not be stored multiple times.
type Set map[interface{}]struct{}

// NewSet creates a new Set containing the given elements.
func NewSet(in ...interface{}) Set {