r5.2xlarge instance in eu-west-1 with 200 GB EBS io1 volume and 3000 IOPS.
package de.mazdermind; | |
import java.io.IOException; | |
import java.nio.ByteBuffer; | |
import java.nio.CharBuffer; | |
import java.nio.channels.ClosedChannelException; | |
import java.nio.channels.SocketChannel; | |
import java.nio.charset.Charset; | |
import java.nio.charset.CharsetDecoder; | |
import java.nio.charset.CharsetEncoder; |
Go is an imperative, compiled, statically-typed, garbage-collected, concurrent, general purpose programming language. It emphasizes fast compilation, fast execution, and a conservative, simple language design.
Go has modern, native implementations of many networking protocols.
python testsqlite.py 10000 :memory: 0 | |
6.65568494797 seconds to do 10000 records db=:memory:, triggers=False | |
6.66251087189 seconds to do 10000 records db=:memory:, triggers=False | |
6.69321203232 seconds to do 10000 records db=:memory:, triggers=False | |
python testsqlite.py 10000 :memory: 1 | |
6.76699709892 seconds to do 10000 records db=:memory:, triggers=True | |
6.82708096504 seconds to do 10000 records db=:memory:, triggers=True | |
6.82913088799 seconds to do 10000 records db=:memory:, triggers=True |
Concurrent applications also make optimal use of the processors. But concurrent applications are difficult to develop, maintain, and debug. To develop thread-safe, high-performance, and scalable applications, Java’s low-level threading capabilities are insufficient.
The java.util.concurrent package includes a number of additions to the Java Collections Framework. These are most easily categorized by the collection interfaces provided:
BlockingQueue
defines a first-in-first-out data structure that blocks or times out when you attempt to add items to a full queue, or retrieve from an empty queue.
https://github.com/wesleyduff/microservicesNode
aws iam create-group --group-name kops
aws iam attach-group-policy --group-name kops \
package main | |
import ( | |
"encoding/json" | |
"flag" | |
"io/ioutil" | |
"log" | |
"net" | |
"os" | |
"os/signal" |
upstream warehouse_inventory { | |
zone inventory_service 64k; | |
server 10.0.0.1:80; | |
server 10.0.0.2:80; | |
server 10.0.0.3:80; | |
} | |
upstream warehouse_pricing { | |
zone pricing_service 64k; | |
server 10.0.0.7:80; |
// Creating a Mono containing "Hello World !". | |
Mono<String> helloWorld = Mono.just("Hello World !"); | |
// Creating an empty Mono | |
Mono<T> empty = Mono.empty(); | |
// Creating a mono from a Callable | |
Mono<String> helloWorldCallable = Mono.fromCallable(() -> "Hello World !"); | |
// Same with Java 8 method reference | |
Mono<User> user = Mono.fromCallable(UserService::fetchAnyUser); |