mccraigmccraig of the clan mccraig mccraigmccraig
mccraigmccraig
/ blah2
Created
October 2, 2019 12:58
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| blah |
mccraigmccraig
/ blah
Created
October 1, 2019 11:43
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| blah |
mccraigmccraig
/ overnight import CN issue logs
Created
May 23, 2019 14:28
This file has been truncated, but you can view the full file.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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 | |
| KAFKA_BOOTSTRAP_SERVERS: yapster-kafka-kafka-bootstrap.kafka.svc.cluster.local:9092 |
mccraigmccraig
/ prws_test.cljc
Created
November 1, 2018 18:42
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| (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]] |
mccraigmccraig
/ test.cljc
Created
November 1, 2018 18:40
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| (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]))) |
mccraigmccraig
/ cn_perms.clj
Created
October 26, 2018 09:43
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| {;; 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 |
mccraigmccraig
/ java_producer.clj
Created
October 25, 2018 22:08
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| (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]) |
mccraigmccraig
/ serde.clj
Created
October 25, 2018 21:55
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| (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])) |
mccraigmccraig
/ serializers.clj
Created
October 25, 2018 21:55
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| (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 |
mccraigmccraig
/ deserializers.clj
Created
October 25, 2018 21:55
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| (ns er-model.connectors.kafka.deserializers | |
| (:require | |
| [clojure.edn :as edn]) | |
| (:import | |
| [org.apache.kafka.common.serialization | |
| Deserializer | |
| StringDeserializer | |
| LongDeserializer | |
| IntegerDeserializer | |
| ByteArrayDeserializer] |
NewerOlder