farukonder

package com.github.farukonder.experimenting.frp.rxjava2.simple;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;

import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;

public class Schedulers3LevelNonBlocking {

farukonder

package com.github.farukonder.experimenting.frp.rxjava2.simple;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;

import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;

public class Schedulers3LevelBlocking {

farukonder

package com.github.farukonder.experimenting.frp.rxjava2.simple;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;

import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;

public class Schedulers2LevelNonBlocking {

farukonder

package com.github.farukonder.experimenting.frp.rxjava2.simple;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;

import io.reactivex.Observable;
import io.reactivex.schedulers.Schedulers;

public class Schedulers2LevelBlocking {

farukonder

faruk@faruk-VirtualBox:~/istio/istio101/workshop/plans$ kubectl exec -n istio-system -it istio-ingressgateway-7f4dd7d699-qjdkc bash
root@istio-ingressgateway-7f4dd7d699-qjdkc:/# netstat -an
Active Internet connections (servers and established)
Proto Recv-Q Send-Q Local Address           Foreign Address         State      
tcp        0      0 127.0.0.1:15000         0.0.0.0:*               LISTEN     
tcp        0      0 0.0.0.0:14000           0.0.0.0:*               LISTEN     
tcp        0      0 172.30.154.231:40914    172.30.154.224:3000     ESTABLISHED
tcp        0      0 172.30.154.231:56078    172.30.154.247:3000     ESTABLISHED
tcp        0      0 172.30.154.231:54080    172.30.154.200:3000     ESTABLISHED
tcp        0      0 172.30.154.231:43138    172.21.16.5:9411        ESTABLISHED

farukonder

faruk@faruk-VirtualBox:~/istio/istio101/workshop/plans$ kubectl get pods -n istio-system
NAME                                        READY     STATUS      RESTARTS   AGE
grafana-6cbdcfb45-jwqmq                     1/1       Running     1          6d
istio-citadel-6b6fdfdd6f-mdxpd              1/1       Running     1          6d
istio-cleanup-secrets-zhrtn                 0/1       Completed   0          6d
istio-egressgateway-56bdd5fcfb-vwhmh        1/1       Running     2          6d
istio-egressgateway-56bdd5fcfb-vx6r6        1/1       Running     0          6m
istio-galley-96464ff6-fjrwp                 1/1       Running     1          6d
istio-grafana-post-install-xvlvf            0/1       Completed   4          6d
istio-ingressgateway-7f4dd7d699-qjdkc       1/1       Running     0          1d

farukonder

apiVersion: networking.istio.io/v1alpha3
kind: VirtualService
metadata:
  name: virtual-service-guestbook
spec:
  hosts:
    - '*'
  gateways:
    - guestbook-gateway
  http:

farukonder

apiVersion: v1
kind: Service
metadata:
  name: guestbook
  labels:
    app: guestbook
spec:
  # comment or delete the following line if you want to use a LoadBalancer
  # type: NodePort
  # if your cluster supports it, uncomment the following to automatically create

farukonder

apiVersion: networking.istio.io/v1alpha3
kind: VirtualService
metadata:
  name: virtual-service-guestbook
spec:
  hosts:
    - '*'
  gateways:
    - guestbook-gateway
  http:

farukonder

apiVersion: networking.istio.io/v1alpha3
kind: Gateway
metadata:
  name: guestbook-gateway
spec:
  selector:
    istio: ingressgateway # use istio default controller
  servers:
  - port:
      number: 14000