srfrnk

"livenessProbe": {
    "exec": {
        "command": [
            "/app/check.sh"
        ]
    },
    "initialDelaySeconds": 30,
    "periodSeconds": 10
},

srfrnk

#!/usr/bin/env bash
trap : TERM INT

echo "Waiting for jar..."
until [ -f ${jarPath} ]
do
     sleep 1
done

jobProps=$(eval echo "${jobProps}")

srfrnk

const express = require('express');
const bodyParser = require('body-parser');
const path = require('path');
const fs = require('fs');

.
.
.

var app = express();

srfrnk

{
  apiVersion: 'apiextensions.k8s.io/v1beta1',
  kind: 'CustomResourceDefinition',
  metadata: {
    name: 'flinkjobs.operators.srfrnk.com',
    namespace: 'flink',
  },
  spec: {
    group: 'operators.srfrnk.com',
    version: 'v1',

srfrnk

FlinkPipelineOptions pipelineOptions =PipelineOptionsFactory.create().as(FlinkPipelineOptions.class);
pipelineOptions.setJobName(jobName);
pipelineOptions.setRunner(FlinkRunner.class);
pipelineOptions.setParallelism(1);
pipelineOptions.setStreaming(false);
Pipeline p = Pipeline.create(pipelineOptions);

p.apply(Create.of("To be, or not to be: that is the question:",
        "Whether 'tis nobler in the mind to suffer", "The slings and arrows of fortune,",
        "Or to take arms against a sea of troubles,"))

srfrnk

package com.spotify.client;

public class ClientAds {
  public boolean showAd(User user,AdDetails ad)
  {
        if(user.fullname.equals("ShaharFrank") && ad.style==Styles.OmerAdam)
        {
            return false;
        }
    return true;

srfrnk

(function(angular) {
  "use strict";
  angular.module("ng.canvas", [])
    .directive('canvas', ["$timeout",
      function($timeout) {
        return {
          restrict: "E",
          link: function(scope, elm , attrs ) {
            scope[attrs.context2d||"context2d"]=elm[0].getContext("2d");
            $timeout(function(){scope.$eval(attrs.init||"canvasInit()")});

srfrnk

require("requirejs").define("models/localCache", [], function () {
    var cache = require('memory-cache');
    return function () {
        return function (req, res, next) {
            if (!!req.localCache) {
                return next();
            }
            var sessionId = req.cookies["connect.sid"];
            req.localCache = cache.get(sessionId) || {};
            res.on('finish', function () {

srfrnk

define("directives/nuget", ["app"], function (app) {
    var nugets = [];

    return app.directive('nuget', [function () {
        return {
            restrict: "E",
            transclude: true,
            link: function (scope, elm, attrs, ctrl, transclude) {
                nugets.push({
                    name: attrs.name,

srfrnk

require("requirejs").define("models/sqlServerHelper", [], function () {
	var Q = require("q");
	var Connection = require('tedious').Connection;
	var Request = require('tedious').Request;
	var Enum = require("linq");

	var sqlServerHelper = {
		connect: function () {
			var connectDefer = Q.defer();