alexeyryzhikov

GOTO 2014 • Microservices • Martin Fowler
https://www.youtube.com/watch?v=wgdBVIX9ifA

https://www.youtube.com/watch?v=GBTdnfD6s5Q
GOTO 2020 • When To Use Microservices (And When Not To!) • Sam Newman & Martin Fowler

https://www.youtube.com/watch?v=9I9GdSQ1bbM
GOTO 2019 • Monolith Decomposition Patterns • Sam Newman

https://www.youtube.com/watch?v=57UK46qfBLY

alexeyryzhikov

@SuppressWarnings("unchecked")
public static <T extends Throwable> RuntimeException unchecked(Throwable t) throws T {
    throw (T) t;
}

alexeyryzhikov

Promise<String> p1 = new Promise<>();

Function0<Future<String>> mkPromise = Function.ofCallable(() -> {
    Promise<String> promise = new Promise<>();

    p1.onSuccess(Function.cons(res -> {
        // Thrown exception will be caught by Monitor.catcher (see Promise.Monitored.apply)
        Throwables.propagate(new NullPointerException());
        promise.setValue("Done");
    }));

alexeyryzhikov

package com.greenwave.training.monitoring.rest.service;

import com.greenwave.training.monitoring.rest.dto.MonitorMessage;

public interface NotificationListener {

    void onMessage(MonitorMessage message);

}

alexeyryzhikov

INFO  10:04:28 Harmless error reading saved cache /home/alexey/dev/projects/axon/tools/apache-cassandra-3.7/bin/../data/saved_caches/KeyCache-e.db
java.lang.RuntimeException: Cache schema version 16099a89-2b3f-3d98-b191-e277722750a0 does not match current schema version f1450460-2d02-35f8-aae4-8ef34ad1bcb4
  at org.apache.cassandra.cache.AutoSavingCache.loadSaved(AutoSavingCache.java:200) ~[apache-cassandra-3.7.jar:3.7]
  at org.apache.cassandra.cache.AutoSavingCache$3.call(AutoSavingCache.java:159) [apache-cassandra-3.7.jar:3.7]
  at org.apache.cassandra.cache.AutoSavingCache$3.call(AutoSavingCache.java:155) [apache-cassandra-3.7.jar:3.7]
  at java.util.concurrent.FutureTask.run(FutureTask.java:266) [na:1.8.0_111]
  at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [na:1.8.0_111]
  at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [na:1.8.0_111]
  at java.lang.Thread.run(Thread.java:745) [na:1.8.0_111]
INFO  10:04:28 Completed loading (8 ms; 1

alexeyryzhikov

@Component
class BufferComponent<T>{

    private transient List<Message<T>> buffer;

    @Inject
    private Config config;

    @Output
    private Out<List<T>> output;

alexeyryzhikov

import sys
import socket
import datetime
import time
from threading import Thread

def get_host_and_port():
  args = sys.argv
  arg_count = len(args)

alexeyryzhikov

root@pve:/raid-pool# cat /proc/meminfo 
MemTotal:       65917384 kB
MemFree:        21318560 kB
MemAvailable:   21319668 kB
Buffers:            5316 kB
Cached:           148020 kB
SwapCached:         6996 kB
Active:         12449036 kB
Inactive:         246540 kB
Active(anon):   12395648 kB

alexeyryzhikov

_this.isPropertyNameSubstringOfAnotherProperty = function(propertyName) {
    var isValid = true;
    _.each(_this.configurationProperties, function(propertyValue, propertyKey) {
        if (isOneStartOfAnother(propertyName, propertyKey)) {
            isValid = false;
        }
    });
    return isValid;
};

alexeyryzhikov

import java.util.Properties;

import com.google.common.base.Charsets;
import com.google.common.collect.ImmutableList;

import org.apache.kafka.clients.CommonClientConfigs;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.ConsumerRecords;
import org.apache.kafka.clients.consumer.KafkaConsumer;