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

package com.blazemeter.dagger.domains.aggregate;

import com.blazemeter.dagger.domains.aggregate.port.AggregateRepository;
import com.blazemeter.dagger.domains.common.CollectionService;
import org.apache.commons.lang3.RandomUtils;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
import org.mockito.ArgumentMatchers;
import org.mockito.Mockito;
import org.springframework.beans.factory.annotation.Autowired;

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

fun digest(file: File, algorithm: String): String {
    val contents = file.readBytes()
    val messageDigest = MessageDigest.getInstance(algorithm)
    val digestBytes = messageDigest.digest(contents)

    return String.format("%032x", BigInteger(1, digestBytes)).substring(0..9)
}

project(":jetpack").configure {
    apply(plugin = "com.github.johnrengelman.shadow")

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