Skip to content

Instantly share code, notes, and snippets.

View chbatey's full-sized avatar
🐯
WFH

Christopher Batey chbatey

🐯
WFH
View GitHub Profile
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
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 {

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:

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
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
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 {
#!/usr/bin/bash -x
container=$1
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:
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
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;