chbatey

        echo "Checking if the commit is already tagged"
        if ! git describe --tag --exact-match 2>&1 | grep "fatal";
        then
          echo "Commit is already tagged"
          exit 0
        fi
        echo "Getting previous tag"
        CURRENT_TAG=$$(git describe --tag --abbrev=0)
        if [ "$${CURRENT_TAG}" = "" ]
        then

chbatey

import akka.actor.{ ActorSystem, PoisonPill }
import akka.util.Timeout
import com.datastax.driver.core.Cluster
import com.typesafe.config.ConfigFactory

import scala.concurrent.duration._
import scala.collection.JavaConverters._
import scala.io.StdIn

object Sandbox extends App {

chbatey

Keybase proof

I hereby claim:

• I am chbatey on github.
• I am chbatey (https://keybase.io/chbatey) on keybase.
• I have a public key ASC3wj_BGvnrpWZ5ueAiB23oZwUwS3j8ryBhBgZznakvGgo

To claim this, I am signing this object:

chbatey

package info.batey.akka.http

import akka.actor.Scheduler
import akka.actor.testkit.typed.scaladsl.TestProbe
import akka.actor.typed.ActorRef
import akka.actor.typed.scaladsl.AskPattern._
import akka.http.scaladsl.server.Directives._
import akka.http.scaladsl.testkit.ScalatestRouteTest
import akka.util.Timeout
import info.batey.akka.http.RouteUnderTest.Ping

chbatey

package info.batey.akka.persistence

import akka.actor.{ActorSystem, Props}
import akka.persistence.PersistentActor
import info.batey.akka.persistence.AutomaticPersist.RealPersistentActor.{PrintName, SayName}

object AutomaticPersist extends App {

  trait PersistMe

chbatey

package info.batey.akka.persistence

import akka.actor.{ActorSystem, Props}
import akka.persistence.PersistentActor
import info.batey.akka.persistence.AlwaysPersist.RealPersistentActor.PrintName

object AlwaysPersist extends App {

  trait AlwaysPersist extends PersistentActor {

chbatey

#!/usr/bin/bash -x                                                                                                                                                                                                                                                                                                                                                         
                                                                                                                                                                                                                                                                                                                                                                           
container=$1                                                                                                                                                                                                                                                                                            

chbatey

owercaseOutputLabelNames: true
lowercaseOutputName: true
rules:
- pattern: org.apache.cassandra.metrics<type=ClientRequest, scope=(\S*), name=(Latency)><>([0-9a-zA-Z]*)
  name: cassandra_clientrequest_$1_$2_$3
- pattern: org.apache.cassandra.metrics<type=ColumnFamily, name=(WriteLatency|ReadLatency)><>([0-9a-zA-Z]*)
  name: cassandra_columnfamily_$1_$2
- pattern: org.apache.cassandra.metrics<type=(Connection|Streaming), scope=(\S*), name=(\S*)><>(Count|Value)
  name: cassandra_$1_$3
  labels:

chbatey

AWSCLoud - access to EC2 and ELB
EC2 - Interface for EC2API from the Golang AWS SDK
ELB - Interface for the ELBAPI from the Golang AWS SDK

newAWSCloud
- Prod code: awsSDKProvider (actual implementation)
- Test code: FakeAWSServices (implemented in aws_test)

FakeAWSServices
- FakeEC2

chbatey

package info.batey.examples.observables;

import com.google.common.util.concurrent.ListenableFuture;
import com.google.common.util.concurrent.ListeningExecutorService;
import com.google.common.util.concurrent.MoreExecutors;
import info.batey.examples.cf.CompletableFutureTest;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import rx.Observable;