mustafaakin

receivers:
  - name: "alerts"
    opsgenie:
      apiKey: xxx
      priority: "P3"
      message: "Event {{ .Reason }} for {{ .InvolvedObject.Namespace }}/{{ .InvolvedObject.Name }} on K8s cluster"
      alias: "{{ .UID }}"
      description: "<pre>{{ toPrettyJson . }}</pre>"
      tags:
        - "event"

mustafaakin

route:
  # Main route
  routes: 
    # This route allows dumping all events because it has no fields to match and no drop rules.
    - match:
      - receiver: dump
    # This starts another route, drops all the events in *test* namespaces and Normal events 
    # for capturing critical events 
    - drop:
      - namespace: "*test*"

mustafaakin

import os
import sqlite3

import cv2
import numpy as np


def score(filename):
    image = cv2.imread(filename)
    gray = cv2.cvtColor(image, cv2.COLOR_BGR2GRAY)

mustafaakin

import org.apache.commons.lang3.time.StopWatch;
import org.apache.commons.math3.ml.clustering.CentroidCluster;
import org.apache.commons.math3.ml.clustering.Clusterable;
import org.apache.commons.math3.ml.clustering.DoublePoint;
import org.apache.commons.math3.ml.clustering.KMeansPlusPlusClusterer;
import org.apache.commons.math3.random.*;

import java.util.ArrayList;
import java.util.List;
import java.util.Random;

mustafaakin

mustafaakin

System.loadLibrary("Hello");
start();
while (true) {
  String request = readRequest();
  KMeansResult response = kMeans.calculate(request);
  String response = response.toString();
  writeResponse(response);
  }
}

mustafaakin

func communicateJava(input interface{}) (interface{}, error) {
  inBytes, err := json.Marshal(input)
  inputStr := string(inBytes)
  goRequest <- inputStr
  respStr := <-javaResponse
  var resp interface{}
  err = json.Unmarshal([]byte(respStr), &resp)
}

//export Java_Test_start

mustafaakin

import org.json.JSONObject;
import org.json.JSONTokener;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

public class Test {

mustafaakin

SELECT destinationaddress,
  SUM(bytes) AS totalBytes
  FROM flows TABLESAMPLE SYSTEM (10)
GROUP BY destinationaddress
ORDER BY totalBytes DESC LIMIT 10

mustafaakin

SELECT sum(packets) AS total,
  split_part(sourceaddress,’.’, 1) = ‘10’ AS isInternal,
  action
FROM flows
GROUP BY 2, action
ORDER BY total DESC LIMIT 10