Dave Rusek mgodave

🤟

move along, nothing to see here...

mgodave / gist:5155644

Created March 13, 2013 20:04

	; -- mode: clojure; --
	; vim: filetype=clojure

	(logging/init :file "/var/log/riemann/riemann.log")

	; Listen on the local interface over TCP (5555), UDP (5555), and websockets
	; (5556)
	(let [host "127.0.0.1"]
	(tcp-server :host host)
	(udp-server :host host)

mgodave / javadoc.py

Last active December 16, 2015 08:39

Serve javadocs from maven cache

	from BaseHTTPServer import BaseHTTPRequestHandler, HTTPServer
	from zipfile import ZipFile
	from string import join
	import os
	import re

	def getMavenCoordinates(elements):
	return dict(zip(('group', 'artifact', 'version'), elements))

	def getMavenArtifactName(coordinates):

mgodave / TimeLimitedFutureTask.java

Created April 28, 2013 17:05

	package org.robotninjas.util;

	import com.google.common.util.concurrent.AbstractFuture;
	import com.google.common.util.concurrent.TimeLimiter;

	import java.util.concurrent.Callable;
	import java.util.concurrent.RunnableFuture;
	import java.util.concurrent.TimeUnit;

	public class TimeLimitedFutureTask<V> extends AbstractFuture<V> implements RunnableFuture<V> {

mgodave / AsyncCommand.java

Created April 29, 2013 21:41

AsyncCommand

	package org.robotninjas.util;

	import com.google.common.base.Optional;
	import com.google.common.util.concurrent.*;

	import java.util.concurrent.Callable;
	import java.util.concurrent.Executor;
	import java.util.concurrent.TimeUnit;

	public class AsyncCommand<V> {

mgodave / FunctionCompositionBuilder.java

Last active December 16, 2015 21:29

Function Composition with Guava

	package org.robotninjas.util;

	import com.google.common.base.Function;
	import com.google.common.util.concurrent.*;

	import java.util.concurrent.CountDownLatch;
	import java.util.concurrent.Executor;
	import java.util.concurrent.ExecutorService;
	import java.util.concurrent.Executors;

mgodave / gist:5535286

Last active December 17, 2015 02:19

	ListenableFuture<RowKey> rowKeyFuture = indexService.lookUp(query);
	AsyncFunction<RowKey, QueryResult> queryFunction =
	new AsyncFunction<RowKey, QueryResult>() {
	public ListenableFuture<QueryResult> apply(RowKey rowKey) {
	return dataService.read(rowKey);
	}
	};
	ListenableFuture<QueryResult> queryFuture = transform(rowKeyFuture, queryFunction);

mgodave / gist:5535727

Last active December 17, 2015 02:29

	public class FunctionComposerExample {

	private final Executor mainPool;
	private final Executor ioPool;

	public FunctionComposerExample(Executor mainPool, Executor ioPool) {
	this.mainPool = mainPool;
	this.ioPool = ioPool;
	}

mgodave / gist:5538189

Last active December 17, 2015 02:48

	public class ChainingExample {

	private final Executor mainPool;
	private final Executor ioPool;

	public ChainingExample(Executor mainPool, Executor ioPool) {
	this.mainPool = mainPool;
	this.ioPool = ioPool;
	}

mgodave / CounterMutationBuilder.java

Created October 16, 2013 19:55

	/*
	* Copyright 2013 Basho Technologies Inc
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software

mgodave / CounterMutationBuilder.java

Created October 16, 2013 20:08

CRDT user API PoC

	/*
	* Copyright 2013 Basho Technologies Inc
	*
	* Licensed under the Apache License, Version 2.0 (the "License");
	* you may not use this file except in compliance with the License.
	* You may obtain a copy of the License at
	*
	* http://www.apache.org/licenses/LICENSE-2.0
	*
	* Unless required by applicable law or agreed to in writing, software