sscarduzio

#!/bin/bash
echo  aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa

sscarduzio

package com.mpme.netty;

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.util.CharsetUtil;

public class PingResponder extends ChannelInboundHandlerAdapter {
	final static private ByteBuf PING = Unpooled.copiedBuffer("PING", CharsetUtil.UTF_8);

sscarduzio

import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder;
import io.netty.util.CharsetUtil;

import java.util.List;

import redgate.protocol.RedisCommand;

sscarduzio

@Test
  public final void testPubSubPongBug() throws Throwable{
    final Jedis c = pool.getResource();
    final String psubMessage = "bang";
    JedisPubSub jps = new JedisPubSub() {
      
      @Override
      public void onUnsubscribe(String channel, int subscribedChannels) {}      
      @Override
      public void onSubscribe(String channel, int subscribedChannels) {}

sscarduzio

#!/bin/bash

# CONF

DBG=true
RELOG_UNAME=your@email.com
RELOG_PASSW=xxxxxxxxxxxxxxx

# END CONF

sscarduzio

/**
 * Created by sscarduzio on 16/10/2014.
 */
object Scalaz extends App {
  import scalaz.stream._
  import scalaz.concurrent.Task

  def fahrenheitToCelsius(d:Double) : Double =  {
    3d // who cares about actually converting..

sscarduzio

  import org.joda.time.format.DateTimeFormat
  import org.joda.time._
  import scala.annotation.tailrec

  val timeWindow: Seconds = Seconds.seconds(Hours.hours(12).toStandardSeconds.getSeconds)
  type Delta = (DateTime, DateTime)
  
  def splitInterval(from: DateTime, to: DateTime, interval: Seconds): Seq[Delta] = {
    @tailrec
    def loop(_from: DateTime, intervalList: Seq[Delta]): Seq[Delta] = {

sscarduzio

#!/bin/bash

### NB: This script assumes you have set up your project in virtualenv!

# Configure here your python script with dependencies
ACTUAL_PYTHON_SCRIPT=rss.py

WORKDIR_SUFFIX="__LAMBDA_PACK_SCRIPT"
rm -rf $TMPDIR/*$WORKDIR_SUFFIX
WORKDIR=`mktemp -d --suffix $WORKDIR_SUFFIX`

sscarduzio

#!/bin/bash

#------------------------------------------------------------------------------
# Name:    sbtmkdirs
# Purpose: Create an SBT project directory structure with a few simple options.
# Author:  Alvin Alexander, http://alvinalexander.com
# Info:    http://alvinalexander.com/sbtmkdirs
# License: Creative Commons Attribution-ShareAlike 2.5 Generic
#          http://creativecommons.org/licenses/by-sa/2.5/
#------------------------------------------------------------------------------

sscarduzio

    <dependencies>
        <dependency>
            <groupId>org.elasticsearch</groupId>
            <artifactId>elasticsearch</artifactId>
            <version>${elasticsearch.version}</version>
            <scope>compile</scope>
        </dependency>
        <dependency>
            <groupId>net.java.dev.jna</groupId>
            <artifactId>jna</artifactId>