Gilad Peleg pgilad

## docker-compose-opt.service
# File: /etc/systemd/system/docker-compose-opt.service

[Unit]
Description=Docker Compose Opt Service
Requires=docker.service network-online.target
After=docker.service network-online.target

[Service]
WorkingDirectory=/opt/applications
Type=oneshot

## apache-zeppelin.rb
class ApacheZeppelin < Formula
  desc "Web-based notebook that enables interactive data analytics"
  homepage "https://zeppelin.apache.org"
  url "http://archive.apache.org/dist/zeppelin/zeppelin-0.7.3/zeppelin-0.7.3-bin-all.tgz"
  sha256 "7e657df51ecfd4aad39d42f8578409692244d36b2da92b5dbd3b6957b829bf58"
  head "https://github.com/apache/zeppelin.git"

  bottle :unneeded

  def install

## get-token.fish
#!/usr/bin/env fish

kubectl -n kube-system describe secrets (kubectl -n kube-system get secrets | awk '/clusterrole-aggregation-controller/ {print $1}') | awk '/token:/ {print $2}'

## kube-resources.sh
#!/bin/bash

kubectl api-resources --verbs=list --namespaced -o name | xargs -n 1 kubectl get --show-kind --ignore-not-found

## DemoController.java
package com.example.demo;

import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Mono;

@RestController
public class DemoController {

    @GetMapping("/ping")

## popular-git-message.sh
#!/bin/bash

git log --author='giladp007@gmail.com' --pretty=format:%s | sed -r 's/WAP-[0-9]*\s+//g' | tr '[:upper:]' '[:lower:]' | sort | uniq -c | sort -nr | head -5

## DataProcessor.java
    public static void main(String[] args) throws InterruptedException {
        final Flux<Long> longFlux = Flux.interval(Duration.ofSeconds(1))
            .doOnSubscribe(e -> log.info("SUBSCRIBE"))
            .doOnTerminate(() -> log.info("TERMINATE"))
            .doOnComplete(() -> log.info("COMPLETE"))
            .doOnCancel(() -> log.info("CANCEL"))
            .doOnNext(s -> log.info("NEXT {}", s))
            .replay()
            .refCount(2, Duration.ofSeconds(1));

## Dockerfile
FROM amazonlinux:latest

RUN yum -y update && yum install -y gcc python-devel zip which

RUN curl https://bootstrap.pypa.io/get-pip.py | python -
RUN pip install pipenv

ENV LANG en_US.UTF-8
ENV LC_ALL en_US.UTF-8
ENV SOURCE_DIR lambdas

## Deployment.java
package com.blazemeter;

import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import io.kubernetes.client.ApiClient;
import io.kubernetes.client.ApiException;
import io.kubernetes.client.Configuration;
import io.kubernetes.client.apis.AppsV1beta1Api;
import io.kubernetes.client.models.AppsV1beta1Deployment;

## DataSender.java
package data;

import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
import reactor.netty.ByteBufFlux;
import reactor.netty.http.client.HttpClient;
import reactor.retry.Retry;
import settings.Settings;