| package ca.underflow.hbase | |
| import org.hbase.async._ | |
| import com.stumbleupon.async._ | |
| object Demo extends App { | |
| // This let's us pass inline functions to the deferred | |
| // object returned by most asynchbase methods |
| /* | |
| Copyright 2012 Twitter, 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 |
Slightly disorganized but reasonably complete notes on the algorithms, strategies and optimizations of the Akka Cluster implementation. Could use a lot more links and context etc., but was just written for my own understanding. Might be expanded later.
Links to papers and talks that have inspired the implementation can be found on the 10 last pages of this presentation.
This is the Gossip state representation:
| #pragma once | |
| #include <cmath> | |
| #include <memory> | |
| #include <vector> | |
| #include <cassert> | |
| namespace sp { | |
| /** |
| import org.junit.Before; | |
| import org.junit.Test; | |
| import sun.misc.Unsafe; | |
| import sun.reflect.ReflectionFactory; | |
| import java.lang.reflect.Constructor; | |
| import java.lang.reflect.Field; | |
| import java.lang.reflect.Modifier; | |
| import static org.junit.Assert.assertEquals; |
This is specifically tailored to Node.js binding projects in which case the C++ layer is always a library.
Clone gyp:
git clone --depth 1 https://chromium.googlesource.com/external/gyp.git gyp
Add the below common.gypi file in the root of the project.
| package akkahttptest | |
| import akka.actor.ActorSystem | |
| import akka.http.Http | |
| import akka.stream.FlowMaterializer | |
| import akka.http.server._ | |
| import akka.http.marshalling.PredefinedToResponseMarshallers._ | |
| import akka.stream.scaladsl.{HeadSink, Source} | |
| object Proxy extends App { |