eslick

;;
;; Flume HBase User Sink
;;

(gen-class
 :name compass.flume.UserSink
 :extends "com.cloudera.flume.core.EventSink$Base"
 :prefix "sink-"
 :main false
 :constructors {[String] []

eslick

;; This is a relatively simple election mechanism for a set of 
;; processes or datomic peers where a processing step requires a 
;; global master.  The elector entity is used to connect a set of peer
;; entities labeled as :election/master.  Using the algorithm,
;; there will only ever be one :election/master in the :election/peer
;; group defined on the elector.
;;
;; The user API is simple a guarded transaction which calls a txn-fn
;; if the entity is the current master.  If not it holds an election 
;; if the timeout has expired.

eslick

(ns experiment.infra.election
  (:use [datomic.api :only [q] :as d])
  (:require [experiment.system :as sys]
            [experiment.infra.data :as data]
            [experiment.infra.protocols :as p]))

;;
;; Reserve - Simple peer coordination mechanism
;;
;; Reservations support multiple peers trying to distribution operations

eslick

{:user {:plugins [[lein-ritz "0.7.0"]]
        :dependencies [[nrepl-inspect "0.3.0"]
                       [ritz/ritz-nrepl-middleware "0.7.0"]]
        :repl-options
        {:nrepl-middleware
         [inspector.middleware/wrap-inspect
          ritz.nrepl.middleware.javadoc/wrap-javadoc
          ritz.nrepl.middleware.apropos/wrap-apropos]}}}

eslick

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

Vagrant::Config.run do |config|
  config.vm.box = "Ubuntu64vb"
  config.vm.boot_mode = :gui
  config.vm.network :bridged
end
  

eslick

cd ansible # run in the ansible directory

export AWS_ACCESS_KEY_ID='<aws_accesskey_id>'
export AWS_SECRET_ACCESS_KEY='<aws_secret_key>'
export ANSIBLE_HOSTS=$(pwd)/plugins/inventory/ec2.py

# use the following only if you're using ssh as transport (typical)
export  ANSIBLE_SSH_ARGS="-o ForwardAgent=yes"

# Run ssh-agent and add your AWS pem key

eslick

[INFO]                                                                         
[INFO] ------------------------------------------------------------------------
[INFO] Building Immutant App Bootstrap Module 1.1.0-SNAPSHOT
[INFO] ------------------------------------------------------------------------
[INFO] 
[INFO] --- maven-enforcer-plugin:1.2:enforce (enforce-java-version) @ immutant-bootstrap-module ---
[INFO] 
[INFO] --- maven-enforcer-plugin:1.2:enforce (enforce-maven-version) @ immutant-bootstrap-module ---
[INFO] 
[INFO] --- buildnumber-maven-plugin:1.2:create-timestamp (get-build-timestamp) @ immutant-bootstrap-module ---

eslick

15:44:58,546 INFO  [org.jboss.as.server] (DeploymentScanner-threads - 2) JBAS018559: Deployed "dummy.clj" (runtime-name : "dummy.clj")
15:48:29,055 INFO  [org.jboss.as.repository] (HttpManagementService-threads - 3) JBAS014900: Content added at location /Users/eslick/.immutant/current/jboss/standalone/data/content/46/a044e91a04105e22e3cbb90a36cea84c7bcdac/content
15:48:29,062 INFO  [org.jboss.as.server.deployment] (MSC service thread 1-9) JBAS015876: Starting deployment of "switchboard.clj" (runtime-name: "switchboard.clj")
15:48:35,024 WARN  [org.jboss.as.server.deployment] (MSC service thread 1-9) JBAS015960: Class Path entry apache-cassandra-clientutil-1.2.6.jar in /Users/eslick/Work/vital/projects/switchboard/switchboard/tmp_mounts/switchboard.clj/cassandra-all-1.2.6.jar  does not point to a valid jar for a Class-Path reference.
15:48:35,047 WARN  [org.jboss.as.server.deployment] (MSC service thread 1-9) JBAS015960: Class Path entry apache-cassandra-thrift-1.2.6.jar in /Users/eslick/Work/vital/projects/sw

eslick

        <subsystem xmlns="urn:jboss:domain:logging:1.2">
            <console-handler name="CONSOLE">
                <level name="DEBUG"/>
                <formatter>
                    <pattern-formatter pattern="%K{level}%d{HH:mm:ss,SSS} %-5p [%c] (%t) %s%E%n"/>
                </formatter>
            </console-handler>
            <periodic-rotating-file-handler name="FILE" autoflush="true">
                <level name="TRACE"/>
                <formatter>

eslick

Bacon:switchboard eslick$ lein deps :tree
WARNING!!! possible confusing dependencies found:
[io.pedestal/pedestal.service "0.2.1"] -> [org.slf4j/slf4j-api "1.7.2"]
 overrides
[com.datomic/datomic-pro "0.8.4143"] -> [org.slf4j/jul-to-slf4j "1.7.5"] -> [org.slf4j/slf4j-api "1.7.5"]
 and
[com.datomic/datomic-pro "0.8.4143"] -> [org.slf4j/log4j-over-slf4j "1.7.5"] -> [org.slf4j/slf4j-api "1.7.5"]
 and
[com.datomic/datomic-pro "0.8.4143"] -> [org.slf4j/jcl-over-slf4j "1.7.5"] -> [org.slf4j/slf4j-api "1.7.5"]