agaro1121

_complete_ssh_hosts ()
{
        COMPREPLY=()
        cur="${COMP_WORDS[COMP_CWORD]}"
        comp_ssh_hosts=`cat ~/.ssh/known_hosts | \
                        cut -f 1 -d ' ' | \
                        sed -e s/,.*//g | \
                        grep -v ^# | \
                        uniq | \
                        grep -v "\[" ;

agaro1121

package pc

import akka.actor.Actor
import akka.actor.Props
import akka.actor.ActorRef
import akka.actor.ActorRefFactory

class Parent extends Actor {
  val child = context.actorOf(Props[Child], "child")
  var ponged = false

agaro1121

/**
 * Takes a camel cased identifier name and returns an underscore separated
 * name
 *
 * Example:
 *     camelToUnderscores("thisIsA1Test") == "this_is_a_1_test"
 */
def camelToUnderscores(name: String) = "[A-Z\\d]".r.replaceAllIn(name, {m =>
  "_" + m.group(0).toLowerCase()
})

agaro1121

The process to view records in kinesis are as follows:

1. Get a shard iterator:

aws kinesis get-shard-iterator --shard-id shardId-000000000000 --shard-iterator-type LATEST --stream-name

2. Run your producer using kpl or anyother library and language.

3. Read records of the recently created shard iterator:

agaro1121

The vice versa can easily be done by including -p flag. But the way to expose ports of host machine to a docker container is bit convoluted, but can be done.

The steps are:

1. Create an alias for the ip you want to use.

sudo ifconfig lo0 alias 172.16.123.1

2. add the flag to docker:

agaro1121

Thread Pools

Thread pools on the JVM should usually be divided into the following three categories:

1. CPU-bound
2. Blocking IO
3. Non-blocking IO polling

Each of these categories has a different optimal configuration and usage pattern.

agaro1121

These are generic npm scripts that you can copy & paste into your package.json file as-is and get access to convinience scripts to manage your Docker images all in one place.

Looking for npm scripts for AWS ECS? Go here!

Watch the video: Do More With Less JavaScript

Docker Containers for Static or Angular/React/Vue/etc SPA Websites

• docker pull duluca/minimal-nginx-web-server
  • Documentation: https://hub.docker.com/r/duluca/minimal-nginx-web-server/
• docker pull duluca/minimal-node-web-server

agaro1121

import akka.actor.{ActorRef, ActorSystem}
import akka.stream.scaladsl.Sink
import com.weightwatchers.reactive.kinesis.consumer.KinesisConsumer
import com.weightwatchers.reactive.kinesis.stream._

object Main extends App {

  val sys = ActorSystem("kinesis-consumer-system")
  var consumer = Option.empty[KinesisConsumer]

agaro1121

/**
 * Module dependencies
 */
var request = require("superagent")
  , breaker = require("./breaker");

// Add the circuit breaker to the default middleware
request.middleware.push(breaker(3000));

// ...snip...

agaro1121

After scouring the internet and piece-mealing together the correct way to do this, here is a step-by-step, all-in-one-place guide to making logback STFU when running your unit tests.

Here's how to do it

Save the following as logback-test.xml under src/test/resources:

<configuration>
  <appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
    <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
      <pattern>%msg%n</pattern>