pgilad

#!/bin/bash

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

pgilad

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")

pgilad

#!/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

pgilad

    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));

pgilad

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

pgilad

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;

pgilad

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;

pgilad

tasks.withType(AbstractArchiveTask) {
    preserveFileTimestamps = false
    reproducibleFileOrder = true
}

springBoot {
    mainClassName = 'com.blazemeter.dagger.DaggerApplication'
    buildInfo {
        properties {
             time = null

pgilad

import _ from 'lodash';
import produce from 'immer';
import { IAccount } from '../../types/account';
import { IData, IModifiable, ProduceRecipe } from '../metadata';

/**
 * An account model
 */
export class Account implements IModifiable<IAccount>, IData<IAccount> {
    readonly data: Readonly<IAccount>;

pgilad

const ts = require('typescript');
const tsConfig = require('./tsconfig.json');

const config = tsConfig.compilerOptions;

function compile(fileNames, options) {
    if (fileNames.filter(Boolean).length === 0) {
        console.log('No files');
        return;
    }