cddr

Dev Journal for getting nano-demo working (on OSX)

## Nanomsg hello world

 * create lein project with [jnanomsg "0.4.3"]
 * add `(require [nanomsg.core :as nn])`
 * Ooops 
 ```1. Unhandled java.lang.UnsatisfiedLinkError
   Unable to load library 'nanomsg': Native library
   (darwin/libnanomsg.dylib) not found in resource path

cddr

Dev Journal for getting nano-demo working (on OSX)

## Nanomsg hello world

 * create lein project with [jnanomsg "0.4.3"]
 * add `(require [nanomsg.core :as nn])`
 * Ooops 
 ```1. Unhandled java.lang.UnsatisfiedLinkError
   Unable to load library 'nanomsg': Native library
   (darwin/libnanomsg.dylib) not found in resource path

cddr

zookeeper:
  image: confluent/zookeeper
  ports:
    - "0.0.0.0:2181:2181"

kafka:
  environment:
    - KAFKA_ADVERTISED_HOST_NAME=192.168.99.100
  image: confluent/kafka
  links:

cddr

(defn run-test-job
  "Runs the email job for `timeout` milliseconds before returning whatever
   has been accumulated in `sent-emails`.

   TODO: Consider promoting more generic version of this to samza-config"
  [timeout]
  (let [job (MapConfig. (assoc (into {} (find-job 'notifications-handler.core.email))
                               "job.task.send-fn" (full-name 'mock-send-fn)))]

    (let [job-proc (.run (JobRunner. job) true)]

cddr

Keybase proof

I hereby claim:

• I am cddr on github.
• I am cddr (https://keybase.io/cddr) on keybase.
• I have a public key ASD2dsyvhcBJmvz3D64pTyiLJqdcsCxDqKy-rPKgy4ATugo

To claim this, I am signing this object:

cddr

#!/bin/bash
#
# Here's the scenario
#
# You can ssh into some shared environment containing kafka but you need to
# go through a bastion server to get there. How can you easily stream kafka
# data into your local system (e.g. to get test data, gather data from shared
# environments to reproduce a bug etc)
#
# This script can be executed on the bastion. It picks a random mesosslave to

cddr

(s/def ::foo-1.0 (s/keys :req [::my-string ::my-int]))
(s/def ::foo-1.1 (s/keys :req [::my-string]))

(defspec compatability-test
  (prop/for-all [v1-1 (s/gen ::foo-1.1)]
    (s/valid? ::foo-1.0 v1-1)))

cddr

(ns hitchhiker.sqlite
  (:require [clojure.java.jdbc :as jdbc]
            [clojure.edn :as edn]
            [clojure.string :as str]
            [hitchhiker.tree.core :as core]
            [hitchhiker.tree.messaging :as msg]
            [clojure.core.cache :as cache]
            [taoensso.nippy :as nippy])
  (:import [java.sql SQLException]))

cddr

(ns kafka-streams.embedded
  "Lifecycle component for an embedded Kafka cluster

   The components defined here use the component lifecycle to model
   the dependencies between the various services (zookeeper, kafka broker
   and kafka client).

   The test-harness function returns a system containing all the relevent
   components, and starting that system starts the components in the
   correct order (i.e. zookeeper, kafka, test-client).

cddr

 (define-ibuffer-filter buffer-modified-p
   "Toggle current view to buffers that have been modified"
   (:description "unsaved file buffers")
   (and (buffer-local-value 'buffer-file-name buf)
        (buffer-modified-p buf)))

 (defun brain-flush ()
   (interactive)
   (ibuffer t "*Brain Flush*"
            '((buffer-modified-p . true))))