Skip to content

Instantly share code, notes, and snippets.

Avatar

mccraigmccraig of the clan mccraig mccraigmccraig

View GitHub Profile
View overnight import CN issue logs
This file has been truncated, but you can view the full file.
ETH0_IP_ADDRESS: 10.0.7.207
PROXY_IP_ADDRESS: 169.254.1.1
MAX_MEMORY: 2048m
MAX_DIRECT_MEMORY: 2048m
SYSTEM_ID: yapster_20180514
ENV: production
CASSANDRA_CONTACT_POINTS: 10.0.6.135,10.0.6.104
CASSANDRA_KEYSPACE: yapster_20180514
CASSANDRA_DC: dc_cassandra
View prws_test.cljc
(ns prpr.cats.prws-test
(:require
#?(:clj [prpr.cats.prws :as sut :refer [prwsdo]]
:cljs [prpr.cats.prws :as sut :refer [PRWS_V_T] :refer-macros [prwsdo]])
[cats.core :as monad :refer [>>= return]]
[cats.context :refer [with-context]]
[cats.monad.state :as state]
#?(:clj [prpr.promise :as prpr :refer [ddo]]
:cljs [prpr.promise :as prpr :refer-macros [ddo]])
#?(:clj [prpr.test :refer [deftest test-async is testing]]
View test.cljc
(ns prpr.test
#?(:clj (:require
[prpr.util.macro :refer [if-cljs]]
[clojure.test :as t]
[prpr.promise :as prpr])
:cljs (:require
[prpr.util.macro :refer-macros [if-cljs]]
[cljs.test :as t :refer-macros [async]]
[prpr.promise :as prpr])))
View cn_perms.clj
{;; this defines hierarchy-type and hierarchy-id attachments of
;; heritable-attrs and heritable-perms
:er-model.importer.import-sources/hierarchy-metadata
{"group"
;; attachments by hierarchy-type id
{:er-model.importer.import-objects/group-type-id
{;; hierarchytype 1 - root
"[[H]]1"
{:h_attrs
View java_producer.clj
(ns er-model.connectors.kafka.java-producer
(:require
[taoensso.timbre :refer [debug info warn]]
[er-model.connectors.kafka.zk :as kafka.zk]
[er-model.connectors.kafka :as c.kafka]
[er-model.connectors.kafka.serializers :as kafka.ser]
[er-model.connectors.kafka.deserializers :as kafka.deser]
[er-model.connectors.kafka.config :as cfg]
[clj-uuid :as uuid]
[manifold.deferred :as deferred])
View serde.clj
(ns er-model.connectors.kafka.serde
(:require
[er-model.connectors.kafka.serializers :as k.ser]
[er-model.connectors.kafka.deserializers :as k.deser])
(:import
[org.apache.kafka.common.serialization
Serde
Serdes
Serdes$StringSerde
Serdes$WrapperSerde]))
View serializers.clj
(ns er-model.connectors.kafka.serializers
(:import (org.apache.kafka.common.serialization
LongSerializer
Serializer
IntegerSerializer
StringSerializer
ByteArraySerializer)
(java.io ByteArrayOutputStream)))
;; from https://github.com/ymilky/franzy/blob/master/src/franzy/serialization/serializers.clj
View deserializers.clj
(ns er-model.connectors.kafka.deserializers
(:require
[clojure.edn :as edn])
(:import
[org.apache.kafka.common.serialization
Deserializer
StringDeserializer
LongDeserializer
IntegerDeserializer
ByteArrayDeserializer]