omnisis

#!/usr/bin/env python

""""
nexus-uploader.py

Allows mirroring local M2 repositories to a remote Nexus server with a single command.
Supports: 
   - uploading of common classifiers (sources, javadocs) if available
   - using regex include pattern for artifactIds/groupIds
   - recursively processing local repo, just point to the root 

omnisis

<broker>
    <transportConnectors>
      <!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
      <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
      <transportConnector name="ssl" uri="ssl://0.0.0.0:61617?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600&amp;needClientAuth=true"/>
    </transportConnectors>
  
    <plugins>
      <jaasDualAuthenticationPlugin configuration="activemq-domain" sslConfiguration="activemq-ssl-domain"/>
    </plugins>

omnisis

package examples.database;

import com.google.common.collect.Lists;
import examples.database.dao.PeopleDAO;
import examples.database.model.PeopleInfo;
import org.apache.commons.lang.time.StopWatch;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.junit.Test;
import org.junit.runner.RunWith;

omnisis

require 'bindata'

class CustomProtocol < BinData::Record
    endian  :big
    stringz :command_word
    uint8   :op1
    uint8   :op2
end

omnisis

package com.nextinstruction.scalacommands

object Commands extends App {
  import org.rogach.scallop._
  import org.rogach.scallop.exceptions._

  class ToolConf(toolArgs: Seq[String]) extends ScallopConf(toolArgs) {
    //version("\nv0.0.1 (c) Not Implemented Industries, LLC.")
    banner("""
      |usage: git [--version] [--help] [-C <path>] [-c name=value]

omnisis

pipeline {
    agent { node { label 'swarm-ci' } }

    environment {
        TEST_PREFIX = "test-IMAGE"
        TEST_IMAGE = "${env.TEST_PREFIX}:${env.BUILD_NUMBER}"
        TEST_CONTAINER = "${env.TEST_PREFIX}-${env.BUILD_NUMBER}"
        REGISTRY_ADDRESS = "my.registry.address.com"

        SLACK_CHANNEL = "#deployment-notifications"

omnisis

Infrastructure

Hystrix

Hystrix is a latency and fault tolerance library designed to isolate points of access to remote systems, services and 3rd party libraries, stop cascading failure and enable resilience in complex distributed systems where failure is inevitable.

Cloud/BigData Development

Genie

Genie is a completely open source federated job orchestration engine developed by Netflix. Genie provides REST-ful APIs to run a variety of big data jobs like Hadoop, Pig, Hive, Spark, Presto, Sqoop and more. It also provides APIs for managing the metadata of many distributed processing clusters and the commands and applications which run on them.

Conductor

omnisis

package examples.utils


object AnsiColors {

  val ANSI_RESET    = "\u001B[0m"
  val ANSI_BLACK    = "\u001B[30m"
  val ANSI_RED      = "\u001B[31m"
  val ANSI_GREEN    = "\u001B[32m"
  val ANSI_YELLOW   = "\u001B[33m"

omnisis

package examples.webserver

import java.sql.Timestamp
import java.util.Date

import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.http.scaladsl.marshallers.sprayjson.SprayJsonSupport
import akka.http.scaladsl.model._
import akka.http.scaladsl._

omnisis

(* helper functions *)
exception AssertionFailure;
fun println(msg) = print(msg ^ "\n");
fun printStatusWithWidth(label, msg, width) = println("\t- " ^ (StringCvt.padRight #" "  width msg) ^ label);
fun printStatus(label, msg) = printStatusWithWidth(label,msg,80)

fun msg_pass(msg) = printStatus("[ PASS ]", msg);
fun msg_fail(msg) = printStatus("[ FAIL ]", msg);